kafka

type KafkaConfig struct {
	// Kafka Broker 地址列表
	BootstrapServers []string `json:"bootstrap_servers" yaml:"bootstrap_servers" env:"DEFAULT_KAFKA_BOOTSTRAP_SERVERS"`

	// Kafka Consumer Group Id
	GroupId string `json:"group_id" yaml:"group_id" env:"DEFAULT_KAFKA_GROUP_ID"`

	// SASL 用户名（如果需要使用 SASL 认证）
	SASLUsername string `json:"sasl_username" yaml:"sasl_username" env:"DEFAULT_KAFKA_SASL_USERNAME"`

	// SASL 密码（如果需要使用 SASL 认证）
	SASLPassword string `json:"sasl_password" yaml:"sasl_password" env:"DEFAULT_KAFKA_SASL_PASSWORD"`

	// SASL 认证机制（如 PLAIN）
	SASLMechanism string `json:"sasl_mechanism" yaml:"sasl_mechanism" env:"DEFAULT_KAFKA_SASL_MECHANISM"`

	// Kafka 最大请求空闲时间（单位：秒）
	MaxOpenRequests uint32 `json:"max_open_requests" yaml:"max_open_requests" env:"DEFAULT_KAFKA_MAX_OPEN_REQUESTS"`

	// DialTimeout   最大连接超时时间（单位：秒）
	DialTimeout uint32 `json:"dial_read_timeout" yaml:"dial_read_timeout" env:"DEFAULT_KAFKA_DIAL_READ_TIMEOUT"`

	// ReadTmout 最大读取超时时间（单位：秒）
	ReadTimeout uint32 `json:"read_timeout" yaml:"read_timeout" env:"DEFAULT_KAFKA_READ_TIMEOUT"`

	// WriteTimeout 最大写入超时时间（单位：秒）
	WriteTimeout uint32 `json:"write_timeout" yaml:"write_timeout" env:"DEFAULT_KAFKA_WRITE_TIMEOUT"`

	// OpenTelemetry 跟踪提供者
	TracerProvider trace.TracerProvider `json:"-"`

	// OpenTelemetry 度量提供者
	MeterProvider metric.MeterProvider `json:"-"`

	// OpenTelemetry 传播器
	Propagator propagation.TextMapPropagator `json:"-"`
}

type KafkaConfigOption func(c *KafkaConfig)