listener

type Config struct {
	// Kafka version.
	Version string

	// Supported values: earliest, latest.
	AutoOffsetReset string

	BootstrapServers []string

	// Supported values: range, sticky, round-robin.
	PartitionAssignmentStrategy string
}

type KafkaContainer interface {
	Run(ctx context.Context) error
}

type KafkaListener interface {
	Id() string

	GroupId() string

	// Supported value: manual.
	AckMode() string

	Topics() []string

	OnEventFunc() func(record *sarama.ConsumerMessage) error

	// Required if AckMode equals to "manual".
	OnEventAckFunc() func(record *sarama.ConsumerMessage, session sarama.ConsumerGroupSession)
}