go查看kafka中的消息内容

Question

求大神！如何用sarama查看某个topic的消息内容

Answer 1

要使用sarama库查看kafka中某个topic的消息内容，你可以通过以下步骤实现：

1. 创建一个sarama的consumer对象，可以通过以下代码实现：

config := sarama.NewConfig()
consumer, err := sarama.NewConsumer([]string{"kafka_host:9092"}, config)

1. 通过consumer对象获取某个topic的partition，可以通过以下代码实现：

partitionConsumer, err := consumer.ConsumePartition("topic_name", 0, sarama.OffsetNewest)

第一个参数为topic的名称，第二个参数为partition的编号，第三个参数为消费的offset，如使用sarama.OffsetNewest表示从最新的offset开始消费。

1. 循环读取partition中的消息，可以通过以下代码实现：

for message := range partitionConsumer.Messages() {
    fmt.Println(message.Value)
}

其中，message.Value表示消息的内容。

完整的代码如下所示：

config := sarama.NewConfig()
consumer, err := sarama.NewConsumer([]string{"kafka_host:9092"}, config)
if err != nil {
    fmt.Println(err)
    return
}
partitionConsumer, err := consumer.ConsumePartition("topic_name", 0, sarama.OffsetNewest)
if err != nil {
    fmt.Println(err)
    return
}
for message := range partitionConsumer.Messages() {
    fmt.Println(message.Value)
}

以上就是使用sarama查看kafka中某个topic的消息内容的方法，希望能对你有所帮助。