Hi Flink community, Was wondering if it is possible to mark the following
DynamicKafkaDeserializationSchema https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaDeserializationSchema.java DynamicKafkaRecordSerializationSchema https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaRecordSerializationSchema.java with Internal Public For context: We have our own custom KafkaDynamicTableFactory and custom serialization and deserialization format factory. However, we also want to enable our users to leverage existing open-source ser/de formats. Currently, we are duplicating the code in both DynamicKafkaDeserializationSchema.java and DynamicKafkaRecordSerializationSchema.java to wrap the generic SerializationSchema<RowData>/DeserializationSchema<RowData> serde logic however, if both classes were marked Internal Public it would reduce overall maintenance effort as we would like our custom implementation aligned with open source as much as possible Looking forward to hearing feedback from the community Tom
