Julien Preisner created FLINK-6062:
--------------------------------------
Summary: Re-read a Kafka topic at the reception of an event
Key: FLINK-6062
URL:
https://issues.apache.org/jira/browse/FLINK-6062 Project: Flink
Issue Type: New Feature
Components: DataStream API, Kafka Connector
Reporter: Julien Preisner
This new feature consist that to re-read a Kafka topic at the reception of an event.
Example of use case : a job deserializes messages from Kafka topic and does calculations. When a special event happens (from another Kafka topic for example), I want to reset my calculations and re-read the topic Kafka.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)