如何在Golang中创建kafka消费者组？
可用的库是sarama（或其扩展sarama-
cluster
），但是没有提供消费者群体示例，在sarama或sarama-cluster中均未提供。
我不了解API。我可以举一个为主题创建消费者组的示例吗？
问题答案：
消费方组由集群消费方“构造函数”的第二个参数指定。这是一个非常基本的草图：
import (
"github.com/Shopify/sarama"
"github.com/bsm/sarama-cluster"
)
conf := cluster.NewConfig()
// add config values
brokers := []string{"kafka-1:9092", "kafka-2:9092"}
group := "Your-Consumer-Group"
topics := []string{"topicName"}
consumer := cluster.NewConsumer(broker, group, topics, conf)
因此，您将拥有一个属于指定消费者组的消费者。
-
我使用的是camel-kafka版本。以下是KafkaURI： 请注意，我在URI选项中使用了。但是，当我一次将多条消息发布到主题时（全部发布到同一个分区），kafka使用者将依次接收这些消息。怎样才能同时接收到这些信息？ 我正在寻找如下的解决方案： 是我用来从ibm MQ中同时读取的内容
-
假设我有一个服务，它通过kafka-rest-proxy来消费消息，并且总是在同一个消费者组上。我们还可以说，它正在消耗一个有一个分区的主题。当服务启动时，它在kafka-rest-proxy中创建一个新的使用者，并使用生成的使用者url，直到服务关闭。当服务重新启动时，它将在kafka-rest-proxy中创建一个新的消费者，并使用新的url（和新的消费者）进行消费。 > 因为kafka每个分
-
本文向大家介绍Kafka 的消费者如何消费数据相关面试题，主要包含被问及Kafka 的消费者如何消费数据时的应答技巧和注意事项，需要的朋友参考一下 消费者每次消费数据的时候，消费者都会记录消费的物理偏移量（offset）的位置 等到下次消费时，他会接着上次位置继续消费
-
我刚接触Kafka，很少阅读教程。我无法理解使用者和分区之间的关系。 请回答我下面的问题。 > 消费者是否由ZK分配到单个分区，如果是，如果生产者将消息发送到不同的分区，那么其他分区的消费者将如何使用该消息？ 我有一个主题，它有3个分区。我发布消息，它会转到P0。我有5个消费者（不同的消费者群体）。所有消费者都会阅读P0的信息吗？若我增加了许多消费者，他们会从相同的P0中阅读信息吗？如果所有消费者
-
当我向主题“Test19”发送任何消息时，配置的ServiceActivator“ProcessMessage”方法将两条消息显示为配置的两个客户，但这里的问题是，在添加到消费者上下文之前，我需要为每个客户加载入站配置文件…否则，我只能在控制台中得到一条消息…是正确的方式还是我需要在这里改变什么？ 谢了。
-
我有一个简单的Kafka消费者微服务应用程序，它使用来自某个主题的消息，同一个应用程序运行在两个不同的池中。 所以，当消息由制作人生成，而我的应用程序尝试使用来自主题的消息时，它只被一个池中的一个人使用。 如何停止从消费者Kafka读取并发消息。我想在两个池中使用相同的消息。 这种情况下可能的解决方案是什么