Hello, This is a discussion thread for https://cwiki.apache.org/confluence/display/KAFKA/KIP-939%3A+Support+Participation+in+2PC .
The KIP proposes extending Kafka transaction support (that already uses 2PC under the hood) to enable atomicity of dual writes to Kafka and an external database, and helps to fix a long standing Flink issue. An example of code that uses the dual write recipe with JDBC and should work for most SQL databases is here https://github.com/apache/kafka/pull/14231. The FLIP for the sister fix in Flink is here https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=255071710 -Artem
