Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KafkaClient ¶
type KafkaClient struct {
// contains filtered or unexported fields
}
func NewKafkaClient ¶
func NewKafkaClient(config types.KafkaClientConfig) *KafkaClient
func (*KafkaClient) Consume ¶
func (client *KafkaClient) Consume(callback func(message []byte) error) (err error)
func (*KafkaClient) Produce ¶ added in v0.0.2
func (client *KafkaClient) Produce(message []byte) (err error)
func (*KafkaClient) Stop ¶ added in v0.0.10
func (client *KafkaClient) Stop() (err error)
func (*KafkaClient) TestConnection ¶ added in v0.0.5
func (client *KafkaClient) TestConnection() (err error)
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.