mjsax commented on code in PR #21803:
URL: https://github.com/apache/kafka/pull/21803#discussion_r3426133833
##########
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java:
##########
@@ -511,7 +512,35 @@ public static StreamThread create(final TopologyMetadata
topologyMetadata,
consumerConfigs.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG,
"none");
}
- final MainConsumerSetup mainConsumerSetup =
setupMainConsumer(topologyMetadata, config, clientSupplier, processId,
consumerConfigs);
+ final MainConsumerSetup mainConsumerSetup = setupMainConsumer(
+ topologyMetadata,
+ config,
+ clientSupplier,
+ processId,
+ consumerConfigs,
+ // TODO (KAFKA-20116): make both suppliers thread-safe
Review Comment:
Extracted this part into https://github.com/apache/kafka/pull/22595 which we
should merge first, and I will rebase this one later.
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
