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 schema
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 that, __consumer_offsets topic i
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
wrote:
> Th
Thank you so much Ian
Thanks and Regards,
Navneet Kumar
On Sat, Jul 2, 2016 at 9:45 PM, Ian Wrigley 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 relatively soon after
> they were written
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
=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
wrote:
>
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