consumer相关内容

MasstranSite-长时间运行的流程和即时响应

我正在使用具有Azure Service Bus的MasstranSite,我希望实现的是从API调用Bus,其中的一些请求将触发较长的进程,但也会立即获得已收到请求的响应。 实现这一目标的最佳方式是什么? 我应该将JobConsumer和GetResponse与JobSubmissionAccept一起使用,还是有更好的选择? 推荐答案 如果您的使用者需要很长时间,通常超过五分 ..

使用流和减少消费者链的订单保证

因此,在当前场景中,我们有一组 API,如下所列: 消费者开始();消费者执行每日聚合();消费者performLastNDaysAggregates();消费者重新填充分数();消费者更新数据存储(); 在这些之上,我们的调度程序之一执行任务,例如 private void performAllTask​​s(T data) {开始().然后(执行每日聚合() ..
发布时间:2022-01-22 10:39:34 Java开发

如何在 RabbitMQ 中设置重试次数?

我正在使用 RabbitMQ,并且我有一个保存电子邮件消息的队列.我的消费者服务使消息出队并尝试发送它们.如果出于任何原因,我的消费者无法发送消息,我想将消息重新排队以再次发送.我意识到我可以做一个 basicNack 并将 requeue 标志设置为 true,但是,我不想无限期地重新排队消息(例如,如果我们的电子邮件系统出现故障,我不想不断地重新排队未发送的消息).我想定义一个有限的次数,我可 ..
发布时间:2022-01-11 17:02:02 C#/.NET

OAuth 提供程序库 (Java)

我正在寻找可帮助我构建 OAuth 提供程序的 Java 库.我必须能够接收 OAuth 签名的请求并确定它们是否有效(检查签名、时间戳和现时值). 你知道是否有什么东西可以让这个任务更容易吗? 解决方案 Scribe 是 Java 的 OAuth 库,由提问者自己编写.;-) 注意:我将其发布在这里作为答案,以便其他谷歌员工可以选择替代方案.对于另一个基于库的替代方案,请参阅 ..
发布时间:2021-12-31 08:53:43 Java开发

快速和最佳的生产者/消费者队列技术 BlockingCollection 与并发队列

我在 C# 3.0 中使用 Generic.Queue 和 Monitor.Enter,wait,exit for wait 在消费队列之前(等待元素入队).现在我正在转向 C# 4. 谁能告诉我哪一个是快速且最好的,尤其是避免锁定.. BlockingCollection 与 concurrentQueue 或其他任何东西... 注意.我不想限制我的制作人 提前致谢.. ..
发布时间:2021-12-28 22:46:28 其他开发

每个 kinesis 分片有多个消费者

我了解到每个 kinesis 流可以有多个消费者应用程序. http://docs.aws.amazon.com/kinesis/latest/dev/developing-consumers-with-kcl.html 但是,我听说每个分片只能拥有一个消费者.这是真的?我没有找到任何文档来支持这一点,并且无法想象如果多个消费者从同一个流中读取会怎样.当然,这并不意味着生产者需要为不同 ..
发布时间:2021-11-27 10:18:48 其他开发

如何在 Javascript 中实现安全的 OAuth2 消费?

我正在用 PHP 设计一个将使用 OAuth2.0 的 API.我的最终目标是用 javascript(使用 AngularJS)构建一个直接访问这个 API 的前端应用程序.我知道传统上没有办法保护 javascript 中的事务,因此直接访问 API 是不可行的.前端需要与服务器代码进行通信,而服务器代码又直接与 API 进行通信.但是,在研究 OAuth2 时,似乎 User-Agent F ..
发布时间:2021-11-15 00:32:44 前端开发

Java 中的 Kafka 消费者

所以我目前正在学习 Kafka,并试图复制 Apache 提供的示例 这里.这是消费者的示例代码,我已经用 java 编写了它,如图所示.但是,当我尝试执行该文件时,我遇到了一些问题.我可以编译文件,但无法正常运行. 我使用以下不带引号的行执行程序,“java TestConsumer localhost:2181 group1 test 4"这传递了示例代码中必需的 4 个参数.但是当我执 ..
发布时间:2021-11-12 02:56:03 Java开发

Java 中的 Kafka 消费者

所以我目前正在学习 Kafka,并试图复制 Apache 提供的示例 这里.这是消费者的示例代码,我已经用 java 编写了它,如图所示.但是,当我尝试执行该文件时,我遇到了一些问题.我可以编译文件,但无法正常运行. 我使用以下不带引号的行执行程序,“java TestConsumer localhost:2181 group1 test 4"这传递了示例代码中必需的 4 个参数.但是当我执 ..
发布时间:2021-11-12 02:55:32 Java开发

生成消息时找不到主题:UNKNOWN_TOPIC_OR_PARTITION

我有一个两节点的 Kafka 集群(EC2 实例),其中每个节点都用作单独的代理.当我使用以下命令在领导者实例上运行生产者时: kafka-console-producer.sh --broker-list localhost:9092 --topic 测试 我收到以下错误. 测试消息[2017-01-09 13:22:39,483] 获取关联 ID 为 0 的元数据时出现警告错误:{t ..
发布时间:2021-11-12 02:12:40 其他开发

Kafka 和 NodeJS 的实时通知

在我的项目中,我必须设计一个实时通知系统.我按照下图做了. 你可以看到我使用 Kafka 作为队列消息系统,使用 NodeJS 构建 Websocket Server 和 Kafka Consumers.生产者将收集通知数据并将其推送到 Kafka.如果数据属于该用户,消费者将从 Kafka 读取并处理数据,并通过 websocket 将其推送到客户端. 有了上面的架构师,每个在线用户 ..
发布时间:2021-11-12 02:11:55 其他开发

Kafka 高级消费者使用 Java API 从主题中获取所有消息(相当于 --from-beginning)

我正在使用来自 Kafka 站点的 ConsumerGroupExample 代码测试 Kafka 高级消费者.我想检索关于我在 Kafka 服务器配置中拥有的名为“test"的主题的所有现有消息.查看其他博客,auto.offset.reset 应该设置为“smallest"才能获取所有消息: private static ConsumerConfig createConsumerConfig ..
发布时间:2021-11-12 01:52:40 Java开发