[GitHub] [flink] tzulitai commented on a diff in pull request #22126: [Bug][FLINK-31363]KafkaSink failed to commit transactions under EXACTLY_ONCE semantics.

tzulitai commented on code in PR #22126: URL: https://github.com/apache/flink/pull/22126#discussion_r1132976860 ## flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java: ## @@ -302,7 +302,7 @@ public void

[GitHub] [flink] tzulitai commented on a diff in pull request #22126: [Bug][FLINK-31363]KafkaSink failed to commit transactions under EXACTLY_ONCE semantics.

tzulitai commented on code in PR #22126: URL: https://github.com/apache/flink/pull/22126#discussion_r1132976860 ## flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java: ## @@ -302,7 +302,7 @@ public void

[GitHub] [flink] tzulitai commented on a diff in pull request #22126: [Bug][FLINK-31363]KafkaSink failed to commit transactions under EXACTLY_ONCE semantics.

tzulitai commented on code in PR #22126: URL: https://github.com/apache/flink/pull/22126#discussion_r1132976860 ## flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java: ## @@ -302,7 +302,7 @@ public void

[GitHub] [flink] tzulitai commented on a diff in pull request #22126: [Bug][FLINK-31363]KafkaSink failed to commit transactions under EXACTLY_ONCE semantics.

tzulitai commented on code in PR #22126: URL: https://github.com/apache/flink/pull/22126#discussion_r1132976860 ## flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java: ## @@ -302,7 +302,7 @@ public void

[GitHub] [flink] tzulitai commented on a diff in pull request #22126: [Bug][FLINK-31363]KafkaSink failed to commit transactions under EXACTLY_ONCE semantics.

tzulitai commented on code in PR #22126: URL: https://github.com/apache/flink/pull/22126#discussion_r1132948153 ## flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java: ## @@ -302,7 +302,7 @@ public void

[GitHub] [flink] tzulitai commented on a diff in pull request #22126: [Bug][FLINK-31363]KafkaSink failed to commit transactions under EXACTLY_ONCE semantics.

tzulitai commented on code in PR #22126: URL: https://github.com/apache/flink/pull/22126#discussion_r1132772741 ## flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java: ## @@ -302,7 +302,7 @@ public void