Joe,
We have the following bean name and type registered for consumers. There is
also a CheckOffsetLag tool.
kafka:type=kafka.ConsumerStats
/**
* JMX interface for monitoring consumer
*/
trait ZookeeperConsumerConnectorMBean {
def getPartOwnerStats: String
def getConsumerGroup: String
def getOffsetLag(topic: String, brokerId: Int, partitionId: Int): Long
def getConsumedOffset(topic: String, brokerId: Int, partitionId: Int):
Long
def getLatestOffset(topic: String, brokerId: Int, partitionId: Int): Long
}
Thanks,
Jun
On Wed, Aug 1, 2012 at 10:10 AM, Joseph Boyd <[email protected]
> wrote:
> Hi there,
>
> Is there any way to know from kafka's JMX interface whether there are
> unread messages on a topic? I think the answer is 'no', based on my
> read of documentation (esp. the 'high water mark'), and my own
> experiments with producing test messages, looking at the stats, and
> then consuming messages (both with/without committing messages
> consumed).
>
> I thought I'd double check on the users list anyhow, though, in case
> I'm missing something. The KAFKA-260 work looks useful in this area
> too.
>
> Thanks for any help.
>
>
> ...joe
>
