kafka

package

v0.0.0-...-de1c451 Latest Latest Go to latest Published: Apr 17, 2022 License: MIT 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 struct {
	// contains filtered or unexported fields
}

Consumer coordinates the consuming of the queue

func NewConsumer(cc ConsumerConfig) *Consumer

NewConsumer creates a new consumer

func (c *Consumer) Close()

Close closes the reader

func (c *Consumer) Consume(ctx context.Context)

Consume Mass Quantities

func (c *Consumer) MsgChan() <-chan *pb.LeadpipeEvent

MsgChan returns a message channel for consuming

type ConsumerConfig struct {
	ConsumerGroupID string
	Brokers         []string
	Topic           string
	MessageChan     chan *pb.LeadpipeEvent
}

ConsumerConfig configures a Consumer

type Message struct {
	VisitorID string
	Payload   string
}

Message models a key/value message

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

Producer is a thin wrapper around a Sarama producer. It hides the Sarama API

func NewProducer(broker string, topic string) *Producer

NewProducer creates a new producer given a list of broker addresses

func (p *Producer) Close()

Close closes the writer

func (p *Producer) Send(ctx context.Context, evt *pb.LeadpipeEvent)

Send wraps the sarama producer SendMessage