Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

How does Debezium set the Kafka message timestamp

apache-kafka debezium

kafka node js client compression issue with snappy

kafka connect exception, Replication factor: 3 larger than available brokers: 1

When Kafka sends multiple batches in the same request?

apache-kafka

org.apache.kafka.common.errors.RecordTooLargeException: The request included a message larger than the max message size the server will accept

Converting Java to Avro and back when using kafka

java apache-kafka avro

Unable to resolve confluent kafka dependencies in gradle?

Long and consistent wait between tasks in spark streaming job

How to set message headers using KafkaTemplate?

strange behavior of kafka tool : kafka.tools.GetOffsetShell

Is there a way to manually store Kafka offset so a consumer never misses messages?

In Kafka, the "Key" does not match the "Id" when updating the document in MongoDB

Can we listen to specific keyed messages by Kafka Consumer

Turn off acking in KafkaSpout while respecting maxSpoutPending

apache-storm apache-kafka

Kafka connector tasks remain in unassigned state permanently