mjsax commented on code in PR #17521:
URL: https://github.com/apache/kafka/pull/17521#discussion_r1804089881
##########
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java:
##########
@@ -1877,12 +1877,10 @@ public synchronized ClientInstanceIds
clientInstanceIds(final Duration timeout)
// (1) fan-out calls to threads
// StreamThread for main/restore consumers and producer(s)
- final Map<String, KafkaFuture<Uuid>> consumerFutures = new HashMap<>();
- final Map<String, KafkaFuture<Map<String, KafkaFuture<Uuid>>>>
producerFutures = new HashMap<>();
Review Comment:
Originally, we did split consumer and producer to be able to handle the
producer-per-task case. Now, we only have producer-per-thread and thus can
unify consumer/producer into "clients"
--
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]
