zoukankan      html  css  js  c++  java
  • kafka使用示例

    示例代码如下:

    producer生产者

    package main
    
    import (
    	"fmt"
    	"github.com/Shopify/sarama"
    )
    func main() {
    	config := sarama.NewConfig()
    	config.Producer.RequiredAcks = sarama.WaitForAll
    	config.Producer.Partitioner = sarama.NewRandomPartitioner
    	config.Producer.Return.Successes = true
    
    	msg := &sarama.ProducerMessage{}
    	msg.Topic ="nginx_log"
    	msg.Value = sarama.StringEncoder("this is a good test,my message is good")
    
    	client,err := sarama.NewSyncProducer([]string{"192.168.1.19:9092"},config)
    	if err != nil{
    		fmt.Println("producer close,err:",err)
    		return
    	}
    
    	defer client.Close()
    
    	pid,offset,err := client.SendMessage(msg)
    	if err != nil{
    		fmt.Println("send message failed,",err)
    		return
    	}
    	fmt.Printf("pid:%v offset:%v
    ",pid,offset)
    }
    

      

  • 相关阅读:
    部分类Partial
    Ajax之XMLHttpRequest
    C#结构(Struct)
    sql数据管理语句
    mysql基本语句
    bootstrap插件-滚动监听
    一轮项目学习总结
    js滚动监听
    Ajax
    各框架、插件记录
  • 原文地址:https://www.cnblogs.com/marshhu/p/12072716.html
Copyright © 2011-2022 走看看