Hello. I am trying to examine the offset and lag for a consumer group. I am trying to pinpoint any consumer lag. However, any consumer group I pick, I always get the same '-1' offset, and the lag keeps increasing. My code is consuming messages, the question is how fast. So, I don't understand the behavior I am getting. Need some help.
Here's the output that I have.
kt group -group foo -topic robot.heartbeat -partitions 0
found 1 brokers
found 1 groups
found 1 topics
{
"name": "foo",
"topic": "robot.heartbeat",
"offsets": [
{
"partition": 0,
"offset": -1,
"lag": 2471
}
]
}
Hello. I am trying to examine the offset and lag for a consumer group. I am trying to pinpoint any consumer lag. However, any consumer group I pick, I always get the same '-1' offset, and the lag keeps increasing. My code is consuming messages, the question is how fast. So, I don't understand the behavior I am getting. Need some help.
Here's the output that I have.