[ https://issues.apache.org/jira/browse/FLINK-8015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Fabian Hueske updated FLINK-8015: --------------------------------- Issue Type: New Feature (was: Improvement) > Add Kafka011JsonTableSink > ------------------------- > > Key: FLINK-8015 > URL: https://issues.apache.org/jira/browse/FLINK-8015 > Project: Flink > Issue Type: New Feature > Components: Table API & SQL > Affects Versions: 1.5.0 > Reporter: Fabian Hueske > > We offer a TableSource for JSON-encoded Kafka 0.11 topics but no TableSink. > Since Flink's Kafka producer changed for Kafka 0.11 we need new base classes > which we can reuse for TableSinks for later Kafka versions. -- This message was sent by Atlassian JIRA (v6.4.14#64029)