Versions in this module Expand all Collapse all v0 v0.4.0 Jun 2, 2022 Changes in this version + const MaxMessageSizeLimit + type KafkaProducerConfig struct + MsgSizeLimitKB int + ProducerID string + ProducerTopic string + type Producer struct + func NewProducer(compressor compressor.Compressor, bootstrapServer string, ...) (*Producer, error) + func (p *Producer) SendAsync(destinationHubName string, id string, msgType string, version string, ...) + func (p *Producer) Start() + func (p *Producer) Stop()
Go to main page