consumer 相关问题

如何更新使用两个上下文使用者的组件的状态

我有一个类组件，该组件使用两个上下文，这些上下文具有从对REST API的API调用生成的值。我要做的是获取上下文值，并使用它们来更新我的组件状态。我是...

reactjs consumer react-context react-state-management

回答 3 投票 3

Java的消费者与回报[复制]

我不明白为什么这个代码工作：资源类{私人资源（）{的System.out.println（“创建......”）; }公共资源OP1（）{的System.out.println（ “OP1”）; ...

java consumer

回答 1 投票 -1

一个MQTT订阅者可以能够采取相同主题的同时多条消息？

我想在我的春节，引导应用程序来创建一个用户。我的目标是，出版商将多个消息发送到一个话题，我一定要得到这些消息并处理它们。我注意到...

activemq mqtt consumer spring-integration-mqtt

回答 1 投票 0

解决减缓LMAX干扰器模式的消费者（eventProcessor）问题

当使用干扰物，可能是消费者（S），即相对滞后，以及因为接收者很慢，整个应用程序会受到影响。请记住，每个生产者（发布者）和...

consumer disruptor-pattern

回答 3 投票 6

确实的RabbitMQ持续了消费者一个打开的连接？

我想实现在环境中的RabbitMQ的解决方案，其中所有的连接都必须从安全区域开始不太安全区。该标准的RabbitMQ实现预见...

callback rabbitmq producer-consumer messagebroker consumer

回答 1 投票 0

JMS消费者微服务的故障转移机制已关闭

我们正在使用activemq用于微服务消息代理。我的查询是关于如何为消费者服务构建故障转移机制。如果消费者服务中断，如何继续进行。我们能做......

spring-boot jms activemq failover consumer

回答 1 投票 -1

React：如何在ComponentDidMount中使用我的使用者来改变状态？

所以我使用React的上下文因为我必须改变相反方向的状态。例如：App.js（有州）

javascript reactjs consumer

回答 2 投票 0

如何设计用于从Kafka获取客户端事件的API？

我考虑架构模式，当我的服务的每个客户都有自己的kafka消费者。例如，有一些事件主题带有一些复制因子和一些分区，我用它们......

java architecture apache-kafka consumer

回答 1 投票 0

Thread.Pool中java.lang.Thread和线程的性能问题

Kafka消费者应用程序具有严重的延迟（在高峰时段没有足够快地消耗kafka事件）。 kafka主题有120个分区，而消费者群体共有30个主机，...

multithreading apache-kafka threadpool executorservice consumer

回答 2 投票 2

如何知道何时停止并行foreach，其中消费者也是C＃中的生产者

我试图使用Parallel.ForEach（）并行处理BlockingCollection中的一些项目。处理项目时，它可以生成0-2个要处理的项目。要处理的项目数量将...

c# parallel-processing parallel.foreach consumer producer

回答 1 投票 0

Pact JVM Java不清楚newbie / starter / tutorial项目？

是否有一个小而简洁的jvm消费者Java（消费者或提供者）junit项目，有人可以分享，最好是在包含所有文件的自包含zip文件中，除了jar ...

java junit jvm consumer pact

回答 3 投票 1

Kafka - 并非所有消费者都收到订阅的消息

为了使用Kafka一般发布消息，我使用类名作为主题：kafkaProducer.send（new ProducerRecord（object.getClass（）。getName（），new DomainObjectAdapter（object）.toJsonString（）））; ...

apache-kafka partition consumer

回答 2 投票 1

如果第一个经纪人失败，卡夫卡消费者就无法消费

我正在使用最新版本的kafka（kafka_2.12-1.0.0.tgz）。我已经设置了包含3个代理的简单集群（在每个实例的属性文件中只更改了broker.id = 1和listeners = PLAINTEXT：//：9092）。之后......

apache-kafka failover consumer

回答 2 投票 4

使用python的Kafka Consumer轮询消息

我在使用消费者群体时从Kafka轮询消息时遇到问题。我的使用者对象使用self.ps = TopicPartition（主题，分区）分配给给定分区，然后消费者...

python apache-kafka consumer kafka-python

回答 1 投票 2

然后在Consumer界面中使用lambda [复制]

我可以和lambdas连在一起吗？我知道我可以这样做：myList.forEach（myConsumer1.andThen（myConsumer2））;但是如果我想提供一个lambda（e） - > {some actions}而不是...

java lambda consumer

回答 2 投票 1

使用泛型类型调用AddConsumer

当我使用MassTransit v5.1.5和默认的ASP.NET Core DI时，我遇到了问题。我有以下代码：var consumers = typeof（CompanyApplicationService）.Assembly .GetTypes（）...

asp.net-core dependency-injection masstransit consumer

回答 1 投票 1

异常Eventlistener没有捕获RabbitMQ使用者的异常

我正在Symfony中创建一个微服务，我需要使用RabbitMQ来使用消息来创建文档。消费者正在工作但是每当抛出异常时我想在...中记录异常

php symfony error-handling rabbitmq consumer

回答 1 投票 0

Hazelcast Queue ItemListener for Pending Item（Producer-Consumer Concept）

我有两个使用Hazelcast的节点。节点A是生产者，它将项目放入队列节点B是消费者，它从队列中消耗或汇集项目。我将ItemListener添加到Node B中，所以当一个项目......

queue hazelcast consumer itemlistener producer

回答 1 投票 0

如何查看（新）与特定Kafka主题相关的消费者

我有一个新消费者列表（python消费者）。我可以使用以下命令检索组：bin / kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost：9092 --list我可以获取...

python apache-kafka consumer

回答 2 投票 2

生产者/消费者FIFO信号量

所以，我一直致力于生产者/消费者问题，我有10个生产者和10个消费者。消费者从生产者生产的FIFO中检索一个数字。所有的消费者......

java fifo consumer producer

回答 1 投票 0

consumer 相关问题

最新问题