k-apol commented on code in PR #19913:
URL: https://github.com/apache/kafka/pull/19913#discussion_r2144965738
##########
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java:
##########
@@ -569,7 +579,7 @@ public Set<String> makeReady(final Map<String,
InternalTopicConfig> topics) {
}
}
log.debug("Completed validating internal topics and created {}",
newlyCreatedTopics);
-
+ this.isInitializing = false;
return newlyCreatedTopics;
Review Comment:
Edit: Removed this in recent change. Per @mjsax , I got rid of the state
introduced here and just created an overload that will be called from init
--
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
