Top "Producer" questions

Producer is an actor in the Producer Consumer scenario

Leader Not Available Kafka in Console Producer

I am trying to use Kafka. All configurations are done properly but when I try to produce message from console …

apache-kafka producer
Fast and Best Producer/consumer queue technique BlockingCollection vs concurrent Queue

Im using Generic.Queue in C# 3.0 and Monitor.Enter,wait,exit for wait before consuming the queue (wait for the …

concurrency c#-3.0 consumer producer
Topic can't be found when producing messages: UNKNOWN_TOPIC_OR_PARTITION

I have a two-nodes Kafka cluster (EC2 instances) where each node is used as a separate broker. When I run …

apache-kafka consumer producer
Interact with kafka docker container from outside of docker host

I have built a kafka docker container and orchestrate it using docker-compose. Calling docker ps I get the following putput: …

docker apache-kafka producer
Spring Kafka asynchronous send calls block

I'm using Spring-Kafka version 1.2.1 and, when the Kafka server is down/unreachable, the asynchronous send calls block for a time. …

spring asynchronous apache-kafka send producer
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
How to use KAFKA's producer API in librdkafka with c++ code on windows

I am trying to write a client as an producer. I followed examples to create a new win32 console project. …

c++ apache-kafka producer
Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)

I have installed Kafka and doing some basic testing. I am able to create topics using scripts provided under Kafka-broker/…

apache-kafka hortonworks-data-platform producer
Kafka Producer Exception NoClassDefFoundError

I have some problem with kafka Producer, but i dont know how i can solved it My Maven Dependency: <…

java maven apache-kafka producer
Kafka producer send message expiring duo to 30003 ms has passed since last append

I'm using Kafka 0.10.1.1 and write a test producer, but I get an error in producer.send onCompletion callback: producer.send(…

apache-kafka producer