It counts the messages that pass through zookeeper and can be used in application where real time message counting is desired with polling and batch processing This repo contains two java files namely kafka producer and consumer. The goal is the produce large number of messages and consume it in batches To achieve this polling feature of zookeeper is used. Start kafka server and zookeeper on your local or server environment and run the producer and consumer independently. Make sure you change topic name , polling time as required.
-
Notifications
You must be signed in to change notification settings - Fork 0
It counts the messages that pass through zookeeper and can be used in application where real time message counting is desired with polling and batch processing
License
RuntimeeError/Kafka-polling-messages-batch
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Folders and files
Name | Name | Last commit message | Last commit date | |
---|---|---|---|---|
Repository files navigation
About
It counts the messages that pass through zookeeper and can be used in application where real time message counting is desired with polling and batch processing
Topics
Resources
License
Stars
Watchers
Forks
Releases
No releases published
Packages 0
No packages published