kafka

type Client struct {
	// contains filtered or unexported fields
}

type Config struct {
	ServerList  []string // kafka服务器地址
	SendTimeOut int      // 发送超时时间， 单位毫秒
	RetryTime   int      // 重传次数， 消息系统里面快速失败，不保证数据的高可到达性
	RetryWait   int      // 重传的等待时间, 单位毫秒
	Print       int      // 错误打印在串口
	OffSet      int64    // 启动时，接收消息的位置， -1 从最新的开始读， -2：从上次的问题开始读
	Group       string   // 读消息的组配置
}