consumer

Documentation

Index

• type Consumer
• type KafkaInput
  • func NewKafkaInput() *KafkaInput
  • func (i *KafkaInput) Cleanup(s sarama.ConsumerGroupSession) error
  • func (i *KafkaInput) ConsumeClaim(s sarama.ConsumerGroupSession, c sarama.ConsumerGroupClaim) error
  • func (i *KafkaInput) Push(m *sarama.ConsumerMessage)
  • func (i *KafkaInput) Read(data []byte) (int, error)
  • func (i *KafkaInput) Setup(s sarama.ConsumerGroupSession) error

Types

type Consumer

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

Consumer represents a Sarama consumer group consumer

type KafkaInput

type KafkaInput struct {
	sarama.ConsumerGroup
	// contains filtered or unexported fields
}

KafkaInput is used for recieving Kafka messages and transforming them into HTTP payloads.

func NewKafkaInput

func NewKafkaInput() *KafkaInput

NewKafkaInput creates instance of kafka consumer client.

func (*KafkaInput) Cleanup

func (i *KafkaInput) Cleanup(s sarama.ConsumerGroupSession) error

Cleanup is run at the end of a session, once all ConsumeClaim goroutines have exited

func (*KafkaInput) ConsumeClaim

func (i *KafkaInput) ConsumeClaim(s sarama.ConsumerGroupSession, c sarama.ConsumerGroupClaim) error

ConsumeClaim and stuff

func (*KafkaInput) Push

func (i *KafkaInput) Push(m *sarama.ConsumerMessage)

Push Messages

func (*KafkaInput) Read

func (i *KafkaInput) Read(data []byte) (int, error)

func (*KafkaInput) Setup

func (i *KafkaInput) Setup(s sarama.ConsumerGroupSession) error

Setup is run at the beginning of a new session, before ConsumeClaim