alpakka kafka
v7.0.0
Системы не приходят одни. В современном мире микросервисов и облачных развертываний новые компоненты должны взаимодействовать с устаревшими системами, что делает интеграцию важным ключом к успеху. Реактивные потоки дают нам технологически независимый инструмент, позволяющий этим разнородным системам взаимодействовать, не подавляя друг друга.
Проект Alpakka — это инициатива с открытым исходным кодом, направленная на реализацию реактивных конвейеров интеграции с поддержкой потоков для Java и Scala. Он построен на основе Akka Streams и был разработан с нуля для понимания потоковой передачи и предоставления DSL для реактивного и потоково-ориентированного программирования со встроенной поддержкой противодавления. Akka Streams — это реализация, совместимая с Reactive Streams и JDK 9+ java.util.concurrent.Flow и, следовательно, полностью совместимая с другими реализациями.
В этом репозитории содержатся исходники коннектора Alpakka Kafka . Это позволяет вам подключить Apache Kafka к Akka Streams. Ранее он был известен как Akka Streams Kafka и даже Reactive Kafka .
Соединители Akka Stream с другими технологиями перечислены в репозитории Alpakka.
Справочная документация Альпакки
Справочная документация по соединителю Alpakka Kafka
Чтобы быть в курсе последних выпусков Alpakka, ознакомьтесь с выпусками Alpakka и выпусками Alpakka Kafka.
Вы можете присоединиться к этим группам и чатам, чтобы обсуждать и задавать вопросы, связанные с Аккой и Альпаккой:
Помимо этого, вам могут быть интересны:
Коннектор Kafka изначально был создан как Reactive Kafka компанией .
Семейством проектов Akka управляют команды Lightbend при помощи сообщества.
Взносы очень приветствуются! Lightbend ценит вклад сообщества как новичков в Альпакке, так и более опытных.
Альпакка зависит от сообщества, чтобы идти в ногу с постоянно растущим числом технологий, с которыми можно интегрироваться. Пожалуйста, сделайте шаг вперед и поделитесь с сообществом Alpakka успешными интеграциями Akka Stream, которые вы реализуете.
Если вы обнаружите проблему, которую хотели бы устранить, самый быстрый способ добиться этого — внедрить исправление и отправить запрос на включение.
Обратитесь к файлу CONTRIBUTING.md для получения более подробной информации о рабочем процессе и общих советов о том, как подготовить запрос на включение.
Вы также можете запросить разъяснения или рекомендации напрямую в вопросах GitHub.
Компоненты Alpakka не всегда двоично совместимы между выпусками. Изменения API, не имеющие обратной совместимости, могут быть внесены по мере доработки и упрощения на основе ваших отзывов. Модуль можно удалить в любой версии без предварительного прекращения поддержки.
Akka лицензируется по лицензии Business Source License 1.1. См. часто задаваемые вопросы по лицензии Akka.
Тесты и документация предоставляются по отдельной лицензии. Подробности см. в файле LICENSE в каждой документации и в корневом каталоге тестов.
