[GitHub] [kafka] vamossagar12 commented on a diff in pull request #12803: KAFKA-13602: Adding ability to multicast records.

2022-12-13 Thread GitBox
vamossagar12 commented on code in PR #12803: URL: https://github.com/apache/kafka/pull/12803#discussion_r1046869563 ## streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java: ## @@ -212,6 +227,7 @@ public void send(final String topic,

[GitHub] [kafka] vamossagar12 commented on a diff in pull request #12803: KAFKA-13602: Adding ability to multicast records.

2022-12-13 Thread GitBox
vamossagar12 commented on code in PR #12803: URL: https://github.com/apache/kafka/pull/12803#discussion_r1046869563 ## streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java: ## @@ -212,6 +227,7 @@ public void send(final String topic,

[GitHub] [kafka] vamossagar12 commented on a diff in pull request #12803: KAFKA-13602: Adding ability to multicast records.

2022-12-05 Thread GitBox
vamossagar12 commented on code in PR #12803: URL: https://github.com/apache/kafka/pull/12803#discussion_r1039384220 ## streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java: ## @@ -459,12 +461,23 @@ private List

[GitHub] [kafka] vamossagar12 commented on a diff in pull request #12803: KAFKA-13602: Adding ability to multicast records.

2022-11-25 Thread GitBox
vamossagar12 commented on code in PR #12803: URL: https://github.com/apache/kafka/pull/12803#discussion_r1032731595 ## streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java: ## @@ -459,12 +461,23 @@ private List

[GitHub] [kafka] vamossagar12 commented on a diff in pull request #12803: KAFKA-13602: Adding ability to multicast records.

2022-11-20 Thread GitBox
vamossagar12 commented on code in PR #12803: URL: https://github.com/apache/kafka/pull/12803#discussion_r1027568306 ## streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java: ## @@ -459,12 +461,23 @@ private List

[GitHub] [kafka] vamossagar12 commented on a diff in pull request #12803: KAFKA-13602: Adding ability to multicast records.

2022-11-20 Thread GitBox
vamossagar12 commented on code in PR #12803: URL: https://github.com/apache/kafka/pull/12803#discussion_r1027509282 ## streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java: ## @@ -459,12 +461,23 @@ private List

[GitHub] [kafka] vamossagar12 commented on a diff in pull request #12803: KAFKA-13602: Adding ability to multicast records.

2022-11-17 Thread GitBox
vamossagar12 commented on code in PR #12803: URL: https://github.com/apache/kafka/pull/12803#discussion_r1025489083 ## streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java: ## @@ -459,12 +461,23 @@ private List

[GitHub] [kafka] vamossagar12 commented on a diff in pull request #12803: KAFKA-13602: Adding ability to multicast records.

2022-11-13 Thread GitBox
vamossagar12 commented on code in PR #12803: URL: https://github.com/apache/kafka/pull/12803#discussion_r1021016017 ## streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java: ## @@ -1046,7 +1047,18 @@ public KTable leftJoin(final KTable other,