Versions in this module Expand all Collapse all v1 v1.3.0 Nov 16, 2021 v1.0.1 Nov 15, 2021 Changes in this version + func GetConfig() *cluster.Config + type FinderKafkaConsumer struct + Config *cluster.Config + Consumer *cluster.Consumer + func NewFinderKafkaConsumer(brokers []string, groupId string, topics []string) (*FinderKafkaConsumer, error) + func (this *FinderKafkaConsumer) Consume(errorFunc func(error), notificationsFunc func(*cluster.Notification), ...)