kafka

Imports

• github.com/Shopify/sarama
• github.com/pingcap/errors
• github.com/pingcap/failpoint
• github.com/pingcap/log
• github.com/pingcap/tiflow/cdc/model
• github.com/pingcap/tiflow/cdc/sink/codec
• github.com/pingcap/tiflow/pkg/config
• github.com/pingcap/tiflow/pkg/errors
• github.com/pingcap/tiflow/pkg/kafka
• github.com/pingcap/tiflow/pkg/notify
• github.com/pingcap/tiflow/pkg/security
• github.com/pingcap/tiflow/pkg/util
• github.com/prometheus/client_golang/prometheus
• github.com/rcrowley/go-metrics
• go.uber.org/zap

Standard library imports

• context
• fmt
• net/url
• regexp
• strconv
• strings
• sync
• sync/atomic
• time