Versions in this module Expand all Collapse all v0 v0.1.0 Jan 19, 2024 Changes in this version + const ExpiredInterval + const HeartbeatInterval + const HeartbeatTopic + const LogConsumerGroup + var KafkaMsgPool = sync.Pool + func NewProvider(logger log.Logger) log.Subscriber + type KafkaMsg struct + Data string + Topic string + type Subscriber interface + Init func(urls string, logdir string) + Run func() + func NewSubscriber() Subscriber
Go to main page