Как я могу сохранить результат потока в удаленную базу данных через REST или что-нибудь легко

Question

Я рассмотрел пример слияния потока потока кафки и обнаружения аномалий. В этом примере результат записывается в тему. Вместо этого Как я могу сохранить результат в удаленной базе данных через REST или что-то еще легко и быстро. Есть ли какая-либо структура в сливной платформе

Пример кода: // вместо кода отправляем удаленную базу данных

wordCounts.toStream (). To ("streams-wordcount-output", Produced.with (stringSerde, longSerde));

Answer 1

Обычный пример здесь - записать результаты вашей потоковой обработки в тему Kafka, а затем использовать Kafka Connect для потоковой передачи этой темы в любое место, куда вы хотите сохранить данные.Kafka Connect является частью Apache Kafka, и существует множество коннекторов, в том числе kafka-connect-jdbc для записи данных в (и из) базы данных.

Если вы пишете напрямую из своего потокового приложения в базу данных, которую вы без необходимости привязываетевместе ваша обработка и ваше хранение.Если база данных находится в автономном режиме или недоступна, ваша потоковая обработка должна справиться с этим.Вместо этого разделите их, и Kafka Connect обработает недоступную базу данных и т. Д.