kafka

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/tx7do/kratos-transport/broker
• github.com/tx7do/kratos-transport/broker/kafka
• github.com/tx7do/kratos-transport/keepalive
• github.com/tx7do/kratos-transport/transport
• go.opentelemetry.io/otel/propagation
• go.opentelemetry.io/otel/trace

Standard library imports

• context
• crypto/tls
• fmt
• net/url
• sync
• sync/atomic