kafka

Documentation

Index

• Constants
• type KafkaProducerConfig
• type Producer
  • 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()

Constants

const (
	MaxMessageSizeLimit = 987 // to make sure that the message size is below 1 MB.

)

Types

type KafkaProducerConfig

type KafkaProducerConfig struct {
	ProducerID     string
	ProducerTopic  string
	MsgSizeLimitKB int
}

type Producer

type Producer struct {
	// contains filtered or unexported fields
}

Producer abstracts hub-of-hubs-kafka-transport kafka-producer's generic usage.

func NewProducer

func NewProducer(compressor compressor.Compressor, bootstrapServer string, producerConfig *KafkaProducerConfig, log logr.Logger) (*Producer, error)

NewProducer returns a new instance of Producer object.

func (*Producer) SendAsync

func (p *Producer) SendAsync(destinationHubName string, id string, msgType string, version string, payload []byte)

SendAsync sends a message to the sync service asynchronously.

func (*Producer) Start

func (p *Producer) Start()

Start starts kafka producer.

func (*Producer) Stop

func (p *Producer) Stop()

Stop stops the producer.