Matt Garbis created KAFKA-6660: ---------------------------------- Summary: Monitoring number of messages expired due to retention policy Key: KAFKA-6660 URL: https://issues.apache.org/jira/browse/KAFKA-6660 Project: Kafka Issue Type: Improvement Reporter: Matt Garbis
I have not been able to find this out, but is there a way to monitor how many messages were expired based on the retention policy? If not, JMX metrics like this would be very useful for my team. I would like to be able to filter this by topic and broker. Something like: {code:java} kafka.server:type=BrokerTopicMetrics,name=MessagesExpiredPerSec{code} Additionally taking this one step further, it would be cool to be able to monitor how many messages a consumer group did not consume before they were expired. -- This message was sent by Atlassian JIRA (v7.6.3#76005)