Maximilian Bode created FLINK-3905: -------------------------------------- Summary: Add KafkaOutputFormat (DataSet API) Key: FLINK-3905 URL: https://issues.apache.org/jira/browse/FLINK-3905 Project: Flink Issue Type: New Feature Components: Kafka Connector Affects Versions: 1.0.3 Reporter: Maximilian Bode Assignee: Maximilian Bode
Right now, Flink can ingest records from and write records to Kafka in the DataStream API, via the {{FlinkKafkaConsumer08}} and {{FlinkKafkaProducer08}} and the corresponding classes for Kafka 0.9. In Flink batch jobs, interaction with Kafka is currently not supported. ---- If there is an easy way to create an inverse to the OutputFormatSinkFunction, something like a SinkFunctionOutputFormat, this might be the way to go? -- This message was sent by Atlassian JIRA (v6.3.4#6332)