Systeme kommen nicht alleine. In der modernen Welt der Microservices und der Cloud-Bereitstellung müssen neue Komponenten mit Legacy-Systemen interagieren, was die Integration zu einem wichtigen Schlüssel zum Erfolg macht. Reactive Streams geben uns ein technologieunabhängiges Werkzeug an die Hand, mit dem diese heterogenen Systeme kommunizieren können, ohne sich gegenseitig zu überfordern.
Das Alpakka-Projekt ist eine Open-Source-Initiative zur Implementierung streamfähiger, reaktiver Integrationspipelines für Java und Scala. Es baut auf Akka Streams auf und wurde von Grund auf so konzipiert, dass es Streaming nativ versteht und ein DSL für reaktive und streamorientierte Programmierung mit integrierter Unterstützung für Gegendruck bereitstellt. Akka Streams ist eine mit Reactive Streams und JDK 9+ java.util.concurrent.Flow kompatible Implementierung und daher vollständig interoperabel mit anderen Implementierungen.
Dieses Repository enthält die Quellen für den Alpakka Kafka-Connector . Damit können Sie Apache Kafka mit Akka Streams verbinden. Früher war es als Akka Streams Kafka und sogar als Reactive Kafka bekannt.
Akka Stream-Konnektoren zu anderen Technologien sind im Alpakka-Repository aufgeführt.
Alpakka-Referenzdokumentation
Referenzdokumentation zum Alpakka Kafka-Connector
Um über die neuesten Alpakka-Veröffentlichungen auf dem Laufenden zu bleiben, schauen Sie sich Alpakka-Veröffentlichungen und Alpakka-Kafka-Veröffentlichungen an.
Sie können diesen Gruppen und Chats beitreten, um Akka- und Alpakka-bezogene Fragen zu diskutieren und zu stellen:
Darüber hinaus können Sie Folgendes genießen:
Der Kafka-Connector wurde ursprünglich als Reactive Kafka von erstellt.
Die Akka-Projektfamilie wird von Teams bei Lightbend mit Hilfe der Community verwaltet.
Beiträge sind herzlich willkommen! Lightbend freut sich über Community-Beiträge sowohl von Alpakka-Neulingen als auch von erfahreneren Spielern.
Alpakka ist darauf angewiesen, dass die Community mit der ständig wachsenden Zahl an Technologien, in die es integriert werden kann, Schritt halten kann. Bitte melden Sie sich an und teilen Sie die erfolgreichen Akka Stream-Integrationen, die Sie implementieren, mit der Alpakka-Community.
Wenn Sie auf ein Problem stoßen, das behoben werden soll, können Sie dies am schnellsten erreichen, indem Sie das Problem implementieren und eine Pull-Anfrage senden.
Weitere Details zum Workflow und allgemeine Hinweise zur Vorbereitung Ihrer Pull-Anfrage finden Sie in der Datei CONTRIBUTING.md.
Sie können auch direkt um Klarstellungen oder Anleitung zu GitHub-Problemen bitten.
Alpakka-Komponenten sind zwischen den Versionen nicht immer binärkompatibel. Es können API-Änderungen eingeführt werden, die nicht abwärtskompatibel sind, wenn wir sie basierend auf Ihrem Feedback verfeinern und vereinfachen. Ein Modul kann in jeder Version gelöscht werden, ohne dass es vorher veraltet ist.
Akka ist unter der Business Source License 1.1 lizenziert. Weitere Informationen finden Sie in den häufig gestellten Fragen zur Akka-Lizenz.
Tests und Dokumentation unterliegen einer separaten Lizenz. Weitere Informationen finden Sie in der LICENSE-Datei in jeder Dokumentation und im Stammverzeichnis des Tests.