[GitHub] [flink] AHeise commented on a change in pull request #16783: [FLINK-23640][connectors/kafka] Add KafkaRecordSerializationSchemaBuilder to cover common serialization scenarios

AHeise commented on a change in pull request #16783: URL: https://github.com/apache/flink/pull/16783#discussion_r692071904 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/sink/KafkaRecordSerializationSchemaBuilder.java ###

[GitHub] [flink] AHeise commented on a change in pull request #16783: [FLINK-23640][connectors/kafka] Add KafkaRecordSerializationSchemaBuilder to cover common serialization scenarios

AHeise commented on a change in pull request #16783: URL: https://github.com/apache/flink/pull/16783#discussion_r692070149 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/sink/KafkaRecordSerializationSchemaBuilder.java ###

[GitHub] [flink] AHeise commented on a change in pull request #16783: [FLINK-23640][connectors/kafka] Add KafkaRecordSerializationSchemaBuilder to cover common serialization scenarios

AHeise commented on a change in pull request #16783: URL: https://github.com/apache/flink/pull/16783#discussion_r690485132 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/sink/KafkaRecordSerializationSchemaBuilder.java ###

[GitHub] [flink] AHeise commented on a change in pull request #16783: [FLINK-23640][connectors/kafka] Add KafkaRecordSerializationSchemaBuilder to cover common serialization scenarios

AHeise commented on a change in pull request #16783: URL: https://github.com/apache/flink/pull/16783#discussion_r690502228 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchemaBuilder.java ## @@

[GitHub] [flink] AHeise commented on a change in pull request #16783: [FLINK-23640][connectors/kafka] Add KafkaRecordSerializationSchemaBuilder to cover common serialization scenarios

AHeise commented on a change in pull request #16783: URL: https://github.com/apache/flink/pull/16783#discussion_r690492786 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/sink/KafkaRecordSerializationSchemaBuilder.java ###

[GitHub] [flink] AHeise commented on a change in pull request #16783: [FLINK-23640][connectors/kafka] Add KafkaRecordSerializationSchemaBuilder to cover common serialization scenarios

AHeise commented on a change in pull request #16783: URL: https://github.com/apache/flink/pull/16783#discussion_r690491144 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/sink/KafkaRecordSerializationSchemaBuilder.java ###

[GitHub] [flink] AHeise commented on a change in pull request #16783: [FLINK-23640][connectors/kafka] Add KafkaRecordSerializationSchemaBuilder to cover common serialization scenarios

AHeise commented on a change in pull request #16783: URL: https://github.com/apache/flink/pull/16783#discussion_r690488773 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/sink/KafkaRecordSerializationSchemaBuilder.java ###

[GitHub] [flink] AHeise commented on a change in pull request #16783: [FLINK-23640][connectors/kafka] Add KafkaRecordSerializationSchemaBuilder to cover common serialization scenarios

AHeise commented on a change in pull request #16783: URL: https://github.com/apache/flink/pull/16783#discussion_r690486505 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/sink/KafkaRecordSerializationSchemaBuilder.java ###

[GitHub] [flink] AHeise commented on a change in pull request #16783: [FLINK-23640][connectors/kafka] Add KafkaRecordSerializationSchemaBuilder to cover common serialization scenarios

AHeise commented on a change in pull request #16783: URL: https://github.com/apache/flink/pull/16783#discussion_r690486505 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/sink/KafkaRecordSerializationSchemaBuilder.java ###

[GitHub] [flink] AHeise commented on a change in pull request #16783: [FLINK-23640][connectors/kafka] Add KafkaRecordSerializationSchemaBuilder to cover common serialization scenarios

AHeise commented on a change in pull request #16783: URL: https://github.com/apache/flink/pull/16783#discussion_r690485132 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/sink/KafkaRecordSerializationSchemaBuilder.java ###

[GitHub] [flink] AHeise commented on a change in pull request #16783: [FLINK-23640][connectors/kafka] Add KafkaRecordSerializationSchemaBuilder to cover common serialization scenarios

AHeise commented on a change in pull request #16783: URL: https://github.com/apache/flink/pull/16783#discussion_r690484382 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/sink/KafkaRecordSerializationSchemaBuilder.java ###

[GitHub] [flink] AHeise commented on a change in pull request #16783: [FLINK-23640][connectors/kafka] Add KafkaRecordSerializationSchemaBuilder to cover common serialization scenarios

AHeise commented on a change in pull request #16783: URL: https://github.com/apache/flink/pull/16783#discussion_r690483562 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/sink/KafkaRecordSerializationSchema.java ##

[GitHub] [flink] AHeise commented on a change in pull request #16783: [FLINK-23640][connectors/kafka] Add KafkaRecordSerializationSchemaBuilder to cover common serialization scenarios

AHeise commented on a change in pull request #16783: URL: https://github.com/apache/flink/pull/16783#discussion_r689720051 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/sink/KafkaRecordSerializationSchemaBuilder.java ###