vvcephei commented on a change in pull request #8662:
URL: https://github.com/apache/kafka/pull/8662#discussion_r425330736
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java
##
@@ -169,6 +173,9 @@ public void makeReady(fi
vvcephei commented on a change in pull request #8662:
URL: https://github.com/apache/kafka/pull/8662#discussion_r424712060
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ClientUtils.java
##
@@ -105,6 +109,7 @@ public static String getTaskProdu