| 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 | |