Java Client for Kafka Consumer(0.9) not polling the records from brokers instantly

2016-05-25 Thread Navneet Kumar
value.deserializer=org.apache.kafka.common.serialization.StringDeserializer topic=visualize-link-redirect Please help me to resolve this issue as soon as possible. Will be grateful to you. Thanks and Regards, Navneet Kumar

Re: Java Client for Kafka Consumer(0.9) not polling the records from brokers instantly

2016-05-26 Thread Navneet Kumar
=org.apache.kafka.common.serialization.StringDeserializer value.deserializer=org.apache.kafka.common.serialization.StringDeserializer topic=visualize-link-redirect Please help me to resolve this issue as soon as possible. Will be grateful to you. Thanks and Regards, Navneet Kumar On Wed, May 25, 2016 at 4:27 PM, Navneet Kumar

My Use case is I want to delete the records instantly after consuming them

2016-07-02 Thread Navneet Kumar
Hi All My Use case is I want to delete the records instantly after consuming them. I am using Kafka 0.90 Thanks and Regards, Navneet Kumar

Re: My Use case is I want to delete the records instantly after consuming them

2016-07-02 Thread Navneet Kumar
Thank you so much Ian Thanks and Regards, Navneet Kumar On Sat, Jul 2, 2016 at 9:45 PM, Ian Wrigley <i...@confluent.io> wrote: > That’s really not what Kafka was designed to do. You can set a short log > retention period, which will mean messages are deleted relativel

Re: My Use case is I want to delete the records instantly after consuming them

2016-07-02 Thread Navneet Kumar
polling strategy needed. Please suggest me. /home/kafka/kafka_2.11-0.9.0.0/bin/kafka-topics.sh --create --zookeeper 172.16.8.216:2181 --replication-factor 3 --partitions 3 --topic EmailOCTracker Thanks and Regards, Navneet Kumar On Sat, Jul 2, 2016 at 10:49 PM, Navneet Kumar <navneetkumar

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

2018-02-02 Thread Navneet Kumar
Appreciate you efforts On 2 Feb 2018 2:37 p.m., "Zoran" wrote: > I just want to say that I have solved the situation by deleting > zookeeper's and kafka's data directories and setting > offsets.topic.replication.factor=3 in kafka server.properties file. > > After