Go to main page
Imports
- github.com/confluentinc/confluent-kafka-go/v2/kafka
- github.com/confluentinc/confluent-kafka-go/v2/schemaregistry
- github.com/confluentinc/confluent-kafka-go/v2/schemaregistry/serde
- github.com/confluentinc/confluent-kafka-go/v2/schemaregistry/serde/avrov2
- github.com/confluentinc/confluent-kafka-go/v2/schemaregistry/serde/jsonschema
- github.com/confluentinc/confluent-kafka-go/v2/schemaregistry/serde/protobuf
- github.com/google/uuid
- github.com/hamba/avro/v2
- github.com/sony/gobreaker
- github.com/zillow/zfmt
- go.opentelemetry.io/otel/attribute
- go.opentelemetry.io/otel/codes
- go.opentelemetry.io/otel/propagation
- go.opentelemetry.io/otel/semconv/v1.25.0
- go.opentelemetry.io/otel/trace
- golang.org/x/sync/errgroup