LogRequestMiddleware assumes there is a zerolog.Logger in the context.

NewAuthenticatedConsumer takes a *github.com/confluentinc/confluent-kafka-go/kafka.ConfigMap, adds the needed configuration for OAuth 2 and returns a new kafka consumer.

TODO returns a error channel for errors, the channel must be drained, otherwise it may lead to a memory leak.

timeout milliseconds.

TrackingIDMiddleware assumes there is a zerolog.Logger in the context.

Now provides the current time, defaults to time.Now.