Documentation
¶
Index ¶
- func GetKafkaProducerConfig(config *sarama.Config) *sarama.Config
- func InitKafkaProducerAsyncClient(config *sarama.Config, kafkaConfig kafkaconfig.KafkaConfig) (sarama.AsyncProducer, error)
- func InitKafkaProducerClient(config *sarama.Config, kafkaConfig kafkaconfig.KafkaConfig) (sarama.SyncProducer, error)
- type Producer
- type ProducerAsync
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetKafkaProducerConfig ¶
GetKafkaProducerConfig 获取生产者Config配置
func InitKafkaProducerAsyncClient ¶
func InitKafkaProducerAsyncClient(config *sarama.Config, kafkaConfig kafkaconfig.KafkaConfig) (sarama.AsyncProducer, error)
InitKafkaProducerAsyncClient 初始化客户端
func InitKafkaProducerClient ¶
func InitKafkaProducerClient(config *sarama.Config, kafkaConfig kafkaconfig.KafkaConfig) (sarama.SyncProducer, error)
InitKafkaProducerClient 初始化客户端
Types ¶
type Producer ¶
type Producer struct {
// contains filtered or unexported fields
}
func NewProducer ¶
func NewProducer(config *sarama.Config, kafkaConfig kafkaconfig.KafkaConfig) *Producer
NewProducer 创建实例
type ProducerAsync ¶
type ProducerAsync struct {
// contains filtered or unexported fields
}
func NewProducerAsync ¶
func NewProducerAsync(config *sarama.Config, kafkaConfig kafkaconfig.KafkaConfig) *ProducerAsync
func (*ProducerAsync) Close ¶
func (m *ProducerAsync) Close()
func (*ProducerAsync) ProducerSendMsgAsync ¶
func (m *ProducerAsync) ProducerSendMsgAsync(topic string, value interface{}) error
Source Files
Click to show internal directories.
Click to hide internal directories.