Versions in this module Expand all Collapse all v0 v0.4.0 Jun 2, 2022 Changes in this version + type Consumer struct + func NewConsumer(committerInterval time.Duration, bootstrapServer string, ...) (*Consumer, error) + func (c *Consumer) Register(registration *transport.BundleRegistration) + func (c *Consumer) Start() + func (c *Consumer) Stop() + type KafkaConsumerConfig struct + ConsumerID string + ConsumerTopic string + type Message struct + ID string + MsgType string + Payload []byte + Version string
Go to main page