...
If configuration INTERNAL_TOPIC_SETUP
is set to MANUAL_SETUP
, the group leader will not set up internal topics during a rebalance but users need to call KafkaStreams#init()
to set up the internal topics. If the internal topics do not exist during a rebalance because KafkaStreams#init()
has not been called or one or more internal topics have been deleted, a MissingInternalTopicsException
is thrown in each Kafka Streams client. If during a rebalance the group leader realizes that an internal topic is misconfigured, a MisconfiguredInternalTopicException
is thrown in each Kafka Streams client.
...