Kafka source optimization

[wey-gu]

If we wire upstream CDC sources to Kafka, we could have streaming data with different schema, and change mode(delete, insert, update).

We may be improving exchange Kafka on:

• configuration could map data to multiple edge types?

I could relate to the limitation now it seems it's already doable from the conf structure. @salahaz could you please help provide more context?

• Insert/update/delete mode could be handled automatically?

@salahaz could you help provide more ideas on this pain point?

[Nicole00]

the requirement looks like more suitable for flink connector, which is already supported.