Struct Source

pkg/acquisition/modules/kafka/source.go:10–15

)

type Source struct {
	metricsLevel metrics.AcquisitionMetricsLevel
	Config       Configuration
	logger       *logrus.Entry
	Reader       *kafka.Reader
}

func (s *Source) GetUuid() string {
	return s.Config.UniqueId