CMAK
CMAK copied to clipboard
kafka manager don't show consumer lag or Sum of partition offsets
I don't know if it is config issue or not. The kafka manager can get everything except consumer lag. Can anyone help me?
I'm using kafka 1.0
Here are the screenshots
Here are the configs
I also checked logs, no errors at all.
I am having the same issue even when using a PLAINTEXT protocol, but it only happens if any acls are set on the topic.
I have acl=2. I will try removing it and see
Has this problem been solved(adding acls then no offsets found in manager)?
I have not checked yet, but I do not see the mentioned issue fixing this.
Just my 2 cents here...
Having 2 equally configured clusters on my end:
- dev consisting of one node, metric show up correctly there
- prod consisting of 3 nodes, metric is always zero
Maybe it will be useful in investigation...
my cluster having issue has 3 nodes as well
me too with api return like this
{
"totalLag": null,
"percentageCovered": 100,
"partitionOffsets": [
10,
14,
11,
13,
11,
11,
12,
13,
11,
6
],
"partitionLatestOffsets": [],
"owners": [
]
}
Not working on my single node, plaintext Kafka. Any progress on this issue?
I pulled up fresh release from master branch. Still nothing. I am using Kafka 2.0 btw. Please resolve this issue. It is a very critical and helpful feature.
I am running into some scala issues (This is little off topic here but I digged more to find a binary but didn't find one) [error] scala.reflect.internal.MissingRequirementError: object java.lang.Object in compiler mirror not found. Do we have any binaries to install this as a tool directly rather depending on src?
Someone already fixed it?
I don't know if it is config issue or not. The kafka manager can get everything except consumer lag. Can anyone help me?
I'm using kafka 2.2.0
I also checked logs, no errors at all.
And also one of the important thing is that my code base is processing messages and inserting to database as well. But why I posted this question is that I may not be to see lags in the topic is exist or not.
Did anyone figure out the root case of the issue and fix it?
Getting the same issue, we're using PLAINTEXT. Any solution so far?