KAFKA-8284: enable static membership on KStream#6673
Conversation
|
@abbccdda failures seem related |
|
@bbejeck Thanks for the info! |
31ac81d to
91c3ac8
Compare
guozhangwang
left a comment
There was a problem hiding this comment.
Have some minor questions on whether it is necessary to define this on the streams config level, otherwise lgtm.
| consumerConfigs.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "none"); | ||
| } | ||
|
|
||
| final String streamGroupInstanceId = config.getString(ConsumerConfig.GROUP_INSTANCE_ID_CONFIG); |
There was a problem hiding this comment.
Let's move this logic into getMainConsumerConfigs directly for cleanness?
| "", | ||
| Importance.MEDIUM, | ||
| CLIENT_ID_DOC) | ||
| .define(ConsumerConfig.GROUP_INSTANCE_ID_CONFIG, |
There was a problem hiding this comment.
Do we have to define it on the StreamsConfig level?
| Type.STRING, | ||
| null, | ||
| Importance.MEDIUM, | ||
| ConsumerConfig.GROUP_INSTANCE_ID_CONFIG) |
There was a problem hiding this comment.
It should be xx_DOC string.
|
Thanks for the review @guozhangwang. Updated the injection path to extract the config value from original consumer config, and refactor the |
guozhangwang
left a comment
There was a problem hiding this comment.
Just one minor, otherwise lgtm.
We can merge it afterwards and green builds.
…s-hashcode * apache-github/trunk: KAFKA-8158: Add EntityType for Kafka RPC fields (apache#6503) MINOR: correctly parse version OffsetCommitResponse version < 3 KAFKA-8284: enable static membership on KStream (apache#6673) KAFKA-8304: Fix registration of Connect REST extensions (apache#6651) KAFKA-8275; Take throttling into account when choosing least loaded node (apache#6619) KAFKA-3522: Interactive Queries must return timestamped stores (apache#6661) MINOR: MetricsIntegrationTest should set StreamsConfig.STATE_DIR_CONFIG (apache#6687) MINOR: Remove unused field in `ListenerConnectionQuota` KAFKA-8131; Move --version implementation into CommandLineUtils (apache#6481) KAFKA-8056; Use automatic RPC generation for FindCoordinator (apache#6408) MINOR: Remove workarounds for lz4-java bug affecting byte buffers (apache#6679) KAFKA-7455: Support JmxTool to connect to a secured RMI port. (apache#5968) MINOR: Document improvement (apache#6682) MINOR: Fix ThrottledReplicaListValidator doc error. (apache#6537) KAFKA-8306; Initialize log end offset accurately when start offset is non-zero (apache#6652)
Part of KIP-345 effort. The strategy is to extract user passed in group.instance.id config and pass it in with given thread-id (because consumer is currently per-thread level). Reviewers: Guozhang Wang <wangguoz@gmail.com>
…am (apache#6779) As title states. We plan to merge this to both trunk and 2.3 if it could fix the stream system tests globally. Reference implementation: apache#6673 Reviewers: Guozhang Wang <wangguoz@gmail.com>, Matthias J. Sax <mjsax@apache.org>
Part of KIP-345 effort. The strategy is to extract user passed in
group.instance.idconfig and pass it in with given thread-id (because consumer is currently per-thread level).Committer Checklist (excluded from commit message)