kafka

type ClusterAdmin interface {
	ListTopics() (map[string]sarama.TopicDetail, error)
}

type Consumer interface {
	ConsumePartition(topic string, partition int32, offset int64) (sarama.PartitionConsumer, error)
	Partitions(topic string) ([]int32, error)
}

type Decoder interface {
	Decode(ctx context.Context, id uint32, message []byte) (string, error)
}

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