Details
-
Sub-task
-
Status: Closed
-
Major
-
Resolution: Abandoned
-
1.5.0
-
None
-
None
Description
Currently, the flink-connector-kafka module has a dependency on flink-table and flink-json. The reason seems to be that the module contains the KafkaJsonTableSource and KafkaJsonTableSink. Even though the flink-table and flink-json dependency are marked as optional, the flink-connector-kafka will still contain the table sources and sinks. I think this is not a clean design.
I would propose to move the table sources and sinks into a dedicated module which depends on flink-connector-kafka. That way we would better separate dependencies and could remove flink-table and flink-json from flink-connector-kafka.
Attachments
Issue Links
- is blocked by
-
FLINK-11015 Remove deprecated code for format-specific Kafka table connectors
- Closed
-
FLINK-11118 Refactor and unify rowtime timestamp extractor interface
- Closed