consumer

type KafkaConsumer struct {
	Opts *Opts

	MySql             *mysql.MySqlDatabase
	MySqlOtelEnricher *otelmysql.MySqlEnricher

	Redis             *redis.RedisDatabase
	RedisOtelEnricher *otelredis.RedisEnricher
	// contains filtered or unexported fields
}

type OptFunc func(*Opts)

type Opts struct {
	ServiceName     string
	BrokerAddress   string
	BrokerTopic     string
	ConsumerGroupId string
}