英文: How to trace two asynchronous go routines with open telemetry 问题 我正在尝试使用Open Telemetry追踪具有两个Go协程...
Benthos带有SSL身份验证的Kafka消费者
英文: Benthos kafka consumer with ssl authentication 问题 我正在使用benthos(https://www.benthos.dev/)来消费来自Kaf...
Kafka日志在Go服务中
英文: Kafka logs in go service 问题 我需要用于调试的Kafka消费者日志。我按照以下步骤进行操作: chanLogs := make(chan confluentkafka...
Extracting Data From Kafka REST Proxy in Go
英文: Extracting Data From Kafka REST Proxy in Go 问题 我正在使用Kafka的REST代理实例来生产和消费消息。我正在使用API获取新消息,但是我无法将这...
安装golang Shopify/sarama Kafka库时出现错误。
英文: Error installing golang Shopify/sarama Kafka library 问题 在安装golang的github.com/Shopify/sarama kafk...
将数据以cloudevents格式发送到Kafka主题。
英文: Send data in cloudevents format to Kafka topic 问题 你好!根据你的描述,你想将数据以CloudEvents格式发送到Kafka。你提到的代码中,...
如何将Watermill(用于Kafka的库)中的解组器更改为Avro?
英文: How to change unmarshaler in watermill (lib for Kafka) to avro 问题 我正在尝试调试为什么无法对通过Kafka接收并使用基于Avr...
如何确保每条消息都能成功处理?
英文: How to make every message process successfully? 问题 以下是一个具有3个Go协程的服务,用于处理来自Kafka的消息: Channel-1和Ch...
NATS Jetstream是否通过键提供消息排序?
英文: Does NATS Jetstream provide message ordering by a key? 问题 我是新接触NATS Jetstream,我一直在阅读他们的官方文档(http...
Docker构建失败,由于kafka未定义的错误。
英文: Docker build fails due to kafka undefined error 问题 当我尝试构建我们的Go应用程序时,我们遇到了以下错误。 => ERROR [buil...
41