Liberte a IA agêntica em tempo real com agentes de streaming no Confluent Cloud e no Couchbase

Estamos entusiasmados com a parceria com a Confluent, que hoje anuncia os novos recursos para Agentes de streaming no Confluent Cloud e um novo mecanismo de contexto em tempo real. Unificando o processamento de dados e os fluxos de trabalho de IA agêntica, os Streaming Agents permitem que os desenvolvedores criem, implementem e orquestrem agentes orientados a eventos usando o Apache Flink® e o Apache Kafka® totalmente gerenciados em uma plataforma unificada. Os novos recursos de hoje levam isso mais longe, ajudando as equipes a criar agentes confiáveis com mais rapidez e facilidade, obter observabilidade aprimorada e melhorar a tomada de decisões de IA com contexto em tempo real.

Como parceiro da Confluent, vemos em primeira mão por que a introdução dos Streaming Agents foi tão importante. Em sua essência, todo problema de IA é um problema de dados. Quando os dados estão obsoletos, incompletos ou inacessíveis, até mesmo os agentes mais sofisticados e os modelos de linguagem ampla (LLMs) não conseguem fornecer resultados confiáveis.

Era exatamente isso que o mercado exigia: uma solução para a criação de sistemas multiagentes dimensionáveis que fossem orientados por eventos, reproduzíveis e baseados em dados novos e contextualizados. Os desenvolvedores precisavam de uma plataforma única que não fornecesse apenas ferramentas isoladas, mas que lhes permitisse obter dados facilmente, passar de forma confiável do protótipo para a produção e obter a observabilidade necessária para depurar, avaliar e iterar o que está realmente acontecendo dentro de seus agentes.

Agentes de streaming potencializam a automação inteligente e com reconhecimento de contexto

Incorporados aos fluxos de dados com acesso à visão mais recente, completa e precisa dos eventos operacionais, os Streaming Agents atuam efetivamente como os “olhos e ouvidos” da empresa. Eles foram projetados para lidar com grandes volumes de dados em tempo real e com o contexto em evolução, o que os torna ideais para casos de uso corporativo em que informações novas, precisão e observabilidade são essenciais. Ao monitorar continuamente os fluxos de dados e usar o contexto de diversas fontes, os Streaming Agents podem tomar decisões inteligentes e informadas e automatizar ações que geram melhores resultados.

Os casos de uso de alto valor incluem:

• • • Prevenção de fraudes em tempo real - Ingerir e processar continuamente dados de transações, detectar anomalias e bloquear automaticamente atividades suspeitas.
    • Otimização inteligente da cadeia de suprimentos - Acompanhe o estoque, as remessas e os sinais de demanda em tempo real, reordenando automaticamente o estoque, redirecionando as remessas ou ajustando as programações de produção com base em condições reais.
    • Suporte dinâmico ao cliente - Obtenha contexto ao vivo de sistemas de CRM, interações de bate-papo e bases de conhecimento para fornecer respostas personalizadas e precisas no momento.

Vamos explorar esse último caso de uso de suporte ao cliente com mais detalhes. Imagine uma empresa global transmitindo eventos de bate-papo de clientes, atualizações de CRM, sinais de inventário de produtos e feedback de agentes de serviço para o Confluent Cloud. Um Streaming Agent criado com base no Flink:

• • • Consome o evento de bate-papo ao vivo
    • Enriquece-o com contexto (histórico do cliente, última compra, tíquetes abertos)
    • Incorpora o bate-papo por meio de um modelo de incorporação
    • Executa uma pesquisa vetorial de milissegundos no Couchbase 8.0 para encontrar conversas anteriores semanticamente relevantes, artigos da base de conhecimento e ações de suporte
    • Invoca uma ferramenta via MCP em tempo real (por exemplo, API de atualização de tíquetes, ferramenta de agendamento de serviços)
    • Gera uma resposta por meio de um LLM com suporte do RAG
    • Alimenta o resultado de volta ao Couchbase (atualização do estado da conversa) e ao tópico do Kafka para auditoria/análise

O resultado: um agente de suporte ao cliente que é sensível ao contexto, em tempo real, alimentado por semântica + vetor, automatizado e totalmente observável. A pilha de dados subjacente no Couchbase garante o conteúdo mais recente e a recuperação semântica; o mecanismo de streaming Confluent garante fluxo orientado a eventos, orquestração de ferramentas e escala de nível de produção.

O que há de novo na versão Q4’25

