用户提供的字符串随每个请求发送到代理进行日志记录，调试和审计目的。默认为“sarama”，但你应该将其设置为特定于您的应用程序的内容。.

设置kafka消费者配.

OffsetNewest -1 or OffsetOldest -2 默认 OffsetOldest.

如果启用，则在消费时发生的任何错误都将返回错误通道（默认禁用）.

kafka启动类型.

设置消费组 GroupId.

设置kafka集群地址.

kafka启动类型.

默认5 秒.

KeepAlive 指定活动网络连接的保持活动期。如果为零，则禁用保活。 （默认为 0：禁用）单位 秒.

默认60 秒.

默认60 秒.

用于消息的压缩类型（默认为无压缩）.

用于消息的压缩级别。意义取决于在实际使用的压缩类型上，默认为默认压缩编解码器的级别。.

消息的最大允许大小（默认为 1000000）。应该设置等于或小于代理的 `message.max.bytes`.

设置生产者 消息 回复等级 0 1 all.

重试发送消息的总次数（默认为 3）.

重试发送消息的总次数（默认为 3）.

如果启用，发送失败的消息将在错误通道中.

如果启用 成功发送的消息将在成功通道中.

如果启用，则开启认证过程.

Sasl_Enable 开启 时需要确定认证方式.

Sasl_Enable 开启 时需要确定认证方式.

kafka启动类型.

设置kafka消费者的消费Topics.

设置kafka版本.

全部启动.

异步生产者.

异步生产和消费.

kafka客户端.

消费者.

同步生产者.

同步生产者和消费.

系统描述:kafka驱动库系统 */.

系统描述:kafka驱动库系统 */.