Criando aplicativos reativos do Couchbase com o Flink

O conector do Couchbase Flink foi atualizado para a versão 0.5.0.

O Apache Flink é uma estrutura e um mecanismo de processamento distribuído para cálculos com estado em fluxos de dados ilimitados e limitados. O Flink foi projetado para ser executado em todos os ambientes de cluster comuns e realizar cálculos na velocidade da memória e em qualquer escala. 

Com nosso conector Couchbase recentemente atualizado, os projetos Flink podem usar os clusters do Couchbase não apenas para armazenar e recuperar dados, mas também para assinar e reagir a alterações nos dados à medida que elas são aplicadas no cluster. Esse recurso é implementado pela leitura direta do fluxo do protocolo de alteração de dados de um cluster do Couchbase. 

Há várias mudanças perceptíveis nesta versão do conector Flink:

• O Flink 2.1.1 agora é compatível com o conector
• O Couchbase java SDK foi atualizado para a versão mais recente
• A dependência da biblioteca DCP é atualizada para a versão mais recente

Além de introduzir o suporte para o Flink 2.1.1, essa nova versão atualiza as dependências do Couchbase e remove APIs anteriormente obsoletas.

O conector pode ser instalado a partir de um repositório Maven:

Ou pode ser criado a partir de fontes localizadas no seguinte repositório do GitHub: https://github.com/couchbaselabs/flink-connector-couchbase. 

O conector fornece classes do Flink, como:

• CouchbaseDCPSource - assina o fluxo DCP do Couchbase para processamento de mutação em tempo real 
• CouchbaseQuerySource  - Executa consultas SQL++ e transmite os resultados para o Flink
• CouchbaseCollectionSink - Armazena documentos em coleções do Couchbase.

Pequenos exemplos de projetos Java que demonstram como usar o conector podem ser encontrados na seção exemplos no repositório: https://github.com/couchbaselabs/flink-connector-couchbase/tree/master/examples

No momento, a biblioteca de conectores é experimental e está em fase alfa. Agradecemos o feedback e as contribuições da comunidade. Se você tiver algum problema ao usar o conector ou se tiver algum feedback, abra um problema no GitHub no repositório do projeto: https://github.com/couchbaselabs/flink-connector-couchbase/issues