Apache Kafka and Avro: org.apache.avro.generic.GenericData$Record cannot be cast to com.harmeetsingh...

Distribute messages equally into partitions in kafka...

Kafka is not sending messages to other partitions...

How to configure min.insync.replicas parameter on Spring Kafka Producer?...

Topics, partitions and keys...

console-producer Error connecting to node kafka1:9092 (org.apache.kafka.clients.NetworkClient) java....

How to run Asynchronous Logic Synchronously...

kafka stream getting duplicate records even after exactly_once enabled...

how to create N number of Kafka Template dynamicaly at run time - spring boot...

Not able to read from Tweets from twitter...

Kafka Connect 5.5.0 - Unable to reset max.request.size...

Why does kafka producer have client.id?...

Kafka: Throughput of producing to thousands of topics with different message rate...

Benefits of Alpakka Kafka Producer over plain Kafka Producer...

How to produce tombstone for a Kafka Avro topic...

Kafka producer not distributing messages over partitions...

Unable to connect spring boot producer app to kafka confluent topic...

Understanding the max.inflight property of kafka producer...

ExecutionException:Due to: org.springframework.kafka.requestreply.KafkaReplyTimeoutException: Reply ...

ack=all and min ISR...

WARN Error while fetching metadata with correlation id 1 : {MY_TOPIC?=INVALID_TOPIC_EXCEPTION} (org....

How to correctly interrupt multithreading with Kafka Producers?...

Difference between request.timeout.ms and timeout.ms properties of Kafka producer...

Implications of keeping linger.ms at 0...

Kafka producer throws "key.serializer" exception...

How to send message to a particular partition in Kafka?...

How to create Custom serializer in kafka?...

How to pass Kafka's --producer.config through Java...

Can I use the same keystore for multiple kafka producer/consumer...

Why do I get Intermittent "NoBrokersAvailable" errors, with python application (kafka-pyth...