client

Documentation

Index

• type Client
  • func NewClient(brokers []string, mechanism sasl.Mechanism, tlsConfig *tls.Config) (*Client, error)
  • func (c *Client) CreateBrokerConn() (*kafka.Conn, error)
  • func (c *Client) CreateControllerConn() (*kafka.Conn, error)
  • func (c *Client) CreateTopicIfNotExist(lgr log.Logger, topic string, entries [][2]string) error
  • func (c *Client) ListTopics() ([]string, error)

Types

type Client

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

func NewClient

func NewClient(brokers []string, mechanism sasl.Mechanism, tlsConfig *tls.Config) (*Client, error)

func (*Client) CreateBrokerConn

func (c *Client) CreateBrokerConn() (*kafka.Conn, error)

func (*Client) CreateControllerConn

func (c *Client) CreateControllerConn() (*kafka.Conn, error)

func (*Client) CreateTopicIfNotExist

func (c *Client) CreateTopicIfNotExist(
	lgr log.Logger,
	topic string,
	entries [][2]string,
) error

func (*Client) ListTopics

func (c *Client) ListTopics() ([]string, error)