IBM ha annunciato watsonx.data integration per Apache Flink, una soluzione per creare e gestire pipeline streaming su Confluent Platform for Apache Flink.

Le pipeline possono essere definite attraverso un canvas drag-and-drop, authoring assistito da AI o Python SDK. Tutte le modalità producono un modello che viene tradotto in un job graph Flink nativo, con funzioni di anteprima e validazione.

La soluzione gestisce cambiamenti dello schema ed errori, permette la ripresa preservando lo stato e instrada i record falliti verso Apache Kafka. Include inoltre monitoraggio della qualità e delle anomalie. IBM dichiara che l’integrazione può essere provata gratuitamente.