kafka

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

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

type Config struct {
	// Brokers Kafka 集群地址列表
	Brokers []string `mapstructure:"brokers"`

	// Version Kafka 版本（如 "3.8.0"）
	Version string `mapstructure:"version"`

	// ClientID 客户端标识
	ClientID string `mapstructure:"client_id"`

	// Producer 生产者配置
	Producer ProducerConfig `mapstructure:"producer"`

	// Consumer 消费者配置
	Consumer ConsumerConfig `mapstructure:"consumer"`

	// SASL 认证配置（可选）
	SASL *SASLConfig `mapstructure:"sasl"`

	// TLS 配置（可选）
	TLS *TLSConfig `mapstructure:"tls"`
}

type ConsumedMessage struct {
	// Topic 消息来源 Topic
	Topic string

	// Partition 消息分区
	Partition int32

	// Offset 消息 Offset
	Offset int64

	// Key 消息键
	Key []byte

	// Value 消息值
	Value []byte

	// Headers 消息头
	Headers map[string]string

	// Timestamp 消息时间戳
	Timestamp int64
}

type Consumer interface {
	// Start 启动消费者
	Start(ctx context.Context, handler MessageHandler) error

	// Stop 停止消费者
	Stop() error

	// IsRunning 检查是否运行中
	IsRunning() bool
}

type ConsumerConfig struct {
	// Enabled 是否启用消费者
	Enabled bool `mapstructure:"enabled"`

	// GroupID 消费者组 ID
	GroupID string `mapstructure:"group_id"`

	// Topics 订阅的 Topic 列表
	Topics []string `mapstructure:"topics"`

	// OffsetInitial 初始 Offset：-1=Newest, -2=Oldest
	OffsetInitial int64 `mapstructure:"offset_initial"`

	// AutoCommit 是否自动提交 Offset
	AutoCommit bool `mapstructure:"auto_commit"`

	// AutoCommitInterval 自动提交间隔
	AutoCommitInterval time.Duration `mapstructure:"auto_commit_interval"`

	// SessionTimeout 会话超时
	SessionTimeout time.Duration `mapstructure:"session_timeout"`

	// HeartbeatInterval 心跳间隔
	HeartbeatInterval time.Duration `mapstructure:"heartbeat_interval"`

	// MaxProcessingTime 单条消息最大处理时间
	MaxProcessingTime time.Duration `mapstructure:"max_processing_time"`

	// FetchMin 最小拉取字节数
	FetchMin int32 `mapstructure:"fetch_min"`

	// FetchMax 最大拉取字节数
	FetchMax int32 `mapstructure:"fetch_max"`

	// FetchDefault 默认拉取字节数
	FetchDefault int32 `mapstructure:"fetch_default"`

	// RebalanceStrategy 再平衡策略：range, roundrobin, sticky
	RebalanceStrategy string `mapstructure:"rebalance_strategy"`
}

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

type ConsumerGroupInfo struct {
	State        string
	ProtocolType string
	Members      []ConsumerGroupMember
}

type ConsumerGroupMember struct {
	MemberID   string
	ClientID   string
	ClientHost string
}

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

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

type KafkaMetricsConfig struct {
	Enabled         bool
	RecordLag       bool
	RecordBatchSize bool
}

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

type Message struct {
	// Topic 目标 Topic
	Topic string

	// Key 消息键（用于分区）
	Key []byte

	// Value 消息值
	Value []byte

	// Headers 消息头
	Headers map[string]string

	// Partition 指定分区（-1 表示自动分配）
	Partition int32

	// Timestamp 消息时间戳
	Timestamp time.Time
}

type MessageHandler func(ctx context.Context, msg *ConsumedMessage) error

type PartitionInfo struct {
	ID       int32
	Leader   int32
	Replicas []int32
	ISR      []int32
}

type Producer interface {
	// Send 同步发送消息
	Send(ctx context.Context, msg *Message) (*ProducerResult, error)

	// SendAsync 异步发送消息
	SendAsync(msg *Message, callback func(*ProducerResult, error))

	// SendJSON 发送 JSON 消息
	SendJSON(ctx context.Context, topic string, key string, value interface{}) (*ProducerResult, error)

	// Close 关闭生产者
	Close() error
}

type ProducerConfig struct {
	// Enabled 是否启用生产者
	Enabled bool `mapstructure:"enabled"`

	// RequiredAcks 确认级别：0=NoResponse, 1=WaitForLocal, -1=WaitForAll
	RequiredAcks int `mapstructure:"required_acks"`

	// Timeout 生产超时时间
	Timeout time.Duration `mapstructure:"timeout"`

	// RetryMax 最大重试次数
	RetryMax int `mapstructure:"retry_max"`

	// RetryBackoff 重试间隔
	RetryBackoff time.Duration `mapstructure:"retry_backoff"`

	// MaxMessageBytes 单条消息最大字节数
	MaxMessageBytes int `mapstructure:"max_message_bytes"`

	// Compression 压缩算法：none, gzip, snappy, lz4, zstd
	Compression string `mapstructure:"compression"`

	// Idempotent 是否启用幂等生产者
	Idempotent bool `mapstructure:"idempotent"`

	// BatchSize 批量发送大小
	BatchSize int `mapstructure:"batch_size"`

	// FlushFrequency 刷新频率
	FlushFrequency time.Duration `mapstructure:"flush_frequency"`
}

type ProducerResult struct {
	// Topic 发送的 Topic
	Topic string

	// Partition 发送的分区
	Partition int32

	// Offset 消息 Offset
	Offset int64

	// Timestamp 服务端时间戳
	Timestamp time.Time
}

type SASLConfig struct {
	// Enabled 是否启用
	Enabled bool `mapstructure:"enabled"`

	// Mechanism 认证机制：PLAIN, SCRAM-SHA-256, SCRAM-SHA-512
	Mechanism string `mapstructure:"mechanism"`

	// Username 用户名
	Username string `mapstructure:"username"`

	// Password 密码
	Password string `mapstructure:"password"`
}

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

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

type TLSConfig struct {
	// Enabled 是否启用 TLS
	Enabled bool `mapstructure:"enabled"`

	// CertFile 证书文件路径
	CertFile string `mapstructure:"cert_file"`

	// KeyFile 密钥文件路径
	KeyFile string `mapstructure:"key_file"`

	// CAFile CA 证书文件路径
	CAFile string `mapstructure:"ca_file"`

	// InsecureSkipVerify 是否跳过证书验证
	InsecureSkipVerify bool `mapstructure:"insecure_skip_verify"`
}

type TopicInfo struct {
	NumPartitions     int32
	ReplicationFactor int16
	Partitions        []PartitionInfo
}

type XDGSCRAMClient struct {
	*scram.Client
	*scram.ClientConversation
	HashGeneratorFcn scram.HashGeneratorFcn
}