producer

Documentation

Index

• type Client
  • func NewClient() *Client
  • func (client *Client) Close() error
  • func (client *Client) Connect(brokers []string, config *sarama.Config) error
  • func (client *Client) Healthy() bool
  • func (client *Client) Publish(produce *commander.Message) error

Types

type Client

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

Client produces kafka messages

func NewClient

func NewClient() *Client

NewClient constructs a new producer client

func (*Client) Close

func (client *Client) Close() error

Close closes the Kafka client producer

func (*Client) Connect

func (client *Client) Connect(brokers []string, config *sarama.Config) error

Connect initializes and opens a new Sarama producer group.

func (*Client) Healthy

func (client *Client) Healthy() bool

Healthy checks the health of the Kafka client

func (*Client) Publish

func (client *Client) Publish(produce *commander.Message) error

Publish publishes the given message