Top "Kafka-consumer-api" questions

Use for questions related to the Apache Kafka consumer API

Kafka consumer list

I need to find out a way to ask Kafka for a list of topics. I know I can do …

apache-kafka kafka-consumer-api
What determines Kafka consumer offset?

I am relatively new to Kafka. I have done a bit of experimenting with it, but a few things are …

java apache-kafka kafka-consumer-api distributed-computing
How to read data using Kafka Consumer API from beginning?

Please can anyone tell me how to read messages using the Kafka Consumer API from the beginning every time when …

apache-kafka kafka-consumer-api
Understanding Kafka Topics and Partitions

I am starting to learn Kafka for enterprise solution purposes. During my readings, some questions came to my mind: When …

apache-kafka kafka-consumer-api kafka-producer-api
Is key required as part of sending messages to Kafka?

KeyedMessage<String, byte[]> keyedMessage = new KeyedMessage<String, byte[]>(request.getRequestTopicName(), SerializationUtils.serialize(message)); producer.send(keyedMessage); …

apache-kafka kafka-consumer-api kafka-producer-api
How to write a file to Kafka Producer

I am trying to load a simple text file instead of standard input in Kafka. After downloading Kafka, I performed …

file apache-kafka kafka-consumer-api kafka-producer-api
Counting Number of messages stored in a kafka topic

I'm using 0.9.0.0 version of Kafka and I want to count the number of messages in a topic without using the …

apache-kafka kafka-consumer-api jms-topic
Consumer not receiving messages, kafka console, new consumer api, Kafka 0.9

I am doing the Kafka Quickstart for Kafka 0.9.0.0. I have zookeeper listening at localhost:2181 because I ran bin/zookeeper-server-start.sh …

apache-kafka kafka-consumer-api
Kafka consumer fetching metadata for topics failed

I am attempting to write a Java client for a third party's Kafka and ZooKeeper servers. I am able to …

apache-kafka kafka-consumer-api
How can I get the last/end offset of a kafka topic partition?

I'm writing a kafka consumer using Java. I want to keep the real time of the message, so if there …

java apache-kafka kafka-consumer-api