consumer相关内容
我正在使用具有Azure Service Bus的MasstranSite,我希望实现的是从API调用Bus,其中的一些请求将触发较长的进程,但也会立即获得已收到请求的响应。 实现这一目标的最佳方式是什么? 我应该将JobConsumer和GetResponse与JobSubmissionAccept一起使用,还是有更好的选择? 推荐答案 如果您的使用者需要很长时间,通常超过五分
..
因此,在当前场景中,我们有一组 API,如下所列: 消费者开始();消费者执行每日聚合();消费者performLastNDaysAggregates();消费者重新填充分数();消费者更新数据存储(); 在这些之上,我们的调度程序之一执行任务,例如 private void performAllTasks(T data) {开始().然后(执行每日聚合()
..
我正在尝试创建一个使用来自外部服务的 API 的骆驼组件. 我的路线如下 from("myComponent:entity?from=&to=").to(“seda:one")来自(“seda:one").aggregate(常量(真),新 GroupedBodyAggregationStrategy()).completionSize(5).completionTimeout(5000)
..
我正在按照文档构建一个演示应用程序,以在 ASP.NET Core 应用程序中使用 MassTransit 与 RabbitMQ 和 Autofac: 我的程序代码: 命名空间 MessageDemo{公开课程序{公共静态无效主要(字符串[]参数){var host = Host.CreateDefaultBuilder(args).UseServiceProviderFactory(ne
..
QueueingConsumer 消费者 = new QueueingConsumer(channel);System.out.println(consumer.getConsumerTag());channel.basicConsume("queue1", 消费者);channel.basicConsume("queue3", 消费者); 是否可以动态停止单独使用队列“queue3"中的消息?
..
我正在使用 RabbitMQ,并且我有一个保存电子邮件消息的队列.我的消费者服务使消息出队并尝试发送它们.如果出于任何原因,我的消费者无法发送消息,我想将消息重新排队以再次发送.我意识到我可以做一个 basicNack 并将 requeue 标志设置为 true,但是,我不想无限期地重新排队消息(例如,如果我们的电子邮件系统出现故障,我不想不断地重新排队未发送的消息).我想定义一个有限的次数,我可
..
我正在寻找可帮助我构建 OAuth 提供程序的 Java 库.我必须能够接收 OAuth 签名的请求并确定它们是否有效(检查签名、时间戳和现时值). 你知道是否有什么东西可以让这个任务更容易吗? 解决方案 Scribe 是 Java 的 OAuth 库,由提问者自己编写.;-) 注意:我将其发布在这里作为答案,以便其他谷歌员工可以选择替代方案.对于另一个基于库的替代方案,请参阅
..
我在 C# 3.0 中使用 Generic.Queue 和 Monitor.Enter,wait,exit for wait 在消费队列之前(等待元素入队).现在我正在转向 C# 4. 谁能告诉我哪一个是快速且最好的,尤其是避免锁定.. BlockingCollection 与 concurrentQueue 或其他任何东西... 注意.我不想限制我的制作人 提前致谢..
..
我了解到每个 kinesis 流可以有多个消费者应用程序. http://docs.aws.amazon.com/kinesis/latest/dev/developing-consumers-with-kcl.html 但是,我听说每个分片只能拥有一个消费者.这是真的?我没有找到任何文档来支持这一点,并且无法想象如果多个消费者从同一个流中读取会怎样.当然,这并不意味着生产者需要为不同
..
我正在尝试使用 oauth2 包(版本 2)使用 Yelp 的 API,Python 3.4(在 Anaconda 的 Spyder 中)代码如下: consumer = oauth2.Consumer(CONSUMER_KEY, CONSUMER_SECRET) 我收到此错误消息: AttributeError: 'module' 对象没有属性 'Consumer' 我猜这个版本
..
我正在用 PHP 设计一个将使用 OAuth2.0 的 API.我的最终目标是用 javascript(使用 AngularJS)构建一个直接访问这个 API 的前端应用程序.我知道传统上没有办法保护 javascript 中的事务,因此直接访问 API 是不可行的.前端需要与服务器代码进行通信,而服务器代码又直接与 API 进行通信.但是,在研究 OAuth2 时,似乎 User-Agent F
..
所以我目前正在学习 Kafka,并试图复制 Apache 提供的示例 这里.这是消费者的示例代码,我已经用 java 编写了它,如图所示.但是,当我尝试执行该文件时,我遇到了一些问题.我可以编译文件,但无法正常运行. 我使用以下不带引号的行执行程序,“java TestConsumer localhost:2181 group1 test 4"这传递了示例代码中必需的 4 个参数.但是当我执
..
所以我目前正在学习 Kafka,并试图复制 Apache 提供的示例 这里.这是消费者的示例代码,我已经用 java 编写了它,如图所示.但是,当我尝试执行该文件时,我遇到了一些问题.我可以编译文件,但无法正常运行. 我使用以下不带引号的行执行程序,“java TestConsumer localhost:2181 group1 test 4"这传递了示例代码中必需的 4 个参数.但是当我执
..
我更改了监听 Kafka 主题的 Web 服务的消费者组 ID.现在,旧的组 ID 仍然注册到主题,但没有具有该组 ID 的消费者.因此,它是滞后的.如何从特定主题中删除特定的消费者群体? 我试过了: kafka-consumer-groups --bootstrap-server kafka01.myserver.com:9092 --topic notification-topic
..
我有一个两节点的 Kafka 集群(EC2 实例),其中每个节点都用作单独的代理.当我使用以下命令在领导者实例上运行生产者时: kafka-console-producer.sh --broker-list localhost:9092 --topic 测试 我收到以下错误. 测试消息[2017-01-09 13:22:39,483] 获取关联 ID 为 0 的元数据时出现警告错误:{t
..
在我的项目中,我必须设计一个实时通知系统.我按照下图做了. 你可以看到我使用 Kafka 作为队列消息系统,使用 NodeJS 构建 Websocket Server 和 Kafka Consumers.生产者将收集通知数据并将其推送到 Kafka.如果数据属于该用户,消费者将从 Kafka 读取并处理数据,并通过 websocket 将其推送到客户端. 有了上面的架构师,每个在线用户
..
我正在使用最新版本的 kafka(kafka_2.12-1.0.0.tgz).我已经设置了具有 3 个代理的简单集群(只是在每个实例的属性文件中更改了 broker.id=1 和 listeners=PLAINTEXT://:9092).集群启动后,我使用以下命令创建了主题 ./kafka-topics.sh --create --zookeeper localhost:2181 --repli
..
我正在尝试利用镜像制造商将 __consumer_offsets 主题与其他主题一起复制. 它给出了如下所述的错误. [2018-10-24 16:16:03,802] ERROR 向主题发送消息时出错__consumer_offsets with key: 16 bytes, value: 445 bytes with error: (org.apache.kafka.clients
..
我正在使用 Kafka 流,并希望将一些消费者偏移量从 Java 重置到开头.KafkaConsumer.seekToBeginning(...) 听起来是正确的做法,但我使用 Kafka Streams: KafkaStreams 流 = new KafkaStreams(builder, props);...流开始(); 我想根据我定义的具体流管道,这会在幕后创建几个消费者.我可以访问那些
..
我正在使用来自 Kafka 站点的 ConsumerGroupExample 代码测试 Kafka 高级消费者.我想检索关于我在 Kafka 服务器配置中拥有的名为“test"的主题的所有现有消息.查看其他博客,auto.offset.reset 应该设置为“smallest"才能获取所有消息: private static ConsumerConfig createConsumerConfig
..