Use for questions related to the Apache Kafka consumer API
I need to find out a way to ask Kafka for a list of topics. I know I can do …
apache-kafka kafka-consumer-apiI 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-computingPlease can anyone tell me how to read messages using the Kafka Consumer API from the beginning every time when …
apache-kafka kafka-consumer-apiI 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-apiKeyedMessage<String, byte[]> keyedMessage = new KeyedMessage<String, byte[]>(request.getRequestTopicName(), SerializationUtils.serialize(message)); producer.send(keyedMessage); …
apache-kafka kafka-consumer-api kafka-producer-apiI 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-apiI'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-topicI 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-apiI am attempting to write a Java client for a third party's Kafka and ZooKeeper servers. I am able to …
apache-kafka kafka-consumer-apiI'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