golang操作kafka消费消息示例代码
代码语言:golang
所属分类:其他
代码描述:golang操作kafka消费消息示例代码
代码标签: golang 操作 kafka 消费 消息 示例 代码
下面为部分代码预览,完整代码请点击下载或在bfwstudio webide中打开
package main import ( "fmt" "github.com/Shopify/sarama" ) func main() { config := sarama.NewConfig() config.Consumer.Return.Errors = true // consumer consumer, err := sarama.NewConsumer([]string{"127.0.0.1:9092"}, config) if err != nil { fmt.Printf("consumer_test create consumer error %s\n", err.Error()) return } defer consumer.Close() partition_consumer, err := consumer.ConsumePartition("test", 0, sarama.OffsetOldest) if err != .........完整代码请登录后点击上方下载按钮下载查看
网友评论0