当前分类:kafka-consumer-api

python - 如何使用kafka.consumer.SimpleConsumer,seek()

python - 卡夫卡生产者没有选择新的分区

python - Kafka在Python中指示group_id时未收到消息

python - 如何在一条消息中向kafka产生音频(.wav)

python - 导入错误没有名为kafka的模块

python - 可以在控制台中使用Kafka消息,但不能在Python库中使用吗?

c - Kafka经纪人无法访问RD Kafka客户

c - librdkafka C API Kafka Consumer无法正确读取所有消息

python - 如何使用python列出卡夫卡消费者群

python - kafka-python使用者未收到消息

python - NoBrokersAvailable:NoBrokersAvailable-Kafka错误

python - 模块'snappy'没有属性'decompress'

java - 接收应用程序如何知道已使用哪种序列化机制?

java - 卡夫卡撞车后,偏移量消失了

java - 如何在Java中的Kafka中为消费者组获取消费者滞后

java - Kafka Consumer-Java(0.9 API)

java - 在Kafka中使用实时消息

java - 为什么我的Kafka消费者如此快速地投票?

java - 如何在kafka的__consumer_offsets主题上访问和提交偏移量?

java - 线程“ StreamThread-1”中的异常org.apache.kafka.streams.errors.StreamsException:无法重新平衡

热门标签:

c
c++
c#
go
php
css
ios