[GitHub] [flink] lindong28 commented on a change in pull request #18397: [FLINK-25702][Kafka] Use the configure feature provided by the kafka Serializer/Deserializer.

lindong28 commented on a change in pull request #18397: URL: https://github.com/apache/flink/pull/18397#discussion_r791270225 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchemaBuilderTest.java

[GitHub] [flink] lindong28 commented on a change in pull request #18397: [FLINK-25702][Kafka] Use the configure feature provided by the kafka Serializer/Deserializer.

lindong28 commented on a change in pull request #18397: URL: https://github.com/apache/flink/pull/18397#discussion_r791272806 ## File path:

[GitHub] [flink] lindong28 commented on a change in pull request #18397: [FLINK-25702][Kafka] Use the configure feature provided by the kafka Serializer/Deserializer.

lindong28 commented on a change in pull request #18397: URL: https://github.com/apache/flink/pull/18397#discussion_r791270225 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchemaBuilderTest.java

[GitHub] [flink] lindong28 commented on a change in pull request #18397: [FLINK-25702][Kafka] Use the configure feature provided by the kafka Serializer/Deserializer.

lindong28 commented on a change in pull request #18397: URL: https://github.com/apache/flink/pull/18397#discussion_r790792173 ## File path:

[GitHub] [flink] lindong28 commented on a change in pull request #18397: [FLINK-25702][Kafka] Use the configure feature provided by the kafka Serializer/Deserializer.

lindong28 commented on a change in pull request #18397: URL: https://github.com/apache/flink/pull/18397#discussion_r790786440 ## File path:

[GitHub] [flink] lindong28 commented on a change in pull request #18397: [FLINK-25702][Kafka] Use the configure feature provided by the kafka Serializer/Deserializer.

lindong28 commented on a change in pull request #18397: URL: https://github.com/apache/flink/pull/18397#discussion_r790745777 ## File path:

[GitHub] [flink] lindong28 commented on a change in pull request #18397: [FLINK-25702][Kafka] Use the configure feature provided by the kafka Serializer/Deserializer.

lindong28 commented on a change in pull request #18397: URL: https://github.com/apache/flink/pull/18397#discussion_r790751091 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchemaBuilderTest.java

[GitHub] [flink] lindong28 commented on a change in pull request #18397: [FLINK-25702][Kafka] Use the configure feature provided by the kafka Serializer/Deserializer.

lindong28 commented on a change in pull request #18397: URL: https://github.com/apache/flink/pull/18397#discussion_r790745777 ## File path:

[GitHub] [flink] lindong28 commented on a change in pull request #18397: [FLINK-25702][Kafka] Use the configure feature provided by the kafka Serializer/Deserializer.

lindong28 commented on a change in pull request #18397: URL: https://github.com/apache/flink/pull/18397#discussion_r790076382 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSerializerWrapper.java ## @@ -32,26

[GitHub] [flink] lindong28 commented on a change in pull request #18397: [FLINK-25702][Kafka] Use the configure feature provided by the kafka Serializer/Deserializer.

lindong28 commented on a change in pull request #18397: URL: https://github.com/apache/flink/pull/18397#discussion_r789704887 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSerializerWrapper.java ## @@ -65,8

[GitHub] [flink] lindong28 commented on a change in pull request #18397: [FLINK-25702][Kafka] Use the configure feature provided by the kafka Serializer/Deserializer.

lindong28 commented on a change in pull request #18397: URL: https://github.com/apache/flink/pull/18397#discussion_r789704887 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSerializerWrapper.java ## @@ -65,8

[GitHub] [flink] lindong28 commented on a change in pull request #18397: [FLINK-25702][Kafka] Use the configure feature provided by the kafka Serializer/Deserializer.

lindong28 commented on a change in pull request #18397: URL: https://github.com/apache/flink/pull/18397#discussion_r789248928 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSerializerWrapper.java ## @@ -65,8

[GitHub] [flink] lindong28 commented on a change in pull request #18397: [FLINK-25702][Kafka] Use the configure feature provided by the kafka Serializer/Deserializer.

lindong28 commented on a change in pull request #18397: URL: https://github.com/apache/flink/pull/18397#discussion_r788868076 ## File path:

[GitHub] [flink] lindong28 commented on a change in pull request #18397: [FLINK-25702][Kafka] Use the configure feature provided by the kafka Serializer/Deserializer.

lindong28 commented on a change in pull request #18397: URL: https://github.com/apache/flink/pull/18397#discussion_r788865671 ## File path:

[GitHub] [flink] lindong28 commented on a change in pull request #18397: [FLINK-25702][Kafka] Use the configure feature provided by the kafka Serializer/Deserializer.

lindong28 commented on a change in pull request #18397: URL: https://github.com/apache/flink/pull/18397#discussion_r788860986 ## File path: