kafka

Documentation

Index

• func Initialize(brokers []string)
• func Shutdown()
• type ConsumerState
• type Stream
  • func (s *Stream) Close()
  • func (s *Stream) Messages() <-chan []byte
• type Subscriber
  • func (s Subscriber) Subscribe(consumerName, topic string) consumer.Streamer

Functions

func Initialize

func Initialize(brokers []string)

Initialize sets up the kafka package.

func Shutdown

func Shutdown()

Shutdown shuts down the kafka package.

Types

type ConsumerState

type ConsumerState struct {
	Partition int32 `json:"partition"`
	Offset    int64 `json:"offset"`
}

ConsumerState contains data that is required to create a Kafka consumer.

type Stream

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

Stream is an implementation of shezmu.Stremer for Kafka messaging queue.

func (*Stream) Close

func (s *Stream) Close()

Close stops Kafka partition consumer.

func (*Stream) Messages

func (s *Stream) Messages() <-chan []byte

Messages returns a channel that stream messages.

type Subscriber

type Subscriber struct{}

Subscriber is a dummy structure that implements shezmu.Subscriber interface.

func (Subscriber) Subscribe

func (s Subscriber) Subscribe(consumerName, topic string) consumer.Streamer

Subscribe creates a consumer.Streamer implementation for Kafka messaging queue.