package
0.0.0-20230706040353-d5b0b989b1c9
Repository: https://github.com/tencentmusic/evhub.git
Documentation: pkg.go.dev
# Functions
New creates a Kafka connector.
TopicGroupOffsetKey returns the key of consumer group.
# Constants
CommitTimeout commit timeout.
KeyTopicGroupOffset is the key of the consumer group.
# Structs
ConsumerGroup is a consumer of Kafka.
Kafka is a type of connector.
Msg is the message of the consumer group.