builder

Documentation

Index

• type MessageBuilder
  • func NewMessageBuilder(key string, topic *string, partitionID int32, headers []kafka.Header, ...) *MessageBuilder
  • func (builder *MessageBuilder) Build() *kafka.Message
  • func (builder *MessageBuilder) Header(header kafka.Header) *MessageBuilder

Types

type MessageBuilder

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

MessageBuilder uses the builder patten to construct a kafka message.

func NewMessageBuilder

func NewMessageBuilder(key string, topic *string, partitionID int32, headers []kafka.Header,
	payload []byte) *MessageBuilder

NewMessageBuilder creates a new instance of MessageBuilder.

func (*MessageBuilder) Build

func (builder *MessageBuilder) Build() *kafka.Message

Build returns the internal kafka message.

func (*MessageBuilder) Header

func (builder *MessageBuilder) Header(header kafka.Header) *MessageBuilder

Header adds a header to the message headers.