英文: How to set consumer to start from a specific offset in Golang Kafka 10 问题 我的需求是在生产者在崩溃之前处理的最后一条消...
107评论apache-kafka
go
如何在Golang Kafka 10中设置消费者从特定偏移量开始？
107评论apache-kafka
go
107评论apache-kafka
go
Golang Kafka无法消费所有最新偏移量的消息。
英文: Golang Kafka not consuming all messages offsetnewest 问题 首先批次： 我正在尝试从100个平面文件中提取数据，将其加载到一个数组中，并将它...
84评论apache-kafka
go
如何在Golang Kafka 10中获取分区的消费者组偏移量
英文: How to get consumer group offsets for partition in Golang Kafka 10 问题 现在Golang Kafka库（sarama）提供了...
81评论apache-kafka
go
在Go中消费Kafka Avro消息
英文: Consume Kafka Avro messages in go 问题 我正在尝试在Go中消费Avro格式的Kafka消息，但无法将Avro消息解码为JSON。 我正在使用Confluent...
76评论apache-kafka
go
从我的边缘节点推送Kafka消息的最佳方法是什么？
英文: What's the best way to push kafka messages from my edge nodes? 问题 我在主要地区（美国东部）有一个工作人员，负责计算我们...
85评论apache-kafka
go
使用Shopify Sarama处理Kafka错误
英文: Kafka Error Handling using Shopify Sarama 问题 所以我正在尝试在我的应用程序中使用Kafka，该应用程序具有将操作记录到Kafka消息队列的生产者和读...
93评论apache-kafka
go
41