Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewKafkaDMLSink ¶
func NewKafkaDMLSink( ctx context.Context, changefeedID model.ChangeFeedID, sinkURI *url.URL, replicaConfig *config.ReplicaConfig, errCh chan error, factoryCreator kafka.FactoryCreator, producerCreator dmlproducer.Factory, ) (_ *dmlSink, err error)
NewKafkaDMLSink will verify the config and create a KafkaSink.
func NewPulsarDMLSink ¶
func NewPulsarDMLSink( ctx context.Context, changefeedID model.ChangeFeedID, sinkURI *url.URL, replicaConfig *config.ReplicaConfig, errCh chan error, pulsarTopicManagerCreator manager.PulsarTopicManager, clientCreator pulsarConfig.FactoryCreator, producerCreator dmlproducer.PulsarFactory, ) (_ *dmlSink, err error)
NewPulsarDMLSink will verify the config and create a PulsarSink.
Types ¶
This section is empty.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.