kafka

package

v0.0.0-...-4e705d1 Latest Latest Go to latest Published: Mar 21, 2022 License: Apache-2.0 Imports: 5 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

type Consumer interface {
	Listen(topic string, received chan []byte)
}

Consumer defines the consumer operations

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

Messager implements kafka message functionality

func NewMessager() *Messager

NewMessager will instantiate an instance using the producer provided

func (m *Messager) Listen(topic string, received chan []byte, signals chan bool)

Listen will listen indefinitely to the kafka bus for messages on a specific topic

func (m *Messager) Relay(inTopic, outTopic string, stop chan os.Signal) error

Relay will start listening for messages, transforming, and sending onwards

func (m *Messager) SendMessage(topic, mKey string, mValue []byte) error

SendMessage can send a message to the

func (m *Messager) WithConsumer(c sarama.Consumer) *Messager

WithConsumer will set the consumer instance on the messager

func (m *Messager) WithProducer(p sarama.SyncProducer) *Messager

WithProducer will set the producer instance on the messager

func (m *Messager) WithRelayTransform(rt RelayTransform) *Messager

WithRelayTransform will set the relay transform func instance on the messager

type Producer interface {
	SendMessage(topic, msg string, value []byte) error
}

Producer defines the producer operations

type RelayTransform func(msg []byte) ([]byte, error)

RelayTransform aliases the function for transforming relayed messages