kafka

Imports

• github.com/IBM/sarama
• github.com/ThreeDotsLabs/watermill
• github.com/ThreeDotsLabs/watermill-kafka/v3/pkg/kafka
• github.com/ThreeDotsLabs/watermill/message
• github.com/cloudevents/sdk-go/v2/event
• github.com/confluentinc/confluent-kafka-go/v2/kafka
• go.opentelemetry.io/otel/metric

Imports in module “github.com/openmeterio/openmeter”

• github.com/openmeterio/openmeter/config
• github.com/openmeterio/openmeter/openmeter/watermill/driver/kafka/metrics
• github.com/openmeterio/openmeter/pkg/slicesx

Standard library imports

• context
• crypto/tls
• errors
• fmt
• log/slog
• strconv
• time