[
https://issues.apache.org/jira/browse/KAFKA-18652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Brutschy updated KAFKA-18652:
-----------------------------------
Labels: kip1071 (was: )
> Extended set of streams-specific broker configurations
> ------------------------------------------------------
>
> Key: KAFKA-18652
> URL: https://issues.apache.org/jira/browse/KAFKA-18652
> Project: Kafka
> Issue Type: Sub-task
> Components: streams
> Reporter: Lucas Brutschy
> Priority: Major
> Labels: kip1071
>
> Add the broker-side configurations to enable the high-availability assignor /
> warm-up tasks (for EA).
>
> h4. New properties
> ||Name||Type||Default||Doc||
> |group.streams.min.session.timeout.ms|int|45s|The minimum session timeout.|
> |group.streams.max.session.timeout.ms|int|60s|The maximum session timeout.|
> |group.streams.min.heartbeat.interval.ms|int|5s|The minimum heartbeat
> interval.|
> |group.streams.max.heartbeat.interval.ms|int|15s|The maximum heartbeat
> interval.|
> |group.streams.acceptable.recovery.lag|long|10’000|The maximum acceptable lag
> (number of offsets to catch up) for a client to be considered caught-up
> enough to receive an active task assignment.|
> |group.streams.num.warmup.replicas|int|2|The maximum number of warmup
> replicas.|
> |group.streams.max.warmup.replicas|int|20|Maximum for dynamic configurations
> of the warmup replica configuration|
> |group.streams.task.offset.interval.ms|int|60s|The interval in which the task
> changelog offsets on a client are updated on the broker. The offsets are sent
> with the next heartbeat after this time has passed.|
> |group.streams.min.task.offset.interval.ms|int|15s|Minimum for dynamic
> configurations of the task offset interval. Used to restrict users of the
> cluster from sending the task changelog offsets too often.|
> |group.streams.assignor.name|string|null|The name of the task assignor used
> for all streams groups. Can be {{sticky}} or {{highly_available}} in AK.|
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
