Resultados da pesquisa a pedido "consumer"
Como definir várias tentativas de repetição no RabbitMQ?
Estou usando o RabbitMQ e tenho uma fila que contém mensagens de email. Meu serviço ao consumidor remove as filas de mensagens e tenta enviá-las. Se, por qualquer motivo, meu consumidor não puder enviar a mensagem, gostaria de colocar novamente a ...
Consumindo Primavera Hateoas Pageable
Eu tenho um serviço de descanso usando HAteoas, o que funcionou antes sem paginação. Agora estou produzindo Json paginável. Fiz isso com recursos prontos para uso da Spring-Hateoas. Mas agora estou consumindo e acho que realmente não está bem ...
Não é possível encontrar o tópico ao produzir mensagens: UNKNOWN_TOPIC_OR_PARTITION
Eu tenho um cluster kafka de dois nós (instâncias EC2) em que cada nó é usado como um broker separado. Quando executo um produtor na instância líder com o seguinte comando: kafka-console-producer.sh --broker-list localhost:9092 --topic testEu ...
vários consumidores por fragmento de kinesis
Eu li que você pode ter vários aplicativos de consumidor por fluxo de ...
Campo de obtenção opcional
Eu tenho uma estrutura de classe como esta: public class Foo { private FooB foob; public Optional<FooB> getFoob() { return Optional.ofNullable(foob); } } public class FooB { private int valA; public int getValA() { return valA; } }Meu objetivo é ...
concorrência simultânea: multi-produtor de um consumidor
Eu tenho uma situação em que diferentes threads preenchem uma fila (produtores) e um consumidor recupera o elemento dessa fila. Meu problema é que, quando um...
Consumidor de alto nível Kafka buscar todas as mensagens do tópico usando a API Java (equivalente a --from-begin)
Estou testando o Consumidor de Alto Nível Kafka usando o código ConsumerGroupExample do site Kafka. Eu gostaria de recuperar todas as mensagens existentes no tópico chamado "teste" que tenho na configuração do servidor Kafka. Olhando para outros ...
Sistema produtor / consumidor usando banco de dados (MySql), isso é viável?
Eu preciso usaralguma coisa para coordenar meu sistema com vários consumidores / produtores, cada um rodando em máquinas diferentes com diferentes sistemas operacionais. Eu tenho pesquisado o uso do MySql para fazer isso, mas parece ridiculamente ...
Biblioteca para o provedor OAuth (Java) [closed]
Estou procurando uma biblioteca Java que me ajude a criar um provedor OAuth. Preciso receber solicitações assinadas do OAuth e determinar se elas são válidas...