Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KafkaConsumer ¶
type KafkaConsumer interface {
Start()
Stop()
}
func NewConsumer ¶
func NewConsumer(config config.KafkaConfig) (Consumer KafkaConsumer, err error)
type KafkaProducer ¶
type KafkaProducer interface {
Start()
Stop()
SendMessage(*sarama.ProducerMessage) error
}
KafkaProducer interface
func NewProducer ¶
func NewProducer(config config.KafkaConfig) (Producer KafkaProducer, err error)
NewProducer return a new Synchronous KafkaProducer for one kafkaCluster. We will set up here the Producer req/s and kafka monitoring topics. This producer is the most restricted producer available, because it is synchronous and wait for all ACKs
Source Files
Click to show internal directories.
Click to hide internal directories.