Resultados da pesquisa a pedido "consumer"
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 ...
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...
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...
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 ...
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 ...
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 é ...
vários consumidores por fragmento de kinesis
Eu li que você pode ter vários aplicativos de consumidor por fluxo de ...
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 ...
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 ...