Versions in this module Expand all Collapse all v0 v0.1.0 Mar 16, 2023 Changes in this version + type KafkaInput struct + func NewKafkaInput() *KafkaInput + func (in *KafkaInput) Ack(msg *core.Message, err error) + func (in *KafkaInput) Configure(config core.StringMap) (err error) + func (in *KafkaInput) GetState() ([]byte, bool) + func (in *KafkaInput) SetState(state []byte) error + func (in *KafkaInput) Start() (err error) + func (in *KafkaInput) Stop() + type KafkaInputConfig struct + ConsumerGroup string + FromBeginning bool + ServerAddresses []string + Topics []string + type KafkaPosition struct + Offset int64 + Partition int32 + Timestamp int64 + Topic string + type MessageConsumer struct + func (mc *MessageConsumer) Cleanup(sarama.ConsumerGroupSession) error + func (mc *MessageConsumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) (err error) + func (mc *MessageConsumer) Setup(sarama.ConsumerGroupSession) error
Go to main page