Versions in this module Expand all Collapse all v0 v0.7.1 Jul 2, 2019 v0.7.0 Jun 25, 2019 Changes in this version + type Adapter struct + BootstrapServers string + ConsumerGroup string + Name string + Namespace string + Net AdapterNet + SinkURI string + Topics string + 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 struct + SASL AdapterSASL + TLS AdapterTLS + type AdapterSASL struct + Enable bool + Password string + User string + type AdapterTLS struct + CACert string + Cert string + Enable bool + Key string
Go to main page