Java, How to get number of messages in a topic in apache kafka

by

It is not java, but may be useful

./bin/kafka-run-class.sh kafka.tools.GetOffsetShell \
  --broker-list <broker>:<port> \
  --topic <topic-name> \
  | awk -F  ":" '{sum += $3} END {print sum}'

More Related Contents:

  1. Connect to Kafka running in Docker
  2. How can I send large messages with Kafka (over 15MB)?
  3. How to create a Topic in Kafka through Java
  4. How Can we create a topic in Kafka from the IDE using API
  5. What determines Kafka consumer offset?
  6. Writing Custom Kafka Serializer
  7. How to Delete a topic in apache kafka [duplicate]
  8. When does the Apache Kafka client throw a “Batch Expired” exception?
  9. What is a simple, effective way to debug custom Kafka connectors?
  10. Is it possible to add partitions to an existing topic in Kafka 0.8.2
  11. How to get kafka consume lag in java program
  12. Handling exceptions in Kafka streams
  13. Is it possible to access message headers with Kafka Streams?
  14. Dynamically connecting a Kafka input stream to multiple output streams
  15. How to create Custom serializer in kafka?
  16. Kafka Consumer CommitFailedException
  17. Can a Kafka consumer(0.8.2.2) read messages in batch
  18. How can I delete a topic in Apache Kafka? [duplicate]
  19. log4j redirect stdout to DailyRollingFileAppender
  20. NoClassDefFoundError in Java: com/google/common/base/Function
  21. How does double to int cast work in Java
  22. Why does Guava’s ImmutableList have so many overloaded of() methods?
  23. Difference between returning null and “” from a JSF action
  24. Problems importing project into Android Studio regarding ActionBarSherlock
  25. Java: Why does this swap method not work? [duplicate]
  26. Split string into individual words Java
  27. New java.security.AccessControlException in Java 8
  28. Fastest way of finding the middle value of a triple?
  29. How to show a notification without a sound java
  30. java daemon thread and non-daemon thread

Leave a Comment