Java操作Kafka執行不成功

使用kafka-clients操作kafka始終不成功，原因不清楚，下面貼出相關程式碼及配置，請懂得指點一下，謝謝! 環境及依賴{代碼...} JDK版本為1.8、Kafka版本為2.12-0.10. 2.0，伺服器使用CentOS-7建置。 測試程式碼 TestBa...

伊谢尔伦 2017-04-18 10:55:11 0  2  1311

java - kafka不能連接寫入

遠端呼叫生產者寫入資料時報錯誤如下 ERROR Error when sending message to topic test with key: null, value: 6 bytes with error: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback) kafka本...

世界只因有你 2017-06-15 09:21:24 0  1  947

php操作kafka怎麼實現延時佇列

如題：php操作kafka怎麼實作延時佇列我知道java能實作該延時佇列，但是我想了解如果使用php能不能實作相同的功能

U2  2022-09-15 16:12:34 0  0  749

nginx - 如何將lua目錄下的檔案（`kafka/*`）全部引入環境裡面?

請教個問題：如何將lua目錄下的檔案（kafka/*）全部引入環境裡面？只知道下面這種方法 {程式碼...}

伊谢尔伦 2017-05-16 17:08:17 0  1  849

java - 如何查看或模擬kafka producer裡的retries（重試）配置的過程呢？

如題，我設定了kafka-producer裡的retries=3,那如何才能看到他的重試過程呢，也沒看到任何的系統日誌什麼的？

ringa_lee 2017-04-18 10:54:22 0  1  634

如何使用 php 函式庫從 Kafka 取得主題中的最後一個偏移量？

我正在使用php-rdkafka庫為API專案編寫Kafka消費者。我需要找到主題中的最後一個偏移量並從中獲取值以進行進一步處理。例如，主題中的最後一個偏移量=5，那麼我需要取得偏移量5並透過API發送它，直到新增新的偏移量。我正在嘗試運行的內容：$conf=newRdKafka\Conf();$settings=['socket.keepalive.enable'=>true,'log_l

P粉763662390 2023-09-10 11:00:45 0  1  691

如何用Java向kafka發送json數據

在網路上都只看到一些Java生產STRING類型的消息。依照Java的producer類別來看，是可以自訂傳送訊息的類型，例如 producer.send(new KeyedMessage<String, HashMap<String , String>>(topic,message); ...

我想大声告诉你 2017-05-17 10:05:08 0  1  1321

java - kafka中partition設計的優點是什麼？

提高並發寫入嗎？磁碟io同一時刻只能寫入一個檔案吧?提高並發讀取嗎？磁碟io同一時刻只能讀取一個檔案吧？提高單次寫入速度嗎？貌似跟partiton沒啥關係吧？提高單次讀取速度嗎？多segment不就解決了？

滿天的星座 2017-06-23 09:13:28 0  1  1209

java - Kafka:如果訊息的保存策略被設定為2天，那麼在一個訊息被發布的兩天時間內，它都是可以被消費的。之後它將被丟棄以釋放空間。

這句話是指訊息在兩天後被丟棄以釋放空間，還是指訊息被消費之後，就釋放空間？

为情所困 2017-05-17 10:05:57 0  1  788

java - springboot新手學習

各位大神們 有沒有系統的學習springboot的資料和代碼可以推薦一下和給一下連結嗎？在GitHub上和百度上的學習資料特別零散 謝謝啦~~

天蓬老师 2017-04-18 10:53:17 0  3  621

spring - JavaWeb中 Service 層的事務問題

下面是我的Spring配置 透過上面的配置可以看出我是在所有的service中加入的事物，也就是說我的service出錯了會回滾所有的提交。那如果遇到Aservice呼叫Bservice的方法，然後Bservice呼叫了Cservice層的方法，A-...

PHP中文网 2017-04-18 10:53:17 0  3  577

java - wait()，notify(),notifyAll() T2 start! T2 end! T1 start! 為什麼會阻塞

{代碼...}

PHP中文网 2017-04-18 10:53:24 0  2  1005

java - C語言演算法題-韓信點兵 解法？

完全不知道怎麼下手??

高洛峰 2017-04-18 10:53:25 0  2  736

java - 使用DDMS分析記憶體發現系統中inactive佔比重很大，這是什麼啊，有辦法對他進行GC嗎

使用DDMS分析記憶體發現系統中inactive佔比重很大，這是什麼啊，有辦法對他進行GC嗎

阿神 2017-04-18 10:53:25 0  1  565

java - 如何寫一個intellij-idea插件，實現編譯時修改原始碼的目的

例如下面這段Java原始碼： {程式碼...} 我希望IDEA編譯後運行，輸出的是具體的電腦名，也就是說，在哪台機器編譯，就輸出哪一台。例如我是在a-pc這台電腦上編譯的，就輸出顯示a-pc。 這個怎麼寫插件實作呢？ PS:1、原始碼...

巴扎黑 2017-04-18 10:53:26 0  3  871

java - SSH專案整合JBPM4.4出現空指標異常

問題現象伺服器啟動不報錯。進行訪問專案時候報出空指標異常 看到這個報錯，我無法定位到具體那裡寫錯了。請教一下各位這個錯誤該如何解決呢？ 開發環境：struts2+hibernate3+spring3; tomcat8; MyEclipse2014+JD...

怪我咯 2017-04-18 10:53:27 0  0  511

java中傳回一個對象，和輸出對象的值，意義在哪裡

例如圖上的return f；這個有什麼意義，

高洛峰 2017-04-18 10:53:28 0  2  594

java - 按鈕效果實作方法？

請問各位那個簽到的按鈕是怎麼做出來的（背景透明但是外圍有一圈不透明的環繞線）。

PHP中文网 2017-04-18 10:53:30 0  2  598

java - List<List<model>>如何更快的取裡面的model？

{代碼...}

PHP中文网 2017-04-18 10:53:31 0  5  664

java - 金融產品中的模組（預付卡池）的設計（資料庫的設計，以及程式碼的設計模式）

金融產品產品的預付卡池，例如針對發行10000張卡（類似與遊戲點卡，但一張卡可以不用完，卡採用不記名方式，用完卡就失效），請問一下數據庫的表的設計有什麼好的建議，以及在程式碼中實現的設計模式的建議，各位大...

怪我咯 2017-04-18 10:53:32 0  0  664