showuon commented on a change in pull request #8712:
URL: https://github.com/apache/kafka/pull/8712#discussion_r436479515
##########
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java
##########
@@ -59,6 +59,9 @@ private InternalAdminClientConfig(final Map<?, ?> props) {
private final int retries;
private final long retryBackOffMs;
+ private int remainingRetries;
+
+ private HashSet<String> leaderNotAvailableTopics = new HashSet<>();
Review comment:
Oh, Nice catch! You're correct, @abbccdda , it might have a non-empty
leaderNotAvailableTopics after each call to `makeReady`. I changed it to using
local variable. Thank you.
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
