kafka

type Brokers map[int64]int64

type Config map[string]string

type DefaultKafkaClient struct{}

type KafkaClient interface {
	CreateTopic(uri string, topic Topic) error
	CreatePartitions(ctx context.Context, uri string, topic Topic, numberOfPartitions int64) error
	UpdateTopicConfiguration(ctx context.Context, uri string, topic Topic) error
	GetTopic(uri string, name string) (*Topic, error)
}

type Topic struct {
	Name              string
	Partitions        int64
	ReplicationFactor int64
	Brokers           Brokers
	Config            Config
}