Os sistemas não vêm sozinhos. No mundo moderno de microsserviços e implantação em nuvem, novos componentes devem interagir com sistemas legados, tornando a integração uma chave importante para o sucesso. Os Reactive Streams nos fornecem uma ferramenta independente de tecnologia para permitir que esses sistemas heterogêneos se comuniquem sem sobrecarregar uns aos outros.
O projeto Alpakka é uma iniciativa de código aberto para implementar pipelines de integração reativos e com reconhecimento de fluxo para Java e Scala. Ele é construído com base no Akka Streams e foi projetado desde o início para entender o streaming nativamente e fornecer um DSL para programação reativa e orientada a fluxo, com suporte integrado para contrapressão. Akka Streams é uma implementação compatível com Reactive Streams e JDK 9+ java.util.concurrent.Flow e, portanto, totalmente interoperável com outras implementações.
Este repositório contém as fontes do conector Alpakka Kafka . O que permite conectar o Apache Kafka ao Akka Streams. Anteriormente era conhecido como Akka Streams Kafka e até mesmo Reactive Kafka .
Os conectores Akka Stream para outras tecnologias estão listados no repositório Alpakka.
Documentação de referência Alpakka
Documentação de referência do conector Alpakka Kafka
Para acompanhar os últimos lançamentos do Alpakka, confira os lançamentos do Alpakka e os lançamentos do Alpakka Kafka.
Você pode participar desses grupos e bate-papos para discutir e fazer perguntas relacionadas a Akka e Alpakka:
Além disso, você pode gostar de seguir:
O conector Kafka foi originalmente criado como Reactive Kafka por .
A família de projetos Akka é gerenciada por equipes da Lightbend com a ajuda da comunidade.
Contribuições são muito bem-vindas! Lightbend agradece as contribuições da comunidade tanto dos novos na Alpakka quanto dos mais experientes.
A Alpakka depende da comunidade para acompanhar o número cada vez maior de tecnologias com as quais se integra. Intensifique e compartilhe as integrações bem-sucedidas do Akka Stream que você implementa com a comunidade Alpakka.
Se você encontrar um problema que gostaria de ver corrigido, a maneira mais rápida de fazer isso acontecer é implementar a correção e enviar uma solicitação pull.
Consulte o arquivo CONTRIBUTING.md para obter mais detalhes sobre o fluxo de trabalho e dicas gerais sobre como preparar sua solicitação pull.
Você também pode solicitar esclarecimentos ou orientações diretamente sobre questões do GitHub.
Os componentes Alpakka nem sempre são compatíveis binariamente entre as versões. Alterações de API que não são compatíveis com versões anteriores podem ser introduzidas à medida que refinamos e simplificamos com base no seu feedback. Um módulo pode ser descartado em qualquer versão sem depreciação prévia.
Akka é licenciada sob a Business Source License 1.1, consulte as Perguntas frequentes sobre licença Akka.
Os testes e a documentação estão sob uma licença separada. Consulte o arquivo LICENSE em cada documentação e no diretório raiz do teste para obter detalhes.