David J. Garcia created KAFKA-9568:
--------------------------------------
Summary: Kstreams APPLICATION_SERVER_CONFIG is not updated with
static membership
Key: KAFKA-9568
URL: https://issues.apache.org/jira/browse/KAFKA-9568
Project: Kafka
Issue Type: Bug
Components: streams
Affects Versions: 2.4.0
Reporter: David J. Garcia
A kstreams application with static membership, and
StreamsConfg.APPLICATION_SERVER_CONFIG set, will NOT update old server config
upon restart of application on new host.
Steps to reproduce:
# start two kstreams applications (with same consumer group) and enable static
membership (and set application server config to <ip-addr>:<port>)
# kill one of the applications and restart it on a new host(with new ip)
before timeout ends (so that rebalancing doesn't occur).
# the other kstreams application will now have an invalid
application_server_config
Possible fix:
If an application restarts with a new host/identity..etc, it could trigger a
"light-rebalance" where the other applications in the consumer group don't
change partition assignments ,but instead just get their configuration updated.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)