sebastienviale commented on code in PR #22725:
URL: https://github.com/apache/kafka/pull/22725#discussion_r3614852737
##########
streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java:
##########
@@ -255,6 +256,16 @@ public class TopologyTestDriver implements Closeable {
private final Map<String, Queue<ProducerRecord<byte[], byte[]>>>
outputRecordsByTopic = new HashMap<>();
private final StreamsConfigUtils.ProcessingMode processingMode;
+ // Multi-partition lifecycle (declareTopic/init). The fields below back
the new API only;
+ // the legacy single-partition execution path does not consult them and
continues to work unchanged.
+ private final Map<String, Integer> declaredPartitionsByTopic = new
HashMap<>();
+ private boolean multiPartitionModeActive = false;
+ private MultiPartitionRuntime runtime;
+ private final StreamsConfig multiSubStreamsConfig;
Review Comment:
done
##########
streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java:
##########
@@ -255,6 +256,16 @@ public class TopologyTestDriver implements Closeable {
private final Map<String, Queue<ProducerRecord<byte[], byte[]>>>
outputRecordsByTopic = new HashMap<>();
private final StreamsConfigUtils.ProcessingMode processingMode;
+ // Multi-partition lifecycle (declareTopic/init). The fields below back
the new API only;
+ // the legacy single-partition execution path does not consult them and
continues to work unchanged.
Review Comment:
done
--
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]
