Imports github.com/Shopify/sarama github.com/ThreeDotsLabs/watermill github.com/ThreeDotsLabs/watermill/message github.com/hashicorp/go-multierror github.com/pkg/errors go.opentelemetry.io/contrib/instrumentation/github.com/Shopify/sarama/otelsarama Standard library imports context fmt strings sync time