You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2020/09/07 07:21:00 UTC

[jira] [Created] (FLINK-19149) Compacted Kafka Topic can be interpreted as Changelog Stream

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)