kafka

package

v0.0.0-...-771d451 Latest Latest Go to latest Published: Sep 23, 2020 License: MIT Imports: 10 Imported by: 0

Details

THIS IS AN EXPERIMENTAL DRIVER, PLEASE USE WITH CAUTION

This section is empty.

This section is empty.

This section is empty.

type Provider struct {
	Brokers  []string
	Balancer kafka.Balancer
	Reader   *kafka.Reader
	// contains filtered or unexported fields
}

Provider is a Kafka based pubsub provider

func (p *Provider) Publish(ctx context.Context, topic string, m *pubsub.Msg) error

Publish publishes a message to Kafka with a uuid as the key

func (p *Provider) Shutdown()

func (p *Provider) Subscribe(opts pubsub.HandlerOptions, h pubsub.MsgHandler)

Subscribe implements Subscribe