Imports github.com/go-kratos/kratos/v2/log github.com/go-kratos/kratos/v2/selector github.com/go-kratos/kratos/v2/transport github.com/segmentio/kafka-go github.com/segmentio/kafka-go/sasl/scram go.opentelemetry.io/otel/propagation go.opentelemetry.io/otel/trace Standard library imports context crypto/tls net/url strings sync user-job/pkg/broker user-job/pkg/broker/kafka user-rpc-rpc-api-user-rpc-job/pkg/broker
Go to main page