Top "Kafka-consumer-api" questions

Use for questions related to the Apache Kafka consumer API

NoBrokersAvailable: NoBrokersAvailable-Kafka Error

i have already started to learn Kafka. Trying basic operations on it. I have stucked on a point which about …

python apache-kafka kafka-consumer-api kafka-producer-api kafka-python
Kafka Consumer outputs excessive DEBUG statements to console (ecilpse)

I'm running some sample code from http://www.javaworld.com/article/3060078/big-data/big-data-messaging-with-kafka-part-1.html?page=2, and the kafkaconsumer is consuming …

java logging apache-kafka log4j kafka-consumer-api
How to connect Kafka with Elasticsearch?

I am new in Kafka, I use kafka to collect netflow through logstash(it is ok), and I want to …

elasticsearch apache-kafka kafka-consumer-api apache-kafka-connect
Kafka10.1 heartbeat.interval.ms, session.timeout.ms and max.poll.interval.ms

I am using kafka 0.10.1.1 and confused with the following 3 properties. heartbeat.interval.ms session.timeout.ms max.poll.interval.ms …

apache-kafka kafka-consumer-api
how to get acknowledgement from Kafka broker if message is produced by producer?

I would like to get some response from the broker when I produce a message. I have tried CallBack mechanism (…

java apache-kafka kafka-consumer-api kafka-producer-api
How to make kafka consumer to read from last consumed offset but not from beginning

I am new to kafka and trying to understand if there is a way to read messages from last consumed …

apache-kafka kafka-consumer-api
kafka Synchronization :"java.io.IOException: Too many open files"

we are having problem with Kafka. sometimes Suddenly, without warning we go out of Synchronization and start to get exceptions …

kafka-consumer-api apache-kafka
Kafka how to read from __consumer_offsets topic

I'm trying to find out which offsets my current High-Level consumers are working off. I use Kafka 0.8.2.1, with no "offset.…

apache-kafka kafka-consumer-api
Does Kafka support request response messaging

I am investigating Kafka 9 as a hobby project and completed a few "Hello World" type examples. I have got to …

apache-kafka kafka-consumer-api kafka-producer-api mom
Leader brokers without a matching listener error in kafka

What is the meaning of this kafka error ? [2018-08-22 11:40:49,429] WARN [Consumer clientId=consumer-1, groupId=console-consumer-62114] 1 partitions have leader brokers …

go apache-kafka kafka-consumer-api