Resultados da pesquisa a pedido "spring-kafka"
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 ...
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 ...
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> ...
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 ...
O Spring Kafka Producer não está enviando para o Kafka 1.0.0 (o Magic v1 não suporta cabeçalhos de registros)
Estou usando esta configuração do docker-compose para configurar o Kafka localmente:https://github.com/wurstmeister/kafka-docker/ [https://github.com/wurstmeister/kafka-docker/] docker-compose up funciona bem, a criação de tópicos via shell ...
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 ...
KStream envia registro para vários fluxos (não Branch)
Existe uma maneira de fazer uma operação semelhante a uma ramificação, mas colocar um registro em cada fluxo de saída cujo predicado é avaliado como verdadeiro? Brach coloca o registro na primeira correspondência (documentação: um registro é ...
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 ...
Página 1 do 2