标签：kafka-python
-
如何使用Python在Apache Kafka中以编程方式创建主题 - python
到目前为止，我还没有看到没有使用配置选项自动创建主题的显式实现主题创建的python客户端。 参考方案 您可以使用 kafka-python 或 confluent_kafka 客户端(这是librdkafka的轻量级包装器)以编程方式创建主题。 使用 kafka-python from kafka.admin import KafkaAdminClient […]
-
使用Apache Kafka 0.10.0 API和Java创建Kafka经纪人集群 - java
我想使用Kafka 0.10 API和Java来创建代理群集。据我所读kafka_2.11-0.10.0.0.jar是否支持使用创建代理： import kafka.cluster.Broker; import kafka.cluster.Cluster; 但是我找不到这样做的任何文档。我最近读了[1]，它讲述了如何在Kafka API中使用Java创建主题 […]