英文: How to configure Kafka environment from different frameworks of Js and Go to ship JSON 问题 我正在构建一...
跨语言(de)序列化
英文: cross language (de)serialization 问题 我正在尝试在Python中进行序列化,并在Golang中进行反序列化,但是遇到了错误。 错误信息 -- "无法...
使用segmentio/kafka-go如何读取kafka中的所有消息?
英文: How to read all messages from kafka using segmentio/kafka-go? 问题 我运行了segmentio/kafka-go包文档中的示例,但...
Kafka消费者使用confluent-kafka-go更改偏移量。
英文: kafka consumer with confluent-kafka-go change offset 问题 我使用以下配置创建了一个新的消费者: c, err := kafka.NewCo...
我们如何确保使用confluent-kafka-go客户端进行可靠且低延迟的Kafka写入?
英文: How can we ensure reliable and low-latency kafka writing using confluent-kafka-go client? 问题 在这段...
Sarama Cluster Admin – Broker Connected方法返回false。
英文: Sarama Cluster Admin - Broker Connected method return false 问题 版本 Sarama - v1.32.0 Kafka - 5.4.6...
将golang的字节数组转换为Node.js的JSON。
英文: Casting golang byte array to node json 问题 你好,我可以帮你翻译这段代码。以下是翻译的结果: 嗨,我有两个服务,一个是用Golang编写的,另一个是用N...
Kafka消费者偏移量导出的Golang代码可以使用sharma或confluent-kafka-go库。
英文: Kafka consumer offset export golang -- sharma or confluent-kafka-go lib 问题 我正在尝试找到一种在消费者组上执行偏移重置...
当我下载大文件时,Kafka会重试多次。
英文: kafka retry many times when i download large file 问题 我是Kafka的新手,我尝试构建一个发送带附件的邮件的服务。 执行流程: Kafka将...
使用Kafka将CSV文件处理为队列,插入到PostgreSQL数据库中,并返回状态消息。
英文: Processing csv files with a queue using Kafka to insert to postgres database and return status m...
41