Consumer not receiving messages, kafka console, new consumer api, Kafka 0.9

by

I my MAC box I was facing the same issue of console-consumer not consuming any messages when used the command

kafka-console-consumer --bootstrap-server localhost:9095 --from-beginning --topic my-replicated-topic

But when I tried with

kafka-console-consumer --bootstrap-server localhost:9095 --from-beginning --topic my-replicated-topic --partition 0

It happily lists the messages sent. Is this a bug in Kafka 1.10.11?

Related Contents:

  1. Understanding Kafka Topics and Partitions
  2. Is key required as part of sending messages to Kafka?
  3. Kafka: Consumer API vs Streams API
  4. Difference between session.timeout.ms and max.poll.interval.ms for Kafka >= 0.10.1
  5. Can multiple Kafka consumers read same message from the partition
  6. Kafka consumer list
  7. What does “Rebalancing” mean in Apache Kafka context?
  8. How to read data using Kafka Consumer API from beginning?
  9. difference between groupid and consumerid in Kafka consumer
  10. Delete message after consuming it in KAFKA
  11. Topics, partitions and keys
  12. How to send key, value messages with the kafka console producer
  13. What is the difference between kafka earliest and latest offset values
  14. Kafka Consumer get key value pair
  15. What is the difference in Kafka between a Consumer Group Coordinator and a Consumer Group Leader?
  16. When to use RabbitMQ over Kafka? [closed]
  17. What determines Kafka consumer offset?
  18. Is there a way to purge the topic in Kafka?
  19. Data Modeling with Kafka? Topics and Partitions
  20. What’s the purpose of Kafka’s key/value pair-based messaging?
  21. Delete topic in Kafka 0.8.1.1
  22. Is there a way to delete all the data from a topic or delete the topic before every run?
  23. List all Kafka 0.10 topics using – -zookeeper flag without access to Zookeeper
  24. How to list all available Kafka brokers in a cluster?
  25. When to use Apache kafka instead of ActiveMQ [closed]
  26. How to view kafka message
  27. How to change the number of replicas of a Kafka topic?
  28. changing kafka retention period during runtime
  29. Why is Kafka pull-based instead of push-based?
  30. What command shows all of the topics and offsets of partitions in Kafka?
  31. When/how does a topic “marked for deletion” get finally removed?
  32. Apache Kafka order of messages with multiple partitions
  33. Synchronising transactions between database and Kafka producer
  34. How to expose a headless service for a StatefulSet externally in Kubernetes
  35. classpath is empty. please build the project first
  36. What are Apache Kafka topic name limitations?
  37. Error creating Kafka Topics- Replication factor larger than available brokers
  38. Kafka + Zookeeper: Connection to node -1 could not be established. Broker may not be available
  39. Which directory does apache kafka store the data in broker nodes
  40. What is the difference between MQTT broker and Apache Kafka
  41. Exception in thread “main” joptsimple.UnrecognizedOptionException: zookeeper is not a recognized option
  42. What is the use of __consumer_offsets and _schema topics in Kafka?
  43. confluent platform vs apache kafka [closed]
  44. Kafka 0.11 how to reset offsets
  45. How to write a file to Kafka Producer
  46. How to see the retention for a particular topic in kafka
  47. what is bootstrap-server in kafka config?
  48. Increase the number of messages read by a Kafka consumer in a single poll
  49. Zookeeper: java.io.IOException: No snapshot found, but there are log entries. Something is broken
  50. How can I get the last/end offset of a kafka topic partition?

Leave a Comment