Hi Beam community, I got a quick question about withValueSerializer() method of KafkaIO.Write<K,V> class: https://beam.apache.org/releases/javadoc/2.25.0/org/apache/beam/sdk/io/kafka/KafkaIO.Write.html
The withValueSerializer method does not support passing in a serializer provider. The problem with lacking that functionality is that I cannot use Kafka schema registry to fetch the schema for serialization. However at the same time, the KafkaIO.Read<K,V> withKeyDeserializer method supports specifying a deserializer provider: https://beam.apache.org/releases/javadoc/2.25.0/org/apache/beam/sdk/io/kafka/KafkaIO.Read.html#withKeyDeserializer-org.apache.beam.sdk.io.kafka.DeserializerProvider- Is this a gap for KafkaIO.Write<K,V> or is it by design? Is there a workaround to specify the schema registry info for KafkaIO.Write<K,V>? Thanks so much!
