consumer 相关问题

golang中生产者消费者死锁

这些是我的全局变量。我在主函数中初始化了taskCond。变量（完成标志布尔值 taskMutexsync.Mutex taskCond *sync.Cond ）我的生产者代码如下所示 - 功能公关...

multithreading go consumer producer

回答 1 投票 0

澄清订阅者不可用时的 QoS 1 和 2 行为

MQTT 的一般流程是：生产者 ---> MQTT Broker ---> 消费者。假设 MQTT Broker 始终启动并运行，但 Consumer 暂时不可用。如果制作人发送消息...

mqtt consumer broker producer qos

回答 1 投票 0

如何暂停KafkaJS消费者并在一段时间后重试

我正在使用 KafkaJS (https://kafka.js.org) 连接到 Kafka 集群。我的消费者负责处理有时可能失败并在等待一段时间后成功的任务（

error-handling apache-kafka consumer pause kafkajs

回答 1 投票 0

Flutter Dialog 无意中触发了后面布局的重新创建

我的 FLutter 代码有一个问题，我无法解决，也无法理解为什么会发生这种情况。首先是问题中的代码：导入 'dart:io'; 导入 'dart:ui'; 导入'包：应用程序/

flutter dart responsive consumer

回答 1 投票 0

consumer.如何指定分区读取？ [卡夫卡]

我正在学习Kafka，我想知道当我从主题消费消息时如何指定分区。我找到了几张这样的图片：这意味着消费者可以消费来自

java apache-kafka partition consumer

回答 1 投票 0

客户端完成消息处理后进行确认。兔子MQ

var 消费者 = new EventingBasicConsumer(channel); Consumer.Received += (模型, ea) => { var eventName = ea.RoutingKey; var message = Encoding.UTF8.GetString(ea.Body);

c# rabbitmq consumer

回答 1 投票 0

如何使用java从kafka主题获取所有消息并统计它们？

此代码有时会从头给我所有消息并等待另一条消息，有时它只是等待另一条消息导入java.util.HashMap；导入java.util.List；

java apache-kafka consumer

回答 1 投票 0

Junit 用于返回 lambda 的消费者类

我正在为具有以下方法的消费者类编写junit测试用例。 @豆 @事务性公共消费者>响应（）{ 返回消息 -> { ...

java lambda junit consumer

回答 1 投票 0

Kafka 消费者在需要时不会暂停

我正在使用 lib https://github.com/confluenceinc/confluence-kafka-go 的 v2 从多个分区使用我的主题。当我启动我的消费者时，看起来不错，但出于商业原因，我...

go apache-kafka cron consumer confluent-kafka-go

回答 1 投票 0

Wolfram Mathematica 中消费者问题的解决方案不起作用

我正在尝试使用 Wolfram Mathematica 13.1 解决柯布-道格拉斯偏好的受限消费者问题。这个问题很简单，可以解析解决。但我的代码不起作用。实用...

optimization wolfram-mathematica consumer wolframalpha wolfram-language

回答 1 投票 0

在java中使用函数式接口

我有 ProductSettings 和 ProductType。产品设置决定是否启用产品类型。产品设置产品设置 = new 产品设置() .setIsTreasuryInfoEn...

java function predicate consumer functional-interface

回答 1 投票 0

参数不匹配的闭包调用：函数“TasksList.build.<anonymous closure>.<anonymous closure>.<anonymous closure>”

您好，当我尝试运行该应用程序时，我收到此错误，它表示闭包调用参数不匹配：函数“TasksList.build...” 由于这是我第一次使用该提供商，所以我...

flutter dart listview provider consumer

回答 1 投票 0

消费者组分配

假设我有一个消费者组，其消费来自：具有 3 个分区的主题 a 具有 2 个分区的主题 b 总共有2个主题和6个分区。如果我将 3 个消费者分配到该组，将会...

apache-kafka consumer

回答 1 投票 0

将消费者偏移重置到 Kafka Streams 的开头

我正在使用 Kafka 流，并且想要将一些消费者偏移量从 Java 重置到开头。 KafkaConsumer.seekToBeginning(...) 听起来像是正确的做法，但我使用 Kafka Streams：

java stream apache-kafka offset consumer

回答 3 投票 0

lua中让消费者作为协程，生产者作为主线程

这是消费者-生产者，生产者作为协程，消费者作为主线程：函数接收（产品）本地状态，值 = coroutine.resume(prod) 返回值结尾函数发送(x)

lua consumer producer

回答 1 投票 0

每个运动分片有多个消费者

我读到每个 kinesis 流可以有多个消费者应用程序。 http://docs.aws.amazon.com/kinesis/latest/dev/developing-consumers-with-kcl.html 然而，我听说每个s只能有一个消费者...

sharding consumer amazon-kinesis

回答 3 投票 0

您将如何在 Windows 服务器上部署 RabbitMQ Consumer

大多数在rabbitmq中设置消费者的教程都使用docker。有没有人在独立的 Windows 服务器上成功部署消费者？就像运行控制台一样简单吗

c# .net rabbitmq consumer

回答 1 投票 0

一元运算符功能接口与消费者功能接口有什么区别？ [已关闭]

我想知道一元运算符和消费者函数式接口有什么区别？最终，他们俩都得到了一个函数并将其应用于泛型 T。预先感谢您！

java consumer functional-interface unary-operator

回答 2 投票 0

如何找出哪个消费者选择了请求（在ActiveMQ Artemis中实现了多个消费者概念）

我们有 3 个生产者和 3 个消费者。当生产者向队列发送消息时，消息由其中一位消费者处理。我们正在尝试确定哪些生产商正在发送

activemq-artemis consumer

回答 1 投票 0

RabbitMQ 批量消费消息并一次全部确认

我有一个 RabbitMQ 队列，我在其中发布了数千条消息。我需要一个后台服务来：批量检索消息，每组消息 100 条将这 100 条消息存储在数据库中确认...

c# rabbitmq batch-processing consumer

回答 1 投票 0

consumer 相关问题

最新问题