[GitHub] [flink] fapaul commented on a change in pull request #17696: [FLINK-24765][kafka] Bump Kafka version to 2.8

2022-01-24 Thread GitBox
fapaul commented on a change in pull request #17696: URL: https://github.com/apache/flink/pull/17696#discussion_r790789244 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/FlinkKafkaInternalProducer.java

[GitHub] [flink] fapaul commented on a change in pull request #17696: [FLINK-24765][kafka] Bump Kafka version to 2.8

2021-11-10 Thread GitBox
fapaul commented on a change in pull request #17696: URL: https://github.com/apache/flink/pull/17696#discussion_r747269811 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerITCase.java ## @@ -53,7

[GitHub] [flink] fapaul commented on a change in pull request #17696: [FLINK-24765][kafka] Bump Kafka version to 2.8

2021-11-10 Thread GitBox
fapaul commented on a change in pull request #17696: URL: https://github.com/apache/flink/pull/17696#discussion_r747269536 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerITCase.java ## @@ -53,7

[GitHub] [flink] fapaul commented on a change in pull request #17696: [FLINK-24765][kafka] Bump Kafka version to 2.8

2021-11-10 Thread GitBox
fapaul commented on a change in pull request #17696: URL: https://github.com/apache/flink/pull/17696#discussion_r746721562 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/FlinkKafkaInternalProducer.java

[GitHub] [flink] fapaul commented on a change in pull request #17696: [FLINK-24765][kafka] Bump Kafka version to 2.8

2021-11-08 Thread GitBox
fapaul commented on a change in pull request #17696: URL: https://github.com/apache/flink/pull/17696#discussion_r744489457 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/FlinkKafkaInternalProducer.java

[GitHub] [flink] fapaul commented on a change in pull request #17696: [FLINK-24765][kafka] Bump Kafka version to 2.8

2021-11-05 Thread GitBox
fapaul commented on a change in pull request #17696: URL: https://github.com/apache/flink/pull/17696#discussion_r743698529 ## File path: flink-connectors/flink-connector-kafka/pom.xml ## @@ -111,6 +111,15 @@ under the License. test +

[GitHub] [flink] fapaul commented on a change in pull request #17696: [FLINK-24765][kafka] Bump Kafka version to 2.8

2021-11-05 Thread GitBox
fapaul commented on a change in pull request #17696: URL: https://github.com/apache/flink/pull/17696#discussion_r743698529 ## File path: flink-connectors/flink-connector-kafka/pom.xml ## @@ -111,6 +111,15 @@ under the License. test +

[GitHub] [flink] fapaul commented on a change in pull request #17696: [FLINK-24765][kafka] Bump Kafka version to 2.8

2021-11-05 Thread GitBox
fapaul commented on a change in pull request #17696: URL: https://github.com/apache/flink/pull/17696#discussion_r743698529 ## File path: flink-connectors/flink-connector-kafka/pom.xml ## @@ -111,6 +111,15 @@ under the License. test +