Hi, Maybe you are looking for something like https://github.com/uber/chaperone ?
See also: * https://issues.apache.org/jira/browse/KAFKA-260 * https://sematext.com/blog/2016/06/07/kafka-consumer-lag-offsets-monitoring/ Otis -- Monitoring - Log Management - Alerting - Anomaly Detection Solr & Elasticsearch Consulting Support Training - http://sematext.com/ On Thu, Feb 9, 2017 at 4:51 AM, Sharninder <sharnin...@gmail.com> wrote: > All consumers will "eventually" get the messages. What is it that you want > to achieve by monitoring that? For the brokers you can monitor lag, for the > producers you can have a counter that tracks messages sent and for > consumers have one that tracks messages consumed. Although, just tracking > lag will probably be sufficient. > > > On Thu, Feb 9, 2017 at 2:19 PM, Nabajyoti Dash < > nabajyoti.dash1...@gmail.com > > wrote: > > > Hi all, > > I have requirement to monitor — wheather every message sent by the > > producer is received by each and every kafka consumers or not. > > > > That is if any message is not delivered then it should be taken care of > > properly. > > > > I googled out but didn’t find any satisfactory answers. > > Please suggest. > > > > Thanks, > > NJ Dash > > > > > -- > -- > Sharninder >
