Categorygithub.com/opendevops-cn/codo-golang-sdkkafka
package
0.4.5
Repository: https://github.com/opendevops-cn/codo-golang-sdk.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
13
Dependents
0
Files
229 SLOC

# Functions

No description provided by the author
No description provided by the author
WithBrokerAddrs 配置 Kafka BootstrapServer 地址列表.
WithMaxOpenConns 配置 Kafka 最大连接超时时间.
WithGroupID 配置 Kafka Consumer Group ID.
WithMaxIdleConns 配置 Kafka 最大读取超时时间.
WithSASLMechanism 配置 SASL 认证机制.
WithSASLPassword 配置 SASL 密码.
WithSASLUsername 配置 SASL 用户名.
WithConnMaxLifetime 配置 Kafka 最大写入超时时间.

# Structs

KafkaConfig 包含 Kafka 连接配置.

# Type aliases

KafkaConfigOption 用于配置 Kafka 配置项的函数类型.