k-apol opened a new pull request, #19913: URL: https://github.com/apache/kafka/pull/19913
This PR implements the init() method described in KIP-698 to allow users to validate or prepare internal Kafka Streams topics before starting the application. The changes include: Introduced a public init() method on KafkaStreams, which performs internal topic validation and optionally sets up missing topics. Added support for a new configuration option, internal.topics.setup, with 'automatic' and 'manual' as options to control default internal topic management. Updated InternalTopicManager to expose validate, and allow for a separate initialization timeout. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