Com o Streaming Agents, todos os engenheiros podem usar as APIs conhecidas do Flink para criar agentes seguros e confiáveis, com suporte nativo para inferência de modelos, chamadas de ferramentas com MCP, embeddings para RAG, funções de ML integradas, tabelas externas, pesquisa e conexões. A Confluent continua a expandir esses recursos e a oferecer experiências de desenvolvedor mais simplificadas. 

• • • Definição de agente - Crie agentes rapidamente com apenas algumas linhas de código e desbloqueie tarefas mais sofisticadas com melhores resultados, avaliando e adaptando iterativamente a chamada da ferramenta.
    • Observabilidade e depuração - Obtenha visibilidade de todas as ações do agente, diagnostique facilmente os problemas para acelerar a resolução e recupere-se de falhas de forma confiável.
    • Mecanismo de contexto em tempo real - Usando o MCP (Model Context Protocol), forneça contexto novo aos agentes de streaming, bem como a qualquer outro agente e aplicativo de IA para melhorar a tomada de decisões e a qualidade dos resultados.

Sinergia com o Couchbase 8.0: uma plataforma de dados unificada para IA agêntica

Embora a estrutura de agente de streaming forneça a orquestração e a lógica para a IA agêntica, a plataforma de dados subjacente é igualmente essencial. É aí que o Couchbase entra em cena, e o momento não poderia ser melhor com o recente lançamento do Couchbase 8.0. Aqui está o que você deve saber:

• • • Indexação de vetores em hiperescala: Couchbase 8.0 apresenta suporte cargas de trabalho de pesquisa vetorial em escala de bilhões com latência de milissegundos e precisão de recuperação ajustável. O benchmarking independente mostrou mais de 19.000 consultas por segundo com latência de 28 ms (66% de recuperação) e resultados sólidos em configurações de recuperação mais altas. 
    • Suporte unificado à carga de trabalho: A pesquisa vetorial não é um complemento - ela faz parte da mesma plataforma que lida com acesso a valor-chave, documentos JSON, cache distribuído, pesquisa (vetorial, texto, GEO), análise e sincronização móvel para aplicativos off-line primeiro. Isso significa que as cargas de trabalho operacionais, de IA/agenética e analíticas coexistem sem a necessidade de unir vários silos de dados. 
    • Contexto, atualização e confiança em tempo real: A IA de agentes depende de um contexto preciso e oportuno. Se a camada de recuperação de vetores estiver obsoleta, desconectada ou com alta latência, os agentes downstream serão prejudicados. O Couchbase 8.0 reforça a capacidade de fornecer novas incorporações, atualizações de documentos em tempo real e atualizações de índices em tempo real, que são essenciais para o padrão de agente de streaming.

Agentes de streaming + Couchbase = IA agêntica em tempo real em escala

Veja como a parceria se desenrola e por que acreditamos que ela oferece uma base atraente para sistemas agênticos empresariais de última geração:

1. 1. 1. Ingestão em tempo real e contexto de streaming: Com o Confluent Cloud executando Kafka + Flink + Streaming Agents, os eventos operacionais são capturados, processados, enriquecidos e transformados em tempo real.
      2. Agentes de streaming incorporam fluxos de trabalho de IA: Os desenvolvedores usam as APIs do Flink para incorporar funções de ML, chamar ferramentas, invocar LLMs ou outros modelos, vetorizar conteúdo não estruturado, unir o contexto de streaming a tabelas externas e orquestrar fluxos de trabalho.
      3. Feed de pesquisa vetorial do Couchbase: Os dados, as incorporações, as atualizações de documentos e o contexto mais recentes estão no Couchbase. Os agentes de streaming podem se vincular ao índice de vetores do Couchbase para fornecer recuperação semântica + contextual aos agentes, alimentando assim o RAG, chatbots contextuais, lógica de decisão em tempo real, investigação de anomalias etc.
      4. Sistemas agênticos adaptativos de loop fechado: O pipeline de streaming pode realimentar os resultados e as atualizações do agente no Couchbase. Com o tempo, os agentes aprendem, ajustam-se e o armazenamento de contexto é atualizado. A plataforma unificada oferece suporte a aplicativos operacionais em escala de produção, e não apenas a pipelines de ML únicos.

Recursos adicionais

• • • Explore o blog do Couchbase sobre o lançamento do Couchbase 8.0: plataforma de dados unificada para aplicativos de IA em hiperescala.
    • Leia o blog da Confluent Apresentando o Streaming Agents no Confluent Cloud.
    • Saiba mais sobre os serviços da Confluent Agentes de streaming e experimente o Início rápido dos agentes de streaming.
    • Visite a documentação do conector Couchbase totalmente gerenciado para o Confluent Cloud.

Comece a usar sua conta gratuita do Couchbase Capella aqui.