Интеграция Kafka с базой данных Ingres

Question

Я пытаюсь интегрировать базу данных Ingres с Kafka.Что я ищу, так это, как только запись будет вставлена ​​/ обновлена ​​/ удалена в базе данных Ingres, она должна опубликовать эту запись в теме Кафки.Есть ли такой продукт / структура, которая может достичь этого?

Существует некоторый соединитель с именем "Kafka Ingressnector", доступный в https://developer.adroitlogic.com/connectors/docs/17.07/kafka/kafka_ingress_connector.html Но, похоже, это не для базы данных Ingres.Обратите внимание на разницу в правописании.Имя базы данных - Ingres, тогда как на этом сайте указан соединитель Ingress.Даже если я игнорирую разницу в правописании, веб-страница ничего не говорит о базе данных Ingres.Кажется, что имя «Kafka Ingress Connector» дано для какой-то другой цели и на самом деле не предназначено для базы данных Ingres.

Я ожидаю интеграции в реальном времени между базой данных Ingres и Kafka.Если кто-то знает об этом, пожалуйста, дайте мне знать.Кроме того, если кто-то из adroitlogic может подтвердить наличие разъема Kafka Ingress, это было бы здорово.Спасибо!

Answer 1

Я не знаю ни одного готового фреймворка для этого, но это тоже не сложно. Традиционный архитектурный ответ на эти потребности - создание правила + процедуры, которая публикует изменения в очереди, реализованные в виде своей собственной таблицы, и вызывает событие. Затем вы создаете простое приложение на языке C (или любое другое), которое прослушивает событие, извлекает записи из очереди (таблицы) и публикует приложение-потребитель, в данном случае Kafka.

(Ingress - совершенно другая вещь, не связанная с продуктом Ingres)

Answer 2

Я не знаю ни одного разъема с открытым исходным кодом. HVR предлагает интеграцию данных в реальном времени для Ingres и Kafka, но я предполагаю, что вам необходимо приобрести лицензию для ее использования.