Apache Кафка для существующего запроса на получение с Oracle БД - PullRequest
0 голосов
/ 11 марта 2020

Я пытаюсь узнать о потоковых сервисах и чтении kafka документов:

https://kafka.apache.org/quickstart

https://kafka.apache.org/24/documentation/streams/quickstart

Чтобы привести простой пример, я пытаюсь реорганизовать запрос GET веб-служб Spring, который принимает параметр идентификатора и возвращает список атрибутов, связанных с этим идентификатором. Бэкэнд БД: Oracle.

Каков подход для загрузки одной таблицы БД Oracle, которую может обслуживать Kafka? Приведенные выше документы не содержат информации для этого. Нужно ли реплицировать базу данных Oracle в базу данных No Sql, такую ​​как MongoDB? ( Почему нам требуется Apache Кафка без SQL баз данных? )

1 Ответ

1 голос
/ 11 марта 2020

Kafka - это платформа для потоковой передачи событий. Это не база данных. Вместо того, чтобы думать о «загрузке одной таблицы Oracle БД, которую может обслуживать Kafka», вам нужно подумать о том, какие события, которые вы ищете, будут запускать обработку?

Change Data Capture (CD C) такие продукты, как Oracle Golden Gate (есть и другие продукты), будут обнаруживать изменения в строках и отправлять сообщения в Kafka каждый раз, когда изменяется ряд.

В качестве альтернативы вы можете настроить Kafka JDB C Source Connector для выполнения запроса и извлечения данных в Kafka.

...