kafka

Documentation

Index

• type Client
  • func NewClient(addrs []string, username, password string) (*Client, error)
  • func (c *Client) GetChannelStatus() (int, int)
  • func (c *Client) SendMessageAsync(msg *Message)
  • func (c *Client) SendMessageSync(msg *Message) error
  • func (c *Client) StartSendingMessage(sendGoroutineCount, channelSize int, logger *zap.Logger)
  • func (c *Client) StopSendingMessage()
• type Message

Types

type Client

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

func NewClient

func NewClient(addrs []string, username, password string) (*Client, error)

func (*Client) GetChannelStatus

func (c *Client) GetChannelStatus() (int, int)

func (*Client) SendMessageAsync

func (c *Client) SendMessageAsync(msg *Message)

func (*Client) SendMessageSync

func (c *Client) SendMessageSync(msg *Message) error

func (*Client) StartSendingMessage

func (c *Client) StartSendingMessage(sendGoroutineCount, channelSize int, logger *zap.Logger)

func (*Client) StopSendingMessage

func (c *Client) StopSendingMessage()

type Message

type Message struct {
	Topic string
	Value []byte
}