kafka

Imports

• github.com/go-kratos/kratos/v2/log
• github.com/google/uuid
• github.com/segmentio/kafka-go
• github.com/segmentio/kafka-go/sasl
• github.com/segmentio/kafka-go/sasl/plain
• github.com/segmentio/kafka-go/sasl/scram
• go.opentelemetry.io/otel/attribute
• go.opentelemetry.io/otel/propagation
• go.opentelemetry.io/otel/semconv/v1.12.0
• go.opentelemetry.io/otel/trace

Standard library imports

• bytes
• context
• crypto/tls
• encoding/gob
• errors
• strconv
• sync
• time
• user-job/pkg/broker
• user-job/pkg/tracing
• user-rpc-rpc-api-user-rpc-job/pkg/broker