У вас есть несколько вариантов, подробно описанных в этом блоге, и этом разговоре .
tl; dr:
- CD «на основе запросов» C, запрос изменений в базе данных с помощью Kafka Connect JDB C Коннектор источника
- Компакт-диск «на основе журнала» C, используйте журнал повторов для записи каждого изменения в Kafka, используя GoldenGate / Qlik Attunity / et c et c et c
Существует также REST API , если вы хотите минимизировать занимаемое пространство, а затем вы просто передаете sh записи из вызова PL / SQL REST в Kafka. Возможно, подходит для небольших редких объемов, но в долгосрочной перспективе он будет негибким и хрупким.