The highest tagged major version is v2.

kafka

package

v0.1.0 Latest Latest Go to latest Published: Jul 29, 2019 License: Apache-2.0 Imports: 7 Imported by: 1

Details

This section is empty.

This section is empty.

This section is empty.

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

Stream implementation of Streamer interface for the Kafka driver

func MustNewStream(brokerList []string, topics []string, conf *sarama.Config) *Stream

func NewStream(brokerList []string, topics []string, conf *sarama.Config) (*Stream, error)

NewStream to the kafka with some brokers and topics for sending

func (s *Stream) Close() error

Close kafka producer

func (s *Stream) Send(messages ...interface{}) (err error)

Send messages to the KAFKA stream

type Subscriber struct {
	subscriber.Base
	// contains filtered or unexported fields
}

Subscriber for kafka

func NewSubscriber(brokers []string, group string, topics []string, configArgs ...*cluster.Config) (*Subscriber, error)

NewSubscriber connection to kafka "group" from list of topics

func (s *Subscriber) Close() (err error)

Close kafka consumer

func (s *Subscriber) Listen() (err error)

Listen kafka consumer

func (s *Subscriber) SetLogger(logger loggerInterface)

SetLogger interface