kafkakit

type KafkaConsumer struct {
	sarama.ConsumerGroup
	// contains filtered or unexported fields
}

type KafkaConsumerConfig struct {
	Addrs []string `long:"addrs" env:"ADDRS" env-delim:"," description:"the addresses of Kafka servers" required:"true"`
	Topic string   `long:"topic" env:"TOPIC" description:"the topic for the Kafka consumer group to consume" required:"true"`
	Group string   `long:"group" env:"GROUP" description:"the ID of the Kafka consumer group" required:"true"`
}

type KafkaProducer struct {
	sarama.SyncProducer
	// contains filtered or unexported fields
}

type KafkaProducerConfig struct {
	Addrs        []string `long:"addrs" env:"ADDRS" env-delim:"," description:"the addresses of Kafka servers" required:"true"`
	Topic        string   `long:"topic" env:"TOPIC" description:"the topic for the Kafka producer to send" required:"true"`
	RequiredAcks int16    `` /* 168-byte string literal not displayed */
}

type Producer interface {
	SendMessages(msgs []*ProducerMessage) error
}

type ProducerMessage struct {
	Key   []byte
	Value []byte
}