Skip to content

Commit cd49634

Browse files
authored
MINOR: Rename streams group configs for consistency with other configuration settings. (#19360)
This is a fix for the naming in ff785ac. Reviewers: Lucas Brutschy <[email protected]>
1 parent 25f9b1e commit cd49634

File tree

1 file changed

+3
-3
lines changed
  • group-coordinator/src/main/java/org/apache/kafka/coordinator/group

1 file changed

+3
-3
lines changed

group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupConfig.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -59,11 +59,11 @@ public final class GroupConfig extends AbstractConfig {
5959
"Negative duration is not allowed.</li>" +
6060
"<li>anything else: throw exception to the share consumer.</li></ul>";
6161

62-
public static final String STREAMS_SESSION_TIMEOUT_MS_CONFIG = "group.streams.session.timeout.ms";
62+
public static final String STREAMS_SESSION_TIMEOUT_MS_CONFIG = "streams.session.timeout.ms";
6363

64-
public static final String STREAMS_HEARTBEAT_INTERVAL_MS_CONFIG = "group.streams.heartbeat.interval.ms";
64+
public static final String STREAMS_HEARTBEAT_INTERVAL_MS_CONFIG = "streams.heartbeat.interval.ms";
6565

66-
public static final String STREAMS_NUM_STANDBY_REPLICAS_CONFIG = "group.streams.num.standby.replicas";
66+
public static final String STREAMS_NUM_STANDBY_REPLICAS_CONFIG = "streams.num.standby.replicas";
6767

6868
public final int consumerSessionTimeoutMs;
6969

0 commit comments

Comments
 (0)