python - kafka python没有收到来自golang生产者的消息
问题描述
我正在使用segmentio-go通过 golang 发布消息。我想使用我尝试过kafka-python、pykafka的 python 来阅读这些消息。
在所有这些库中,我无法接收消息,我可以通过在 golang 端创建消费者来从 golang 读取消息时读取消息。而且当我通过python发布消息时,我可以从python消费者和golang消费者那里读取它,但是那些通过golang发布消息的主题,python端的消费者完全挂起/卡住了,代码没有'不要崩溃,但也不要响应。
在 python 消费者中,我能够获取代理及其主题,仅对于那些通过 golang 发布消息的主题,python 消费者会被挂起。
Python消费者的代码:
consumer = KafkaConsumer(<topic name>, bootstrap_servers=[<ip:port>], auto_offset_reset='earliest', group_id=None, max_partition_fetch_bytes=104857600)
print(consumer.topics()) # Able to get all topic names
for message in consumer:
print(message.value)
Golang 生产者的代码
l := log.New(os.Stdout, "kafka framer: ", 0)
w := kafka.NewWriter(kafka.WriterConfig{
Brokers: []string{broker_address},
Topic: topic_name,
Logger: l,
})
err := w.WriteMessages(ctx, kafka.Message{
Key: []byte(strconv.Itoa(0)),
Value: []byte(data),
})
if err != nil {
panic("could not write message " + err.Error())
}
请帮忙。
解决方案
推荐阅读
- typescript - 使 MaterialTopTabNavigator 不可见
- python - 如何将列表的子列表与同一列表中的其他列表的子列表进行比较
- swift - Swift:后台任务在 Apple Watch 模拟器中有效,但在设备中无效
- c++ - 如何使用 boost::karma/qi 解析日期时间?
- python - What is the best way to make a singly linked list of integer digits in Python?
- excel - 将多个工作簿中的单个工作表移动并保存为新文件
- gnupg - 有没有办法从 PGP 公钥中快速去除除一个 UID(用户 ID)之外的所有内容?
- c - 在 C 中创建具有 >1byte 键和值的哈希表
- unity3d - 如何为 Unity 映射我的搅拌机环境?
- r - 为什么在 R 中使用 tfestimators 包时出现此错误?