mjsax commented on code in PR #17521:
URL: https://github.com/apache/kafka/pull/17521#discussion_r1804091881
##########
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java:
##########
@@ -349,8 +349,7 @@ public boolean isStartingRunningOrPartitionAssigned() {
private volatile long fetchDeadlineClientInstanceId = -1;
private volatile KafkaFutureImpl<Uuid> mainConsumerInstanceIdFuture = new
KafkaFutureImpl<>();
private volatile KafkaFutureImpl<Uuid> restoreConsumerInstanceIdFuture =
new KafkaFutureImpl<>();
- private volatile KafkaFutureImpl<Map<String, KafkaFuture<Uuid>>>
producerInstanceIdFuture = new KafkaFutureImpl<>();
- private volatile KafkaFutureImpl<Uuid> threadProducerInstanceIdFuture =
new KafkaFutureImpl<>();
+ private volatile KafkaFutureImpl<Uuid> producerInstanceIdFuture = new
KafkaFutureImpl<>();
Review Comment:
We only have producer per thread and can unify both cases (up to know, only
one of both variables would be used, never both at the same time)
--
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]
