Documentation
¶
Index ¶
- type Client
- func (c *Client) Consume(ctx context.Context, timeout time.Duration, topic string) *sarama.ConsumerMessage
- func (c *Client) CreateTopic(name string, detail *sarama.TopicDetail, validateOnly bool)
- func (c *Client) Produce(topic string, value []byte, headers ...sarama.RecordHeader)
- func (c *Client) ProduceWithKey(topic string, key, value []byte, headers ...sarama.RecordHeader)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func (*Client) CreateTopic ¶
func (c *Client) CreateTopic(name string, detail *sarama.TopicDetail, validateOnly bool)
func (*Client) Produce ¶
func (c *Client) Produce(topic string, value []byte, headers ...sarama.RecordHeader)
func (*Client) ProduceWithKey ¶
func (c *Client) ProduceWithKey(topic string, key, value []byte, headers ...sarama.RecordHeader)
Source Files
Click to show internal directories.
Click to hide internal directories.