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
最新問題