connect/config/kafka.go

package config

import "time"

type kafka struct {
	Brokers   []string // Brokers kafka 集群
	Topic     string   // Topic 主题
	Partition int      // Partition po
	MaxBytes  int      // MaxBytes 最大字节数

	Timeout   time.Duration // Timeout 超时时间
	DualStack bool          // DualStack 双栈
}