kafka

Imports

• github.com/Shopify/sarama
• github.com/pkg/errors
• github.com/prometheus/client_golang/prometheus
• github.com/rcrowley/go-metrics
• github.com/xdg/scram

Imports in module “github.com/TencentBlueKing/bkmonitor-datalink/pkg/transfer”

• github.com/TencentBlueKing/bkmonitor-datalink/pkg/transfer/config
• github.com/TencentBlueKing/bkmonitor-datalink/pkg/transfer/define
• github.com/TencentBlueKing/bkmonitor-datalink/pkg/transfer/eventbus
• github.com/TencentBlueKing/bkmonitor-datalink/pkg/transfer/logging
• github.com/TencentBlueKing/bkmonitor-datalink/pkg/transfer/monitor
• github.com/TencentBlueKing/bkmonitor-datalink/pkg/transfer/pipeline
• github.com/TencentBlueKing/bkmonitor-datalink/pkg/transfer/utils

Standard library imports

• context
• crypto/sha256
• crypto/sha512
• crypto/tls
• crypto/x509
• encoding/base64
• fmt
• strconv
• strings
• sync
• sync/atomic
• time