sender

type KafkaSender struct {
	Target KafkaTarget
	Debug  bool
}

type KafkaTarget struct {
	Brokers      []string
	Topic        string
	WriteTimeout time.Duration
}

type Sender interface {
	SendMessage([]byte) error
}