Konstantin Knauf created FLINK-19149:
----------------------------------------
Summary: Compacted Kafka Topic can be interpreted as Changelog
Stream
Key: FLINK-19149
URL: https://issues.apache.org/jira/browse/FLINK-19149
Project: Flink
Issue Type: Improvement
Components: Connectors / Kafka
Reporter: Konstantin Knauf
I would like to be able to interpret a compacted Kafka Topic as a upsert stream
in Apache Flink. Similarly, I would like to be able to write an upsert stream
to Kafka (into a compacted topic).
In both cases, the (possibly implicit) primary key of the Flink SQL Table would
need to correspond to the fields that make up the keys of the Kafka records.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
