kafka

package

v0.0.0-...-0d0a0fb Latest Latest Go to latest Published: Jun 23, 2020 License: GPL-2.0 Imports: 2 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Messager struct {
	Writer *kafka.Writer
}

Messager interface for sending messages

func NewMessager(messagingURL, messagingTopic string) *Messager

NewMessager returns a kafka writer to send messages

func (m *Messager) Close()

Close - shutdown

func (m *Messager) Send(ctx context.Context, key string, value []byte) error

Send - pushes a new message to kafka