Go to main page
Imports
- github.com/twmb/franz-go/pkg/kgo
- github.com/twmb/franz-go/pkg/sasl
- go.opentelemetry.io/otel/trace
- github.com/twmb/franz-go/pkg/sr
- github.com/LerianStudio/lib-observability/v2/assert
- github.com/LerianStudio/lib-observability/v2/log
- github.com/LerianStudio/lib-observability/v2/metrics
- github.com/LerianStudio/lib-commons/v6/commons
- github.com/LerianStudio/lib-commons/v6/commons/circuitbreaker
- github.com/LerianStudio/lib-commons/v6/commons/outbox
Imports in module “github.com/LerianStudio/lib-streaming/v3”
- github.com/LerianStudio/lib-streaming/v3/internal/cloudevents
- github.com/LerianStudio/lib-streaming/v3/internal/config
- github.com/LerianStudio/lib-streaming/v3/internal/consumer
- github.com/LerianStudio/lib-streaming/v3/internal/contract
- github.com/LerianStudio/lib-streaming/v3/internal/emitter
- github.com/LerianStudio/lib-streaming/v3/internal/kafkasec
- github.com/LerianStudio/lib-streaming/v3/internal/manifest
- github.com/LerianStudio/lib-streaming/v3/internal/producer
- github.com/LerianStudio/lib-streaming/v3/internal/transport
- github.com/LerianStudio/lib-streaming/v3/internal/transport/eventbridge
- github.com/LerianStudio/lib-streaming/v3/internal/transport/rabbitmq
- github.com/LerianStudio/lib-streaming/v3/internal/transport/sqs