Fabian Hueske created FLINK-8015: ------------------------------------ Summary: Add Kafka011JsonTableSink Key: FLINK-8015 URL: https://issues.apache.org/jira/browse/FLINK-8015 Project: Flink Issue Type: Improvement 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)