kafkago

Documentation

Index

• func NewProducer(brokers string) *kafkago.Writer
• func NewReader(brokers string) *kafkago.Reader
• func Prepare(writer *kafkago.Writer, message []byte, numMessages int) func()
• func PrepareReader(reader *kafkago.Reader, numMessages int) func()

Functions

func NewProducer

func NewProducer(brokers string) *kafkago.Writer

NewProducer returns a new kafkago writer.

func NewReader

func NewReader(brokers string) *kafkago.Reader

NewReader returns a new kafkago writer.

func Prepare

func Prepare(writer *kafkago.Writer, message []byte, numMessages int) func()

Prepare returns a function that can be used during the benchmark as it only performs the sending of messages.

func PrepareReader

func PrepareReader(reader *kafkago.Reader, numMessages int) func()

PrepareReader returns a function that can be used during the benchmark as it only performs the consuming of messages.