Skip to content

Instantly share code, notes, and snippets.

@luccabb

luccabb/delete_topic.py

Created November 29, 2021 07:20
Show Gist options
  • Save luccabb/163e456b170def0d5eb851588066ea45 to your computer and use it in GitHub Desktop.
Save luccabb/163e456b170def0d5eb851588066ea45 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
delete_topic.py
from kafka.admin import KafkaAdminClient, NewTopic
admin_client = KafkaAdminClient(
bootstrap_servers="localhost:9093",
client_id='test'
)
admin_client.delete_topics(['topic_name'])
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment