[ https://issues.apache.org/jira/browse/FLINK-6062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011988#comment-16011988 ]
Julien Preisner commented on FLINK-6062: ---------------------------------------- Yes, it is the solution that I designed to do my use case. I wrote a shell script that restart the job. Thanks [~tzulitai]. > 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 > Affects Versions: 1.2.0 > 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)