confluent-kafka-go
confluent-kafka-go copied to clipboard
Added rd_kafka_list_groups API to get consumer group subscription metadata
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 )
@confluentinc It looks like @simnotes just signed our Contributor License Agreement. :+1:
Always at your service,
clabot
@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?
Hi !
Any news on this topic ? It should be a great feature !
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.
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.