pykafka
-
Kafka 生产者始终将消息发送到同一分区 (Kafka + Python)
-
如何自动生成消息的分区键（Kafka + Python）？
-
同一组下不同分区的Kafka消费者仍然间歇性地消费相同的消息
-
confluent-kafka-python 库：每个主题每个 consumer_group 的读取偏移量
-
将 csv 文件写入 kafka 主题
-
无法使用pykafka发送消息
-
无法从远程机器与 Kafka 集群通信
-
TypeError: produce() got an unexpected keyword argument 'linger_ms'
-
PyKafka 客户端连接错误的代理
-
如何通过http消费kafka主题和parse/serve？
-
PyKafka 元数据以字节而不是字符串为单位
-
我可以在生产一批消息后从 Kafka 产品中调用一次 get_delivery_report 吗？
-
Kafka 和 Pyspark 集成
-
如何在 Pykafka simpleconsumer 中 select 起始偏移量？
-
如何将 pykafka 组消费者与 gevent 一起使用？
-
pykafka 主题 return None
-
如何使 kafka-python 或 pykafka 与 uwsgi 和 gevent 一起作为异步生产者工作？
-
What's the reason for TypeError: unhashable type: 'TopicAndPartition' when KafkaUtils.createDirectStream?