File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
group-coordinator/src/main/java/org/apache/kafka/coordinator/group Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff 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
You can’t perform that action at this time.
0 commit comments