Go to main page
Imports
- github.com/pingcap/errors
- github.com/pingcap/log
- github.com/pingcap/tidb/br/pkg/utils
- github.com/pingcap/tiflow/cdc/model
- github.com/pingcap/tiflow/cdc/sink/ddlsink/mq/ddlproducer
- github.com/pingcap/tiflow/pkg/errors
- github.com/pingcap/tiflow/pkg/sink
- github.com/pingcap/tiflow/pkg/sink/codec/common
- github.com/pingcap/tiflow/pkg/sink/kafka
- go.uber.org/atomic
- go.uber.org/zap
- golang.org/x/sync/errgroup
Imports in module “github.com/pingcap/ticdc”
- github.com/pingcap/ticdc/downstreamadapter/sink/helper
- github.com/pingcap/ticdc/downstreamadapter/sink/helper/eventrouter
- github.com/pingcap/ticdc/downstreamadapter/sink/helper/topicmanager
- github.com/pingcap/ticdc/downstreamadapter/worker/producer
- github.com/pingcap/ticdc/pkg/common
- github.com/pingcap/ticdc/pkg/common/columnselector
- github.com/pingcap/ticdc/pkg/common/event
- github.com/pingcap/ticdc/pkg/config
- github.com/pingcap/ticdc/pkg/metrics
- github.com/pingcap/ticdc/pkg/sink/codec
- github.com/pingcap/ticdc/pkg/sink/codec/encoder
- github.com/pingcap/ticdc/pkg/sink/kafka
- github.com/pingcap/ticdc/pkg/sink/kafka/v2
- github.com/pingcap/ticdc/pkg/sink/mysql
- github.com/pingcap/ticdc/pkg/sink/util