[ https://issues.apache.org/jira/browse/FLINK-9679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16548951#comment-16548951 ]
ASF GitHub Bot commented on FLINK-9679: --------------------------------------- Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/6259 Actually I've suggested to move the whole writing schema logic into the coder. So the coder should have a method like `writeSchema(..., OutputStream out)`. Substituting previous `topic + "value"` with `subject` does not change anything. It simply renames a lookup key. The whole problem is that it is static and does not take into account the actual topic the message will be written to. Unfortunately I am afraid it would require some changes in the `FlinkKafkaProducer` itself. > Implement AvroSerializationSchema > --------------------------------- > > Key: FLINK-9679 > URL: https://issues.apache.org/jira/browse/FLINK-9679 > Project: Flink > Issue Type: Improvement > Affects Versions: 1.6.0 > Reporter: Yazdan Shirvany > Assignee: Yazdan Shirvany > Priority: Major > Labels: pull-request-available > > Implement AvroSerializationSchema using Confluent Schema Registry -- This message was sent by Atlassian JIRA (v7.6.3#76005)