flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dawidwys <...@git.apache.org>
Subject [GitHub] flink issue #6259: [FLINK-9679] Implement AvroSerializationSchema
Date Thu, 19 Jul 2018 08:03:42 GMT
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.


---

Mime
View raw message