Как УДАЛИТЬ запись из приемника JDBC с помощью Apache Flink?

Question

чтение некоторых данных JSON из Kafka на основе значения в JSON. Можно ли ВСТАВИТЬ или УДАЛИТЬ запись из приемника JDBC?

Answer 1

Вы можете написать свой собственный приемник через расширение RichSinkFunction. Создайте соединение с помощью JDBC в методе open() и выполните операторы CRUD в методе invoke().