Re: kafka offset not working

2019-10-08 Thread Benjamin Cuthbert
tarted > from a checkpoint/savepoint it'll continue to consume from where it left > off. > > Hope that makes sense, > Eduardo > > > On Mon, 7 Oct 2019, 16:52 Benjamin Cuthbert, > wrote: > >> All >> >> Our kafka consumer has the group.id property but

kafka offset not working

2019-10-07 Thread Benjamin Cuthbert
All Our kafka consumer has the group.id property but when we receive messages on the channel when not connect and then reconnect we don't get the message. The kafka console consumer when running "-group testben" works perfectly fine. Is there some other place to setup flink to read from the late

jvm options for individual jobs / topologies

2018-05-08 Thread Benjamin Cuthbert
Hi all, How do I give different topologies / jobs different Xmx memory parameters? Regards