kafka_connector

Documentation

Overview

Package kafka_connector provides a connector to Kafka

Index

• type Connector
  • func NewConnector(client kafka.Client) *Connector
  • func (c *Connector) Close() error
  • func (c *Connector) NewConsumer(topic, group string, batchSize int, fn type2.HandleMessage) error
  • func (c *Connector) Produce(ctx context.Context, msg *types.Message) error

Types

type Connector

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

Connector is a kafka connector

func NewConnector

func NewConnector(client kafka.Client) *Connector

NewConnector create a new kafka connector

func (*Connector) Close

func (c *Connector) Close() error

Close the connector

func (*Connector) NewConsumer

func (c *Connector) NewConsumer(topic, group string, batchSize int, fn type2.HandleMessage) error

NewConsumer consume Messages from the queue in real time

func (*Connector) Produce

func (c *Connector) Produce(ctx context.Context, msg *types.Message) error

Produce produce a Message to the queue in realtime