Resultados da pesquisa a pedido "producer-consumer"
Sobrecarga de consumidor RabbitMQ
Eu tenho lido sobre os princípios das mensagens AMQP confirma. ( https://www.rabbitmq.com/confirms.html [https://www.rabbitmq.com/confirms.html]) Artigo realmente útil e bem escrito, mas uma coisa em particular sobre os agradecimentos dos ...
Como encerrar os threads de trabalho após o término do trabalho em um padrão produtor-consumidor multithread?
Estou tentando implementar um padrão produtor-consumidor multithread usando Queue.Queue no Python 2.7. Estou tentando descobrir como fazer com que os consumidores, ou seja, os threads de trabalho, parem assim que todo o trabalho necessário ...
Erro: não foi possível encontrar ou carregar a classe principal config.zookeeper.properties
Estou tentando executar um aplicativo de consumidor produtor de exemplo usando o Apache Kafka. Eu baixei ...
Aguarde e notifique em Threads de Consumidor e Produtor
Apenas comecei a aprender multi-threading. Eu tenho 5 produtores e 2 consumidores em vários segmentos. Basicamente, este programa adiciona 100 itens à fila. O produtor deixará de adicionar quando o tamanho da fila for 100. Gostaria que o ...
Gerenciando a comunicação assíncrona: como examinar a resposta recebida em outro encadeamento
Eu tenho um thread de expedidor e um de ouvinte. Quando envio um comando, desejo aguardar uma resposta antes de enviar o comando de acompanhamento. Além disso, preciso examinar a resposta antes de prosseguir com o segundo comando, o mínimo dos ...
Consumir do Kafka com falha O Iterator está no estado de falha
Estou recebendo exceção ao consumir as mensagens do kafka. org.springframework.messaging.MessagingException: Consuming from Kafka failed; nested exception is java.util.concurrent.ExecutionException: java.lang.IllegalStateException: Iterator is ...
Como o reequilíbrio do consumidor funciona em Kafka?
Quando um novo consumidor / colaborador é adicionado ou desativado, o Kafka aciona uma operação de reequilíbrio. O Kafka Rebalancing é uma operação de bloqueio. Os consumidores da Kafka são bloqueados enquanto uma operação de reequilíbrio está em ...
Como agregar os dados de um produtor assíncrono e gravá-los em um arquivo?
Estou aprendendo sobre padrões assíncronos / aguardados em c #. Atualmente, estou tentando resolver um problema como este: Há um produtor (um dispositivo de hardware) que gera 1000 pacotes por segundo. Eu preciso registrar esses dados em um ...
O Zookeeper é obrigatório para Kafka?
No Kafka, eu gostaria de usar apenas um único broker, tópico único e uma única partição com um produtor e vários consumidores (cada consumidor obtendo sua própria cópia dos dados do broker). Diante disso, eu não quero a sobrecarga de usar o ...
consumidor / produtor em c ++
Este é um problema clássico de c / p, em que alguns threads produzem dados enquanto outros leem os dados. Tanto o produtor quanto os consumidores estão compartilhando um buffer de tamanho constante. Se o buffer estiver vazio, os consumidores ...