kafka

package
v0.4.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 2, 2022 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Consumer 

type Consumer struct {
	// contains filtered or unexported fields
}

Consumer abstracts hub-of-hubs-kafka-transport kafka-consumer's generic usage.

func NewConsumer 

func NewConsumer(committerInterval time.Duration, bootstrapServer string, consumerConfig *KafkaConsumerConfig, conflationManager *conflator.ConflationManager, statistics *statistics.Statistics,
	log logr.Logger,
) (*Consumer, error)

NewConsumer creates a new instance of Consumer.

func (*Consumer) Register 

func (c *Consumer) Register(registration *transport.BundleRegistration)

Register function registers a msgID to the bundle updates channel.

func (*Consumer) Start 

func (c *Consumer) Start()

Start function starts the consumer.

func (*Consumer) Stop 

func (c *Consumer) Stop()

Stop stops the consumer.

type KafkaConsumerConfig 

type KafkaConsumerConfig struct {
	ConsumerID    string
	ConsumerTopic string
}

type Message 

type Message struct {
	ID      string `json:"id"`
	MsgType string `json:"msgType"`
	Version string `json:"version"`
	Payload []byte `json:"payload"`
}

Message abstracts a message object to be used by different transport components.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.