Kafka Connect против потоков для раковин [закрыто]
Вы правы, JPA - это спецификация. Hibernate, EclipseLink - это пара его реализаций.
Чтобы использовать реализацию JPA, вам необходимо указать поставщика непрерывности (Hibernate, EclipseLink). Поставщики персистентности имеют классы реализации для спецификаций JPA.
1 ответ
Отличный вопрос! Все дело в использовании правильного инструмента для работы. Специальное назначение Kafka Connect - потоковая интеграция между исходными системами и Kafka, или из Kafka в другие системы (включая RDBMS).
Что дает вам Kafka Connect?
- Масштабируемость; вы можете развернуть несколько рабочих, и Kafka Connect будет распределять задачи между ними
- Устойчивость; если узел выходит из строя, Kafka Connect перезапустит работу на другом работнике
- Простота использования; коннекторы существуют для множества технологий, поэтому для реализации коннектора обычно требуется всего несколько строк управления схемами JSON
- ; поддержка схем в JSON, полная интеграция с реестром схем для Avro, подключаемые преобразователи из сообщества для Protobuf
- Встроенные преобразования с помощью преобразования отдельных сообщений
- Унифицированное и централизованное управление и настройка для всей вашей интеграции tasks
Это не значит, что вы не можете сделать это в Kafka Streams, но вам придется в конечном итоге самому написать много кода, когда он предоставляется из коробка для вас от Kafka Connect. Таким же образом вы могли бы использовать API-интерфейс Consumer API и кучу сделанного на заказ кода для выполнения потоковой обработки, которую дает вам Kafka Streams API, аналогично вы могли бы использовать Kafka Streams для получения данных из тема Кафки в базу данных - но зачем вам?
Если вам необходимо преобразовать данные перед их отправкой в приемник, то рекомендуется отсоединить преобразование от отправки. Преобразуйте данные в Kafka Streams (или KSQL) и запишите их в другую тему Kafka. Используйте Kafka Connect для прослушивания этой новой темы и записи преобразованных сообщений в целевой приемник.