Apache Kafka соединяется со Springboot - PullRequest
0 голосов
/ 30 декабря 2018

Я пытаюсь найти примеры связи Кафки с Springboot.Похоже, что нет интеграции с весенней загрузкой для kafka connect.Может ли кто-нибудь указать мне правильное направление, чтобы я мог слушать изменения в mysql db?

1 Ответ

0 голосов
/ 30 декабря 2018

Kafka Connect на самом деле не нуждается в Spring Boot, потому что вам нечего его кодировать, и он действительно лучше всего работает, когда работает в режиме distrbited, как кластер, а не встроен в другие приложения.Я полагаю, если вы захотите это сделать, то вы можете скопировать соответствующие части исходного кода , но это, конечно, не использует Spring Boot, и вам придется подключить все это самостоятельно

Сам фреймворк состоит из нескольких уже написанных основных Java-зависимостей (Debezium или Confluent JDBC Connector, для вашего примера mysql) и двух файлов конфигурации.Один для Kafka Connect, чтобы узнать о серверах начальной загрузки, сериализаторах и т. Д., А другой для фактического коннектора MySQL.

...