KafkaDataSinkFactory (flink-cdc-parent 3.8-SNAPSHOT API)

java.lang.Object
- org.apache.flink.cdc.connectors.kafka.sink.KafkaDataSinkFactory

All Implemented Interfaces:

DataSinkFactory, Factory
```
public class KafkaDataSinkFactory
extends Object
implements DataSinkFactory
```
A dummy DataSinkFactory to create KafkaDataSink.

Nested Class Summary
- Nested classes/interfaces inherited from interface org.apache.flink.cdc.common.factories.Factory
  Factory.Context

Field Summary

Fields
Modifier and Type Field Description

static String IDENTIFIER

Constructor Summary

Constructors
Constructor Description

KafkaDataSinkFactory()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`DataSink`	`createDataSink(Factory.Context context)`	Creates a `DataSink` instance.
`String`	`identifier()`	Returns a unique identifier among same factory interfaces.
`Set<ConfigOption<?>>`	`optionalOptions()`	Returns a set of `ConfigOption` that an implementation of this factory consumes in addition to `Factory.requiredOptions()`.
`Set<ConfigOption<?>>`	`requiredOptions()`	Returns a set of `ConfigOption` that an implementation of this factory requires in addition to `Factory.optionalOptions()`.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - IDENTIFIER
```
public static final String IDENTIFIER
```
    See Also:
    
    Constant Field Values
- Constructor Detail
  - KafkaDataSinkFactory
```
public KafkaDataSinkFactory()
```
- Method Detail
  - createDataSink
```
public DataSink createDataSink(Factory.Context context)
```
    Description copied from interface: DataSinkFactory
    
    Creates a DataSink instance.
    
    Specified by:
    
    createDataSink in interface DataSinkFactory
  - identifier
```
public String identifier()
```
    Description copied from interface: Factory
    
    Returns a unique identifier among same factory interfaces.
    
    Specified by:
    
    identifier in interface Factory
  - requiredOptions
```
public Set<ConfigOption<?>> requiredOptions()
```
    Description copied from interface: Factory
    
    Returns a set of ConfigOption that an implementation of this factory requires in addition to Factory.optionalOptions().
    
    Specified by:
    
    requiredOptions in interface Factory
  - optionalOptions
```
public Set<ConfigOption<?>> optionalOptions()
```
    Description copied from interface: Factory
    
    Returns a set of ConfigOption that an implementation of this factory consumes in addition to Factory.requiredOptions().
    
    Specified by:
    
    optionalOptions in interface Factory