Top "Kafka-producer-api" questions

Use for questions related to the Apache Kafka producer API.

Kafka throws java.nio.channels.ClosedChannelException

When i try to consume messages from the kafka server which is hosted in ec2 with kafka console tool (V 0.9.0.1 , …

apache-kafka kafka-consumer-api kafka-producer-api
Is it possible to transfer files using Kafka?

I have thousands of files generated each day which I want to stream using Kafka. When I try to read …

apache-kafka kafka-consumer-api kafka-producer-api
Can single Kafka producer produce messages to multiple topics and how?

I am just exploring Kafka, currently i am using One producer and One topic to produce messages and it is …

apache-kafka kafka-producer-api
Kafka producer difference between flush and poll

We have a Kafka consumer which will read messages and do so stuff and again publish to Kafka topic using …

python apache-kafka kafka-producer-api confluent-platform
Understanding the max.inflight property of kafka producer

I work on a bench of my Kafka cluster in version 1.0.0-cp1. In part of my bench who focus on …

configuration apache-kafka kafka-producer-api producer
Kafka : Running Confluent in a Windows environment

I set up Kafka for local run. I have written sample producer and consumer in Java and running from local, …

java apache-kafka kafka-producer-api apache-kafka-connect confluent-platform
Kafka DefaultPartitioner algorithm

There is a very small but very powerful detail in the Kafka org.apache.kafka.clients.producer.internals.DefaultPartitioner implementation …

apache-kafka kafka-producer-api
KafkaProducer not successfully sending message into the queue

I have built a small testing environment on my Windows PC and write down the following code for testing kafka (…

java apache-kafka kafka-producer-api
Kafka consumer "failed to find leader" when fetching topic metadata

When I try to use the Kafka producer and consumer (0.9.0) script to push/pull messages from a topic, I get …

apache-kafka apache-zookeeper kafka-consumer-api kafka-producer-api
Using Kafka Producer by different threads

I have kafka producer for my java based web application to push messages to Kafka. As per the documentation I …

apache-kafka kafka-producer-api