why kafkaSink doesn't support transform
Open
- Dominant language
- Java
- Stars
- 4.1k
- Forks
- 1.7k
- PR merge metrics
- No merged PRs in 30d
Description
```java
@Override
public DataStreamSink createSink(DataStream dataSet) {
if (!useAbstractBaseColumn) {
throw new UnsupportedOperationException("kafka not support transform");
}
return createOutput(dataSet, null);
}
```
as code in `KafkaSinkFactory`
I need to transform data from binlog to kafka
Contributor guide
Assessment
This issue has not been assessed yet.