kafka

type Config struct {
	// Brokers Kafka 集群地址列表
	Brokers []string `json:"brokers"`
	// Topic 消费的 Topic
	Topic string `json:"topic"`
	// GroupID 消费者组 ID
	GroupID string `json:"group_id"`
	// Offset 起始位置: newest (最新) 或 oldest (最早)
	Offset string `json:"offset"`
}

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