Hi David, We are also running streaming jobs over Kafka source .
Yes : Consumer Group Id needs to be set for Kafka source explicitly t . We are also using checkpointing and save points for persisting state . Any time we change group id it starts from latest offset(default Kafka connector behavior) . Thanks Sohi -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
