kafka

Documentation

Index

• func NewConsumer(brokers []string, topic string, group string) *kaf.Reader
• func NewProducer(brokers []string) *kaf.Writer
• type Client
  • func NewKafkaClient(read bool, write bool, brokers []string, topic string, group string, ...) *Client
  • func (client *Client) Close()

Functions

func NewConsumer

func NewConsumer(brokers []string, topic string, group string) *kaf.Reader

NewConsumer creates a new kafka consumer.

func NewProducer

func NewProducer(brokers []string) *kaf.Writer

NewProducer creates a new kafka producer.

Types

type Client

type Client struct {
	Consumer *kaf.Reader
	Producer *kaf.Writer
}

Client struct.

func NewKafkaClient

func NewKafkaClient(read bool, write bool, brokers []string, topic string, group string, readOldest bool) *Client

NewKafkaClient creates a new KafkaClient struct.

func (*Client) Close

func (client *Client) Close()

Close closes active consumers/producers.