kafka

type Config struct {
	Encoder        string `toml:"encoder"`
	BrokerList     string `toml:"broker_list"`
	Topic          string `toml:"topic"`
	Partition      int32  `toml:"partition"`
	MaxPayloadSize int    `toml:"max_payload_size"`
	Compression    string `toml:"compression"`
}

type KafkaSink struct {
	sync.Mutex
	// contains filtered or unexported fields
}

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