Resultados da pesquisa a pedido "spring-kafka"
Kafka incorporado: KTable + KTable leftJoin produz registros duplicados
Eu venho buscando o conhecimento do arcano. Primeiro, eu tenho dois pares de tópicos, com um tópico em cada par alimentando o outro tópico. Dois KTables estão sendo formados pelos últimos tópicos, que são usados em um KTable + KTable leftJoin. O ...
Por que o consumidor Kafka leva muito tempo para começar a consumir?
Iniciamos um consumidor Kafka, ouvindo um tópico que ainda não foi criado (a criação automática de tópicos está ativada). Pouco tempo depois, um produtor está publicando mensagens sobre esse tópico. No entanto, leva algum tempo para o ...
Consumidor kafka primavera, procure compensar em tempo de execução?
Estou usando o KafkaMessageListenerContainer para consumir a partir do tópico kafka, tenho uma lógica de aplicativo para processar cada registro que depende também de outros microsserviços. Agora estou confirmando manualmente o deslocamento após ...
Kafka em Kubernetes - Marcando o coordenador como morto para o grupo
Eu sou muito novo no Kubernetes e queria configurar o Kafka e o tratador com ele. Consegui configurar o Apache Kafka e o Zookeeper no Kubernetes usando o StatefulSets. eu seguiesta ...
Mensagens de marca de exclusão não removendo registro do armazenamento de estado do KTable?
Estou criando os dados de processamento do KTable a partir do KStream. Mas quando eu aciono uma lápide com chave e carga nula, ele não está removendo a mensagem do KTable. amostra - public KStream<String, GenericRecord> ...
Lendo a mesma mensagem várias vezes de Kafka
eu usoAPI Spring Kafka [http://docs.spring.io/spring-kafka/reference/htmlsingle/#_retrying_deliverieshttp://] implementar o consumidor Kafka com gerenciamento manual de deslocamento: @KafkaListener(topics = "some_topic") public void ...
Spring @KafkaListener executa e pesquisa registros após determinado intervalo
Queríamos consumir os registros após um determinado intervalo (por exemplo, a cada 5 minutos). As propriedades do consumidor são padrão: @Bean public KafkaListenerContainerFactory<ConcurrentMessageListenerContainer<Integer, String>> ...
Exemplo de teste Kafka incorporado simples com bota de mola
Editar FYI:exemplo de trabalho do gitHub [https://github.com/YunaBraska/embedded-kafka-example] Eu estava pesquisando na Internet e não consegui encontrar um exemplo simples e funcional de um teste Kafka incorporado. Minha configuração é: Bota ...
Como escrever para os consumidores Kafka - single threaded vs multi threaded
Eu escrevi um único consumidor Kafka (usando o Spring Kafka), que lê de um único tópico e faz parte de um grupo de consumidores. Depois que uma mensagem é consumida, ela executa todas as operações a jusante e passa para o próximo deslocamento da ...
Como testar um ConsumerAwareRebalanceListener?
Eu desenvolvi um@KafkaListener que também está marcado com oConsumerAwareRebalanceListener interface, usando o Spring Boot 2.0.6. Eu implementei oonPartitionsAssigned, no qual rebobino o deslocamento de um período fixo de tempo, digamos 60 ...
Página 1 do 2