spring-kafka

    -3熱度

    2回答

    我有一個用戶名[字符串],我想檢查給定用戶名的密碼。我會怎麼做?

    3熱度

    2回答

    幾次我用Spring Kafka API實現卡夫卡消費者與手動偏移管理: @KafkaListener(topics = "some_topic") public void onMessage(@Payload Message message, Acknowledgment acknowledgment) { if (someCondition) { acknowledgm

    0熱度

    1回答

    我正在使用春季卡夫卡1.0.3消費卡夫卡消息。 2在kafka中的主題和每個主題都有1個分區。 在java代碼中,有2個@KafkaListener消費每個主題消息。 ConcurrentKafkaListenerContainerFactory的併發性設置爲1.但消息有時會延遲20多秒。 @Configuration @EnableKafka public class KafkaConfig

    0熱度

    1回答

    我需要將導航麪包屑添加到SharePoint主頁面的幫助。 我已經在SharePoint Designer中打開了我的母版頁,並打開了麪包屑,但是這沒有達到我想要的效果。 我想要默認hello>This is >Me類型的麪包屑。 我該如何做到這一點?

    0熱度

    1回答

    我讓我的動物園管理員和3位卡夫卡經紀人在本地運行。 我開始了一個生產者和一個消費者。我可以看到消費者正在消費信息。 然後,我開始使用相同消費羣組名稱(不同端口,因爲它是一個春季啓動項目)的三個消費者。但我發現所有的消費者都在消費(接收)消息。但是我期望消息是負載均衡的,因爲只有消息不會在消費者中重複。我不知道問題是什麼。 這裏是我的屬性文件 spring.cloud.stream.bindings

    1熱度

    1回答

    我正在使用一個名爲Lyften Bloggie的組件在我的網站上建立了Joomla。但RSS提要存在問題。當我單擊Feed時,它將重新加載相同的博客頁面,並且不顯示任何內容。當我用Firebug檢查它時,它在網絡控制檯顯示301錯誤。我不知道發生了什麼。我在Joomla中禁用了SEF URL,同樣的問題仍然存在。當我在chrome中打開時,它顯示了Feed源,但是在Feed驗證器中它又顯示相同的3

    0熱度

    1回答

    我有一個生產者(Source)寫消息到卡夫卡輸出通道,該生產者發送不同類型的對象。在消費者方面(Sink)我想在同一個輸入通道上有多個@Streamlistener方法,每種方法具有不同的參數類型,目前它不工作我得到Duplicate @StreamListener mapping for 'input'。 這裏是我的消費者代碼: @StreamListener(Sink.INPUT) publ

    0熱度

    1回答

    使用int-kafka:出站通道適配器生成kafka時,似乎沒有可用的錯誤通道。在這種情況下,如何處理消息在reties時間後未能生成kafka? 任何可能導致卡夫卡故障的錯誤。 (下面的代碼只是代碼片斷互聯網,只是不知道如何處理錯誤給它添加) <int-kafka:outbound-channel-adapter id="kafkaOutboundChannelAdapter"

    1熱度

    2回答

    我試圖計算其存儲到哈希的引用的標量變量元素的數量進行計數的密鑰的數量: $result = $test->call($val); 我試圖keys %result,keys $result。但是這個失敗了。 我的理解是,$result是一個標量變量存儲引用匿名哈希,因爲 print "Test $results \n"; 給 Test YYY::ZZZ::AAA=HASH(0x1133d80

    2熱度

    1回答

    我剛開始在ExtJS Grid中潛水,我想創建一些工具欄搜索,如下面的JqGrid。網格將根據在該列中鍵入的鍵顯示結果。 任何人都可以給我看演練嗎?^_^ 在此先感謝您的任何答案。 jqgrid http://fbcdn-sphotos-a.akamaihd.net/hphotos-ak-ash4/379109_10150531271858928_704228927_8868872_1607857