kafka

type KafkaWriter interface {
	WriteMessages(ctx context.Context, msgs ...gokafka.Message) error
}

type Message struct {
	Topic   string `json:"topic"`
	Content []byte `json:"content"`
}

type MessageChan chan Message

type Params struct {
	Broker           string
	Port             int
	Channel          MessageChan
	BatchSize        int
	MaxBatchSize     int
	Interval         time.Duration
	Topic            string
	ObsChannel       observability.Channel
	RetryInterval    time.Duration
	TestMessageTopic string
	LogLevel         log.LogLevel
}