guozhangwang commented on a change in pull request #8876: URL: https://github.com/apache/kafka/pull/8876#discussion_r441229437
########## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java ########## @@ -273,13 +273,13 @@ public boolean isRunning() { private volatile ThreadMetadata threadMetadata; private StreamThread.StateListener stateListener; - private final Admin adminClient; private final ChangelogReader changelogReader; // package-private for testing final ConsumerRebalanceListener rebalanceListener; final Consumer<byte[], byte[]> mainConsumer; final Consumer<byte[], byte[]> restoreConsumer; + final Admin adminClient; Review comment: Yeah I agree, will move all these variables to private and add getters. ---------------------------------------------------------------- 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