Add list of topics/consumers method to get consumers with the specific topic

[kennycontreras]

Description

Similar to the behavior of list_consumer_groups in KafkaAdminClient, adding a new method that returns the list of topics with the corresponding consumers would be a good feature.

Suggested Solution

This method could be implemented using the KafkaAdminClient class.

admin_client = KafkaAdminClient(bootstrap_servers=['broker-1',
                                                   'broker-2',
                                                   'broker-3'],)

print(admin_client.list_topics_consumers()

[('topic_1_test', ['consumer_test_1', 'consumer_test_2']), ('topic_2_test', ['consumer_test_3', 'consumer_test_4'])]

Alternative

Inside the Kafka Consumer. A similar method can work for a specific topic, which receives a topic as a parameter and returns the consumer list.

consumer = KafkaConsumer(bootstrap_servers=['broker-1',
                                            'broker-2',
                                            'broker-3'],)

print(consumer.get_consumer('topic_1_test')

['consumer_test_1', 'consumer_test_2']