Code

Add safe kafka connectors#68

Code

Merged

velo merged 3 commits intoDataSQRL:mainDataSQRL/flink-sql-runner:mainfrom

ferenc-csaky:safe-kafka-connectorsferenc-csaky/flink-jar-runner:safe-kafka-connectorsCopy head branch name to clipboard

Apr 22, 2025

Commits

Commits on Apr 22, 2025

• Add `kafka-safe` nad `upsert-kafka-safe` connector implementations

  ferenc-csaky

  committed
  1e93ed4

  Copy full SHA for 1e93ed4

• Split Flink-specific implementations to custom src base folders in `flexible-json-format`

  ferenc-csaky

  committed
  81fff7f

  Copy full SHA for 81fff7f

• Limit CI runs to Flink 1.19

  ferenc-csaky

  committed
  d3971ea

  Copy full SHA for d3971ea