D_WithCA 设置证书.

D_WithUserNamePassword 设置用户名称密码.

DefaultDialer 获取默认的链接对象.

读取器配置设置 DefaultReaderConfig 默认读取器配置.

写入器配置设置 DefaultWriterConfig 默认写入器器配置.

GetDialer 获取链接.

InitDefaultDialer 初始化默认的Dialer.

NewDialer 创建新的拨号器.

NewReader 创建新的Kafka读取对象.

NewReaderChannel 创建新的读取器 并将读取内容输出到管道.

NewWriter 创建新的Kafka数据写入器.

NewWriter1 创建新的Kafka写入器.

R_WithBroker 读取器 配置Broker.

R_WithDialer 读取器 配置链接器.

R_WithErrorLogger 读取器 错误日志.

R_WithGroup 读取器 配置消费者组.

R_WithLogger 读取器 日志.

R_WithMaxBytes 读取器 配置最多读取字节数.

R_WithMinBytes 读取器 配置最少读取字节数.

R_WithTopic 读取器 配置主题.

W_WithBatchBytes 写入器 配置批量发送字节数上限.

W_WithBroker 写入器 配置Broker.

W_WithDialer 写入器 配置链接器.

W_WithErrorLogger 写入器 错误日志.

W_WithLogger 写入器 日志.

W_WithTopic 写入器 配置主题.

KafkaDialerOptionHandler Kafka链接器配置选项.

KafkaOptionHandler Kafka配置选项.

KafkaOptionHandler Kafka配置选项.