Я работаю над POC со следующими целями:
a.Запишите данные из таблиц БД Oracle в разделы (скажем, PARENT, CHILD), используя соединитель источника JDBC Kafka Connect.[Достигнуто]
б.Преобразуйте эти темы в потоки Kafka (PARENT_TOPIC -> PARENT_STREAM и CHILD_TOPIC -> CHILD_STREAM) [ACHIEVED]
c.Выполните итерацию по PARENT_STREAM и получите соответствующие записи CHILD из CHILD_STREAM на основе столбцов соединения
d.Преобразуйте каждую запись PARENT и соответствующую запись (записи) CHILD и создайте POJO (родительский список).
e.Используйте описанный выше POJO для создания объектов JSON для дальнейшей обработки.
В настоящее время я застрял, пытаясь достичь точки (c) и далее - все примеры / демонстрации, похоже, работают над простыми преобразованиями (поиск количества).Похоже, что потоковые соединения / Windows не соответствуют моим требованиям.
Пожалуйста, предложите способы достижения вышеуказанной цели.Кроме того, это правильный подход для достижения конечной цели?