producer

Documentation

Index

• func CloseAsyncProducer(asyncProducer sarama.AsyncProducer) error
• func CloseSyncProducer(syncProducer sarama.SyncProducer) error
• func CreateNewASyncProducer(brokerList []string, kafkaConfiguration *sarama.Config) (sarama.AsyncProducer, error)
• func CreateNewClientConfiguration(producerConfig *configuration.KafkaProducerConfig) (*sarama.Config, error)
• func CreateNewProducerMessage(configProducer configuration.KafkaProducerConfig, messageKey string, ...) *sarama.ProducerMessage
• func CreateNewSyncProducer(brokerList []string, kafkaConfiguration *sarama.Config) (sarama.SyncProducer, error)
• func SendMessageToASyncProducerTopic(kProducer sarama.AsyncProducer, message *sarama.ProducerMessage, ...)

Functions

func CloseAsyncProducer

func CloseAsyncProducer(asyncProducer sarama.AsyncProducer) error

func CloseSyncProducer

func CloseSyncProducer(syncProducer sarama.SyncProducer) error

func CreateNewASyncProducer

func CreateNewASyncProducer(brokerList []string, kafkaConfiguration *sarama.Config) (sarama.AsyncProducer, error)

func CreateNewClientConfiguration

func CreateNewClientConfiguration(producerConfig *configuration.KafkaProducerConfig) (*sarama.Config, error)

func CreateNewProducerMessage

func CreateNewProducerMessage(configProducer configuration.KafkaProducerConfig, messageKey string, messageValue string) *sarama.ProducerMessage

func CreateNewSyncProducer

func CreateNewSyncProducer(brokerList []string, kafkaConfiguration *sarama.Config) (sarama.SyncProducer, error)

func SendMessageToASyncProducerTopic

func SendMessageToASyncProducerTopic(kProducer sarama.AsyncProducer, message *sarama.ProducerMessage, topicName string,
	wg *sync.WaitGroup, throttle chan int)