我正在使用sarama（1.27）ClusterAdmin管理kafka1.1.0中的主题。我管理kafka主题的应用程序正在作为REST服务运行

我正在尝试改编来自<code>github.com/Shopify/sarama</code>的消费者组示例中的代码，并努力在<code>session.MarkMessag

我正在尝试为配置了<a href="https://github.com/shopify/sarama" rel="nofollow noreferrer"><code>github.com/Shopify/sarama</code></

我在使用协议缓冲区时正在使用的一种用例是反序列化在用户端（使用sarama库和Go）接收到的协议缓冲区

我有一个用例，我想将 <code>consumer_group_2</code> 重命名为 <code>consumer_group</code>。我想这样做是因为我想从

这是我第一次尝试连接到托管在 AWS 服务器上的 Confluent Kafka 集群，但不使用任何 Amazon Managed Streaming 服

我有一个关于 sarama Go 语言 Kafka 库的看似简单的问题：当 Kafka 代理由于空闲超时（由 <code>connections.max.id

<h2>用例：</h2> <ul> <li>Producer：在主题 <code>db.inventory.customers</code></li> 写入 Kafka <li>ConsumerGroup1 (cg1)：从 <code>

我们的消费者组正在处理 100 多个主题（所有主题只有一个分区，所有 100 个主题的分区0） 例如在

我正在尝试使用 <a href="https://pkg.go.dev/go.uber.org/zap#example-package-AdvancedConfiguration" rel="nofollow noreferrer">zap lo

对不起，我有一个关于 kafka 使用 Shopify/sarama 的问题。 <ol> <li>我必须实现 func <code>ConsumeClaim</code> 并

我正在尝试让一些消费者处理来自 kafka 的消息，我想实现 kubernetes 部署可扩展性以实现弹性消息处理能

如果不知道代理地址，有没有办法开始与 Sarama 中的 Kafka 集群交互？ 如果用于连接集群的代理宕机了，

<a href="https://github.com/Shopify/sarama" rel="noreferrer">Shopify/sarama</a> 是否提供类似于 JVM API 中的 <a href="https://kaf

我正在尝试使用 sarama 获取 kafka 生产者/消费者指标。但我找不到任何关于如何做同样的例子。有人可以

嗨，我正在用 Go 和 Kafka 编写一个服务，我需要实现一个删除所有端点，该端点将从特定主题中删除所有