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
Kafka Connect - Failed to flush, timed out while waiting for producer to flush outstanding messages

I am trying to use the Kafka Connect JDBC Source Connector with following properties in BULK mode. connector.class=io.…

Read More
apache-kafka apache-kafka-connect kafka-producer-api