kafka

Oct 25, 2023

Changes in this version

type Adapter

+ func (a *Adapter) ConsumerMessageToCloudEvent(ctx context.Context, cm *sarama.ConsumerMessage) (*cloudevents.Event, error)

May 18, 2021

Changes in this version

type Adapter

+ func (a *Adapter) Cleanup(sess sarama.ConsumerGroupSession)

+ func (a *Adapter) HandleServiceMessage(ctx context.Context, message ctrl.ServiceMessage)

+ func (a *Adapter) Setup(sess sarama.ConsumerGroupSession)

type AdapterConfig

+ DisableControlServer bool

Feb 23, 2021

Changes in this version

type Adapter

+ func (a *Adapter) SetRateLimits(r rate.Limit, b int)

+ type AdapterConfig struct

+ ConsumerGroup string

+ KeyType string

+ Name string

+ Topics []string

Apr 20, 2021

Changes in this version

type Adapter

+ func (a *Adapter) GetConsumerGroup() string

+ func (a *Adapter) SetReady(int32, bool)

Nov 10, 2020

Changes in this version

+ func NewAdapter(ctx context.Context, processed adapter.EnvConfigAccessor, ...) adapter.MessageAdapter

+ func NewEnvConfig() adapter.EnvConfigAccessor

+ type Adapter struct

+ func (a *Adapter) ConsumerMessageToHttpRequest(ctx context.Context, span *trace.Span, cm *sarama.ConsumerMessage, ...) error

+ func (a *Adapter) Handle(ctx context.Context, msg *sarama.ConsumerMessage) (bool, error)

+ func (a *Adapter) Start(ctx context.Context) error