Skip to content

Instantly share code, notes, and snippets.

@rohitdholakia

rohitdholakia/gist:7cc53b5fbf6eda29c572f994e881154a

Created June 30, 2020 21:26
Show Gist options
  • Save rohitdholakia/7cc53b5fbf6eda29c572f994e881154a to your computer and use it in GitHub Desktop.
Save rohitdholakia/7cc53b5fbf6eda29c572f994e881154a to your computer and use it in GitHub Desktop.
Download ZIP
Raw
gistfile1.txt
from confluent_kafka import admin, ConfigResource
config = {'bootstrap.servers': 'broker:9092'}
a = admin.AdminClient(config)
fs = a.describe_configs([ConfigResource(ConfigResource.Type.TOPIC, 'topic_name')])
for f, item in fs.items(): print(item.result()) # this works great
fs = a.describe_configs([ConfigResource.Type.GROUP, 'group_name'])
# this line causes it to die!
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment