英文: How can I stop Dapr Kafka Component from connecting to closed consumer groups? 问题 我在Kubernetes中有...
发布到Redpanda代理时代理不可用
英文: Broker not available when publishing to Redpanda broker 问题 当我尝试向Redpanda代理发布消息时,我遇到了错误The broker...
无法使用Sarama库更新Kafka中的分区
英文: Unable to Update partitions in kafka using Sarama Library 问题 我已经尝试使用Sarama Go库来更新Kafka中的分区,有人可以建...
如何在运行时更改主题的偏移量?
英文: How to change offset of a topic during runtime? 问题 我有一个为 Kafka 主题提供消息的生产者,并且还有另一个服务从主题中读取这些消息。 我...
sarama.ConsumePartition实例是共享默认组还是使用不同的组?
英文: sarama.ConsumePartition instances is sharing default group or using different group? 问题 当我在不同的进程...
Sarama Cluster Admin – Broker Connected方法返回false。
英文: Sarama Cluster Admin - Broker Connected method return false 问题 版本 Sarama - v1.32.0 Kafka - 5.4.6...
gopls returns the error "gopls: no packages returned: packages.Load error" for github.com/Shopify/sarama
英文: gopls returns the error "gopls: no packages returned: packages.Load error" for github....
如何使用Shopify/sarama Golang库在Kafka中为主题添加消费者组?
英文: How to add consumerGroup for a topic in kafka using Shopify/sarama golang library? 问题 在sarama库中,...
安装golang Shopify/sarama Kafka库时出现错误。
英文: Error installing golang Shopify/sarama Kafka library 问题 在安装golang的github.com/Shopify/sarama kafk...
Golang删除Kafka主题中的所有记录。
英文: Golang delete all records from a topic in Kafka 问题 嗨,我正在使用Go和Kafka编写一个服务,并且需要实现一个删除所有记录的端点,该端点将从...