kafkaClient

Documentation

Index

• func StartTopicReader(ctx context.Context, messageChannel chan string, errorChannel chan error, ...)
• type Writer
  • func GetWriter(kafkaURI string, topic string) Writer
  • func (writer Writer) SendMessage(message []byte) error

Functions

func StartTopicReader

func StartTopicReader(ctx context.Context, messageChannel chan string, errorChannel chan error, brokerURLs []string, inbound string, groupID string)

StartTopicReader Connects to kafka topic and reads new messages and writes them to the messageChannel any errors will be sent to errorChannel

Types

type Writer

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

func GetWriter

func GetWriter(kafkaURI string, topic string) Writer

GetWriter creates a kafka.Writer and wraps in a Writer stucture

func (Writer) SendMessage

func (writer Writer) SendMessage(message []byte) error

SendMessage constructs a kafkaMessage from message and writes to the topic the writer is attached to