flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From medcv <...@git.apache.org>
Subject [GitHub] flink issue #6259: [FLINK-9679] Implement AvroSerializationSchema
Date Wed, 18 Jul 2018 17:44:42 GMT
Github user medcv commented on the issue:

    https://github.com/apache/flink/pull/6259
  
    @dawidwys I update the PR, please review
    
    the usage would be like this
    ` ConfluentRegistryAvroSerializationSchema.forSpecific(User.class, subject,  schemaRegistryUrl)`
    as Confluent needs "subject"  to fetch the Schema info. Now `ConfluentRegistryAvroSerializationSchema`
uses "subject" directly instated on `topic + "-value"`.


---

Mime
View raw message