Versions in this module Expand all Collapse all v0 v0.0.2 Mar 23, 2020 v0.0.1 Mar 20, 2020 Changes in this version + type KafkaAsyncProducerStarter struct + KafkaAsyncProducerConfig *KafkaProducerConfig + func (k *KafkaAsyncProducerStarter) GetKafkaSendMsgChan() chan<- *sarama.ProducerMessage + func (k *KafkaAsyncProducerStarter) GetUserTopic() string + func (k *KafkaAsyncProducerStarter) OnStartApplication(ctx SpringBoot.ApplicationContext) + func (k *KafkaAsyncProducerStarter) OnStopApplication(ctx SpringBoot.ApplicationContext) + func (k *KafkaAsyncProducerStarter) SetErrorHandle(handle func(*sarama.ProducerError)) + type KafkaProducerConfig struct + AcksLevel string + Brokers []string + ChannelBufferSize int + ClientId string + ConnectTimeOut int + FlushFrequency uint32 + FlushMaxMessages uint32 + FlushMessages uint32 + IsSync bool + ReadTimeOut int + UserTopic string + Version string + WriteTimeOut int
Go to main page