Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewKafkaInput ¶
Types ¶
type Consumer ¶
type Consumer struct {
// contains filtered or unexported fields
}
func (*Consumer) Cleanup ¶
func (consumer *Consumer) Cleanup(sarama.ConsumerGroupSession) error
Cleanup is run at the end of a session, once all ConsumeClaim goroutines have exited
func (*Consumer) ConsumeClaim ¶
func (consumer *Consumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
ConsumeClaim must start a consumer loop of ConsumerGroupClaim's Messages().
type KafkaConfig ¶
type KafkaInput ¶
type KafkaInput struct {
// contains filtered or unexported fields
}
func (*KafkaInput) Emit ¶
func (input *KafkaInput) Emit() map[string]interface{}
func (*KafkaInput) Run ¶
func (input *KafkaInput) Run()
func (*KafkaInput) Stop ¶
func (input *KafkaInput) Stop()
Click to show internal directories.
Click to hide internal directories.