Top "Kafka-producer-api" questions

Use for questions related to the Apache Kafka producer API.

Can I ignore org.apache.kafka.common.errors.NotLeaderForPartitionExceptions?

My Apache Kafka producer (0.9.0.1) intermittently throws a org.apache.kafka.common.errors.NotLeaderForPartitionException My code that performs the Kafka send …

Read More
exception-handling apache-kafka kafka-producer-api
Kafka Consumer's poll() method gets blocked

I'm new to Kafka 0.9 and testing some features I realized a strange behaviour in the Java implemented Consumer (KafkaConsumer). The …

Read More
apache-kafka polling kafka-consumer-api kafka-producer-api