Imports
- github.com/confluentinc/confluent-kafka-go/kafka
- github.com/go-bamboo/pkg/log
- github.com/go-bamboo/pkg/queue
- github.com/go-bamboo/pkg/rescue
- github.com/go-bamboo/pkg/tracing
- github.com/go-kratos/kratos/v2/errors
- github.com/go-kratos/kratos/v2/metrics
- go.opentelemetry.io/otel
- go.opentelemetry.io/otel/attribute
- go.opentelemetry.io/otel/propagation
- go.opentelemetry.io/otel/trace
- google.golang.org/protobuf/reflect/protoreflect
- google.golang.org/protobuf/runtime/protoimpl
- google.golang.org/protobuf/types/known/anypb
- google.golang.org/protobuf/types/known/durationpb