confluent-kafka-go icon indicating copy to clipboard operation
confluent-kafka-go copied to clipboard

Added rd_kafka_list_groups API to get consumer group subscription metadata

Open simnotes opened this issue 5 years ago • 4 comments

I added new GetConsumerGroupsMetadata function to consumer, producer and adminClient API, which calls rd_kafka_list_groups from librdkafka to retrieve current consumer group status and consumer group subscriptions from broker. Via the new API it is possible to query subscription-status like in "kafka-consumer-groups.sh"

Also added integration and dry-tests to everything.

(somehow this is a copy form pr #331 )

simnotes avatar May 17 '19 06:05 simnotes

@confluentinc It looks like @simnotes just signed our Contributor License Agreement. :+1:

Always at your service,

clabot

ghost avatar May 17 '19 06:05 ghost

@edenhill I published the included changes prior to the 1.0.0 release and you told me, that those changes might be merged after the release (which is understandable). So now I merged the 1.0.0 release with my changes, fixed the merge issues, ran the tests again and everything seems to be ok -> Do you mind, having a look again?

simnotes avatar May 17 '19 12:05 simnotes

Hi !

Any news on this topic ? It should be a great feature !

nsagnett avatar Jun 03 '21 16:06 nsagnett

CLA assistant check
Thank you for your submission! We really appreciate it. Like many open source projects, we ask that you all sign our Contributor License Agreement before we can accept your contribution.
0 out of 2 committers have signed the CLA.

:x: Simon Streubel
:x: simnotes


Simon Streubel seems not to be a GitHub user. You need a GitHub account to be able to sign the CLA. If you have already a GitHub account, please add the email address used for this commit to your account.
You have signed the CLA already but the status is still pending? Let us recheck it.

CLAassistant avatar Apr 01 '22 15:04 CLAassistant

Closing this now that rd_kafka_list_groups is deprecated and replaced with rd_kafka_ListConsumerGroups and rd_kafka_DescribeConsumerGroups.

Both are available in the go client via #923.

milindl avatar May 15 '23 16:05 milindl