messaging

type Client interface {
	NewConsumer(topicName, consumerName string, concurrency int) (kafka.Consumer, error)
	NewProducer(topicName string) (Producer, error)
}

type ClusterConfig struct {
	Brokers []string `yaml:"brokers"`
}

type KafkaConfig struct {
	Clusters map[string]ClusterConfig `yaml:"clusters"`
	Topics   map[string]TopicConfig   `yaml:"topics"`
}

type Producer interface {
	Publish(msg *replicator.ReplicationTask) error
	PublishBatch(msgs []*replicator.ReplicationTask) error
	Close() error
}

type TopicConfig struct {
	Cluster string `yaml:"cluster"`
}