python - 如何使用 Python 以编程方式在 Apache Kafka 中创建主题

Question

到目前为止，我还没有看到一个 python 客户端在不使用配置选项自动创建主题的情况下显式实现主题的创建。

Answer 1

您可以使用kafka-python 以编程方式创建主题。或 confluent_kafka客户端，它是 librdkafka 的轻量级包装器.

---

使用 kafka-python

from kafka.admin import KafkaAdminClient, NewTopic


admin_client = KafkaAdminClient(
    bootstrap_servers="localhost:9092", 
    client_id='test'
)

topic_list = []
topic_list.append(NewTopic(name="example_topic", num_partitions=1, replication_factor=1))
admin_client.create_topics(new_topics=topic_list, validate_only=False)

---

使用 confluent_kafka

from confluent_kafka.admin import AdminClient, NewTopic


admin_client = AdminClient({
    "bootstrap.servers": "localhost:9092"
})

topic_list = []
topic_list.append(NewTopic("example_topic", 1, 1))
admin_client.create_topics(topic_list)