Resultados da pesquisa a pedido "apache-kafka-streams"
Kafka Streams - envie tópicos diferentes, dependendo dos dados do Streams
Eu tenho um aplicativo kafka streams aguardando a publicação de registros no tópicouser_activity. Ele receberá dados json e, dependendo do valor de contra uma chave, desejo inserir esse fluxo em tópicos diferentes. Este é o meu código de ...
Como gerenciar a junção em janela do Kafka KStream ao Kstream?
Baseado emapache Kafka docs [https://kafka.apache.org/documentation/streams#streams_dsl_joins] KStream-to-KStream Joins are always windowed joins, minha pergunta é como posso controlar o tamanho da janela? É do mesmo tamanho para manter os dados ...
Consultas do sistema externo durante o processamento do Kafka Stream
Estou tentando criar uma arquitetura de streaming para análise de streaming. Requisitos: Entrada de dados de streaming RT e NRTProcessadores de fluxo implementando algumas análises financeirasFluxo de saída da análise RT e NRTSolicitações ...
Streaming de mensagens para vários tópicos
Eu tenho um único tópico mestre e vários predicados, cada um dos quais com um tópico de saída associado a ele. Quero enviar cada registro para TODOS os tópicos cujo predicado se resolve como verdadeiro. Estou usando o Luwak para testar quais ...
Kafka Streams - Como controlar melhor o particionamento do tópico de armazenamento de estado criado internamente?
As lojas do estado em Kafka Streams são criadas internamente. Os armazenamentos de estado são particionados por chave, mas não permitem fornecer particionamento diferentepor chave (no meu conhecimento). QUESTÕES Comocontrolar o número de ...
Por que o Apache Kafka Streams usa o RocksDB e se é possível alterá-lo?
Durante a investigação de novos recursos no Apache Kafka 0.9 e 0.10, usamos o KStreams e o KTables. Há um fato interessante, que o Kafka usa o RocksDB internamente. VejoIntrodução ao Kafka Streams: processamento de ...
Número da linha Kafka Streams
Eu sou novo no Kafka Streams, atualmente estou confuso com o paralelismo máximo do aplicativo Kafka Streams. Eu segui o link a seguir e não obtive a resposta que estou tentando ...
Kafka Streams não incrementa o deslocamento em 1 ao produzir para o tópico
Eu implementei um processador de registro de cartas Kafka Dead simple Funciona perfeitamente ao usar registros produzidos pelo produtor do consol No entanto, acho que nossos aplicativos Kafka Streams não garantem que, produzindo registros ...
Testar a topologia do Kafka Streams
Estou procurando uma maneira de testar um aplicativo Kafka Streams. Para que eu possa definir os eventos de entrada e a suíte de testes me mostre a saída. Isso é possível sem uma configuração real do Kafka?
Como posso obter o valor de deslocamento no KStream
Estou desenvolvendo um PoC com o Kafka Streams. Agora, preciso obter o valor de deslocamento no consumidor do fluxo e usá-lo para gerar uma chave exclusiva(topic-offset)->hash para cada mensagem. O motivo é: os produtores são syslog e apenas ...