You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Is it possible to reset a consumer group's offsets using the AdminClient?
I've been trying to experiment to figure if this is possible. I've instantiated an AdminClient and I can successfully retrieve the topics by calling list_topics(), and list my group admin.list_groups(group="mark.test3.all.sa.derive", timeout=30) successfully, but when I try to get the configs for the group:
And subsequently invoke result() on the group's future I get the following error:
cimpl.KafkaException: KafkaError{code=INVALID_REQUEST,val=42,str="This most likely occurs because of a request being malformed by the client library or the message was sent to an incompatible broker. See the broker logs for more details."}
It's unlikely to be an incompatible broker issue, otherwise the first 2 calls would not have succeeded. As far I my understanding of the documentation and looking at the tests that also invoke describe_configs() I'm doing everything correctly.
Any thoughts as to why I'm getting this error?
And can one using AdminClient actually reset the offsets for a consumer group?
I'm using version 1.9.2 of the library.
When I've looked at the broker logs in AWS Cloudwatch, I see the following error:
org.apache.kafka.common.errors.InvalidRequestException: Unexpected resource type UNKNOWN for resource mark.test3.all.sa.derive
It would appear whether I pass ResourceType.GROUP or 3 (GROUP) as the first argument to ConfigResource, the broker is receiving UNKNOWN for that group. The group does exist.
reacted with thumbs up emoji reacted with thumbs down emoji reacted with laugh emoji reacted with hooray emoji reacted with confused emoji reacted with heart emoji reacted with rocket emoji reacted with eyes emoji
Uh oh!
There was an error while loading. Please reload this page.
Uh oh!
There was an error while loading. Please reload this page.
-
Is it possible to reset a consumer group's offsets using the
AdminClient
?I've been trying to experiment to figure if this is possible. I've instantiated an
AdminClient
and I can successfully retrieve the topics by callinglist_topics()
, and list my groupadmin.list_groups(group="mark.test3.all.sa.derive", timeout=30)
successfully, but when I try to get the configs for the group:And subsequently invoke
result()
on the group's future I get the following error:It's unlikely to be an incompatible broker issue, otherwise the first 2 calls would not have succeeded. As far I my understanding of the documentation and looking at the tests that also invoke
describe_configs()
I'm doing everything correctly.I'm using version 1.9.2 of the library.
When I've looked at the broker logs in AWS Cloudwatch, I see the following error:
It would appear whether I pass
ResourceType.GROUP
or3
(GROUP) as the first argument toConfigResource
, the broker is receivingUNKNOWN
for that group. The group does exist.Beta Was this translation helpful? Give feedback.
All reactions