kafka

package

v0.0.0-...-3bd2bae Latest Latest Go to latest Published: Jan 17, 2025 License: GPL-3.0 Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

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

NewConsumer creates a new kafka consumer.

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

NewProducer creates a new kafka producer.

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

Client struct.

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

NewKafkaClient creates a new KafkaClient struct.

func (client *Client) Close()

Close closes active consumers/producers.