consumer

    1热度

    1回答

    卡夫卡消费者调查消息与python

    我在消费者组中的卡夫卡轮询消息有问题。 我的消费对象分配给一个给定的分区与 self.ps = TopicPartition(topic, partition) 之后，消费者分配到该分区： self.consumer.assign([self.ps]) 之后，我能够与 算分区内部消息 self.consumer.seek_to_beginning(self.ps) pos = self.
    python apache-kafka consumer kafka-python 2017-09-10

    1热度

    1回答

    管道消费者/生产者：谁应该是消费者/生产者的父/子后叉

    首先，对不起，如果使用不好的英语。 在我的笔记中，我写过这个子进程通常是制作者，但我不明白为什么。 在fork（）调用之后，消费者和生产者是谁？ 问题是：如果子进程是生产者，他会在父进程完成之前完成，这意味着子进程成为僵尸进程。 关于这个问题，我试图了解小素描：
    pipe fork consumer producer 2017-12-27

    1热度

    1回答

    Java消费者的Jython函数

    我想为Java方法提供一个Python函数作为消费者。 public Class MyObject { public void javaFunction(Consumer<Double> consumer){...} } 和 def python_function(arg): some_code_using(arg) 我试过如下： myObjectInstance.j
    java python jython consumer 2017-07-31

    1热度

    1回答

    消息在虚拟主题不是由消费者队列

    我试图用一个队列中的ActiveMQ从虚拟话题邮件出列消耗。我试着将一些消息和它显示了主题下的“消息入队”，但它是不能够被消耗掉。我创建 虚拟主题名称是VirtualTopic.AA和消费者称为Consumer.client1.VirtualTopic.AA。 在consumer.client1.VirtualTopic.AA，我可以看到，有一个消费者，但它是不能够从虚拟话题出队的消息。 任何人都
    spring jms activemq virtual consumer 2017-09-27

    0热度

    1回答

    Java客户端程序消耗与授权

    我需要调用Java代码中REST调用REST调用。 我在 编号 保障形式主要凭据 提供的算法，这 获取服务器时间 使用标识，安全密钥它生成一个安全令牌 现在授权在下面的表格 "Authorization": "name id=Id, serverTime=serverTime, securitytoken=securitytoken" 需要一个Java客户端程序来调用使用上述授权头这个REST
    java rest client consumer 2017-11-18

    0热度

    1回答

    分辩哪个队列在Apache的骆驼使用通配符时

    在我的申请，我正在使用Apache的骆驼通配符和我已经定义路线建设者这样叫： 从（“ActiveMQ的：队列：* processQueue”） .bean（beanOne “的someMethod”）; 虽然发送消息我会发短信给 “{} UNIQUEID .processQueue” 队列，所以我需要得到UNIQUEID内的someMethod的beanOne。
    java apache-camel activemq wildcard consumer 2017-08-11

    0热度

    1回答

    如何保护进程间生产者消费者消息传递机制免受因一方崩溃而导致的损坏？

    我在Windows上为一个生产者和一个消费者在共享内存中实现了一个进程间消息队列。 我使用一个命名信号量来算空槽，一个信号灯入选计数满插槽和一个命名的mutex来保护共享内存中的数据结构。 考虑，例如消费者方面。生产者方面是相似的。 首先它等待对充分旗语然后（1）它需要由互斥下的队列中的消息，然后它用信号空信号（2） 问题： 如果消费者进程在（1）和（2）之间崩溃，那么有效的进程可以使用的队列中的
    windows synchronization interprocess consumer producer 2017-08-15

    1热度

    2回答

    Kafka：多个独立消费者群体可以消费一个主题吗？

    很奇怪，我无法在网上轻松找到这些信息，但我无法。所以，我的问题是我有一个卡夫卡话题。我希望两个彼此独立的消费者组消费这个主题的消息。所以，我想要的是两个消费者群体都能够看到并消费彼此独立的所有消息。为了更加清楚，我不想让一个消费者组消费一些消息，并且一些消息被另一个消费组消费;不，我希望2个组消耗消息，就好像另一个组不存在一样。
    apache-kafka consumer 2017-10-04

    0热度

    1回答

    Pact JVM Java不清楚新手/启动器/教程项目？

    是否有一个小而简洁的jvm消费者Java（消费者或提供者）junit项目，有人可以共享，最好在一个包含所有文件的独立zip文件中，除了jar导入？ 当我按照例如这里的步骤：https://github.com/DiUS/pact-jvm/tree/master/pact-jvm-consumer-junit和“Using the base ConsumerPactTest”，我得到各种错误，我试图
    java junit jvm consumer pact 2017-10-09

    1热度

    1回答

    为什么在Tornado RequestHandler的__init__中调用的异步使用者的行为与静态调用的行为不同？

    我想使用每个处理程序的独特队列使用Tornado的异步服务器。当调用结束点时，作业被放入队列中。我有一个消费函数，它异步地从队列中“消耗”作业。但是，消费者的行为往往取决于我称之为self.consumer()还是AsyncHandler.consumer()。我最初的猜测是，这是因为实例级锁定，但无法找到证据。我连续发送4个帖子请求。这里是他们输出的2个片段。 import tornado.we
    python asynchronous tornado consumer 2017-10-21
最新问题