pubsub

type KafkaPublisher interface {
	Publish(messages []*sarama.ProducerMessage) error
	PublishMetric(topic, measurement string, tags map[string]string, fields map[string]interface{}, tm time.Time) error
	Close() error
}

type KafkaSubscriber interface {
	Subscribe(topics []string, consumerGroup string, onMessage OnKafkaMessage) error
	Close()
}

type OnKafkaMessage func(message *sarama.ConsumerMessage)