kafka

Documentation

Index

• type Producer
  • func NewProducer(compressor compressors.Compressor, log logr.Logger) (*Producer, error)
  • func (p *Producer) SendAsync(msg *transport.Message)
  • func (p *Producer) Start()
  • func (p *Producer) Stop()
  • func (p *Producer) Subscribe(messageID string, callbacks map[transport.EventType]transport.EventCallback)
  • func (p *Producer) SupportsDeltaBundles() bool

Types

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 compressors.Compressor, log logr.Logger) (*Producer, error)

NewProducer returns a new instance of Producer object.

func (*Producer) SendAsync

func (p *Producer) SendAsync(msg *transport.Message)

SendAsync sends a message to the sync service asynchronously.

func (*Producer) Start

func (p *Producer) Start()

Start starts the kafka.

func (*Producer) Stop

func (p *Producer) Stop()

Stop stops the producer.

func (*Producer) Subscribe

func (p *Producer) Subscribe(messageID string, callbacks map[transport.EventType]transport.EventCallback)

Subscribe adds a callback to be delegated when a given event occurs for a message with the given ID.

func (*Producer) SupportsDeltaBundles

func (p *Producer) SupportsDeltaBundles() bool

SupportsDeltaBundles returns true. kafka does support delta bundles.