Documentation
¶
Index ¶
- type Adapter
- func (a *Adapter) Cleanup(_ sarama.ConsumerGroupSession) error
- func (a *Adapter) ConsumeClaim(sess sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
- func (a *Adapter) Setup(_ sarama.ConsumerGroupSession) error
- func (a *Adapter) Start(ctx context.Context, stopCh <-chan struct{}) error
- type AdapterNet
- type AdapterSASL
- type AdapterTLS
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Adapter ¶
type Adapter struct { BootstrapServers string Topics string ConsumerGroup string Net AdapterNet SinkURI string Name string Namespace string // contains filtered or unexported fields }
func (*Adapter) Cleanup ¶
func (a *Adapter) Cleanup(_ sarama.ConsumerGroupSession) error
func (*Adapter) ConsumeClaim ¶
func (a *Adapter) ConsumeClaim(sess sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
func (*Adapter) Setup ¶
func (a *Adapter) Setup(_ sarama.ConsumerGroupSession) error
ConsumerGroupHandler functions to define message consume and related logic.
type AdapterNet ¶
type AdapterNet struct { SASL AdapterSASL TLS AdapterTLS }
Click to show internal directories.
Click to hide internal directories.