Re: Setting topic's offset from the shell

2018-03-05 Thread Zoran
t group.id config in kafka-console-consumer (or in any other consumer) to the value which you haven't used before. This will replay all available messages in the topic from start if you use --from-beginning in console consumer. On Wed, 28 Feb 2018 at 14:19 Zoran wrote: Hi, If I have a topi

Re: Setting topic's offset from the shell

2018-03-04 Thread Zoran
the topic from start if you use --from-beginning in console consumer. On Wed, 28 Feb 2018 at 14:19 Zoran wrote: Hi, If I have a topic that has been fully read by consumers, how to set the offset from the shell to some previous value in order to reread again several messages? Regards.

Setting topic's offset from the shell

2018-02-28 Thread Zoran
Hi, If I have a topic that has been fully read by consumers, how to set the offset from the shell to some previous value in order to reread again several messages? Regards.

Re: Group consumer cannot consume messages if kafka service on specific node in test cluster is down

2018-02-02 Thread Zoran
will help to someone. Regards. On 01/30/2018 03:02 PM, Zoran wrote: Sorry, I have attached wrong server.properties file. Now the right one is in the attachment. Regards. On 01/30/2018 02:59 PM, Zoran wrote: Hi, I have three servers: blade1 (192.168.112.31), blade2 (192.168.112.32)

Re: Group consumer cannot consume messages if kafka service on specific node in test cluster is down

2018-01-30 Thread Zoran
Sorry, I have attached wrong server.properties file. Now the right one is in the attachment. Regards. On 01/30/2018 02:59 PM, Zoran wrote: Hi, I have three servers: blade1 (192.168.112.31), blade2 (192.168.112.32) and blade3 (192.168.112.33). On each of servers kafka_2.11-1.0.0 is

Group consumer cannot consume messages if kafka service on specific node in test cluster is down

2018-01-30 Thread Zoran
## # The id of the broker. This must be set to a unique integer for each broker. broker.id=0 # Socket Server Settings # # The address the socket server listens on. It will get the value returned from # java.net.InetAddres