Re: Kafka avro producer

First ideally we need to provision our schema on cluster statically after that only the put operation can be performed. Dynamic schema provisions is supported in kafka? Not sure.. I guess no On Wed, Mar 27, 2019, 22:03 lsroudi abdel wrote: > It depend on your use case, you could push your

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

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

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

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: My Use case is I want to delete the records instantly after consuming them

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

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

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: Java Client for Kafka Consumer(0.9) not polling the records from brokers instantly

=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

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

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