pubsubx

Imports

• github.com/Shopify/sarama
• github.com/ThreeDotsLabs/watermill
• github.com/ThreeDotsLabs/watermill-kafka/v2/pkg/kafka
• github.com/ThreeDotsLabs/watermill/message
• github.com/ThreeDotsLabs/watermill/pubsub/gochannel
• github.com/sirupsen/logrus
• go.opentelemetry.io/otel/propagation
• go.opentelemetry.io/otel/trace

Imports in module “github.com/clinia/x”

• github.com/clinia/x/logrusx
• github.com/clinia/x/otelx/instrumentation/otelsaramax
• github.com/clinia/x/pubsubx/kafkax
• github.com/clinia/x/stringsx

Standard library imports

• bytes
• context
• embed
• fmt
• io
• sync
• time