Java使用kafka發(fā)送消息沒有生效 kafka消費者java版本讀取不到消息怎么辦
一般消息發(fā)不出去很大可能都是配置或環(huán)境的問題
1、排查環(huán)境是否有問題，zookeeper節(jié)點是否存活，kafka節(jié)點是否存活，通過命令行的方式能否發(fā)出去消息（使用kafka-console-producer.sh）,如果通過命令行都發(fā)不出去那就是集群的問題了。
2、網(wǎng)絡(luò)問題，調(diào)用機器和集群之間網(wǎng)絡(luò)是否通暢
3、調(diào)用時配置的host、port和集群中配置的是否一致，是否需要使用主機名而不是ip
4、客戶端api版本是否和服務(wù)端差別太大導(dǎo)致不兼容
5、防火墻問題，關(guān)閉集群的防火墻實時
諸如此類，可能性太多就不一 一列舉了。
你這既然有打印堆棧，如果報錯肯定有異常信息的，可能卡住的時間比較長，耐心等待吧，祝你早日解決bug。
季朱15286052391： 多個topic怎么設(shè)置kafkaspout java例子 -
巴楚縣相貫： ______ +t)?＂1+2=幾.out:＂當然是; t=add(i,j).println(".println("public class j { static int add(int a,int b){ int s; s=a+b; System; } public static void main(String args[]){ int i=1,j=2; int t;); System; return s.out
季朱15286052391： c++怎么調(diào)用java的kafka接口 -
巴楚縣相貫： ______ 看Java源代碼,發(fā)現(xiàn)有些方法是空實現(xiàn),在方法前面有一個修飾詞 native ; 查閱得知 該方法就是Java程序調(diào)用底層的C接口,你可以向這方面入手找些資料做參考!
季朱15286052391： java socket服務(wù)器發(fā)送信息給指定的客戶端,在線等 -
巴楚縣相貫： ______ 2種方法:1、服務(wù)器主動發(fā)送時,客戶端也需要啟一個ServerSocket進行偵聽2、服務(wù)器被動發(fā)送時,客戶端發(fā)起連接請求詢問,服務(wù)器進行應(yīng)答
季朱15286052391： 這是一個線程,在服務(wù)器上,從客戶端發(fā)送消息到服務(wù)器,服務(wù)器這個程序處理 -
巴楚縣相貫： ______ 你沒明白 Socket 是一個全雙工通信,你一句它一句的模式只適合說完了就 close,不適合只 flush 不close 的情況.當下面情況出現(xiàn)時會死鎖:...
季朱15286052391： 數(shù)據(jù)為什么要由kafka傳送給分布式系統(tǒng) -
巴楚縣相貫： ______ 主要是為了數(shù)據(jù)的安全.因為分布式數(shù)據(jù)庫相當于單獨存在的個體,一旦發(fā)生意外也只影響到局部數(shù)據(jù)庫.另外,當數(shù)據(jù)傳送時,可以減輕中心服務(wù)器的壓力.具體的看下面: 分布式數(shù)據(jù)庫系統(tǒng)通常使用較小的計算機系統(tǒng),每臺計算機可單獨放在一個地方
季朱15286052391： 如何用Java實現(xiàn)服務(wù)器確認后客戶端才能發(fā)送下一條信息. -
巴楚縣相貫： ______ 1. Server代碼 package com.javacodegeeks.android.androidsocketserver; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.net.ServerSocket; import java.net.Socket; import android.app....
季朱15286052391： 定義一個Java手機接口,打電話,接電話,發(fā)短信,接受短信的功能 -
巴楚縣相貫： ______ public interface Calling param callPhoneNo 主叫號碼 * @param calledPhoneNo 被叫號碼 * @return 返回接電話成功失敗標識 *...
季朱15286052391： 想做一個用java發(fā)短信的程序 求大神解答 -
巴楚縣相貫： ______ 方法一:采用短信貓(適用小規(guī)模使用) 其實就是使用程序,想數(shù)據(jù)庫中指定表寫入短信內(nèi)容和手機號,即可 方法二:到電信局申請sp(使用大規(guī)模使用) 申請的時候,電信局會給你詳細的接口文檔
1、排查環(huán)境是否有問題，zookeeper節(jié)點是否存活，kafka節(jié)點是否存活，通過命令行的方式能否發(fā)出去消息（使用kafka-console-producer.sh）,如果通過命令行都發(fā)不出去那就是集群的問題了。
2、網(wǎng)絡(luò)問題，調(diào)用機器和集群之間網(wǎng)絡(luò)是否通暢
3、調(diào)用時配置的host、port和集群中配置的是否一致，是否需要使用主機名而不是ip
4、客戶端api版本是否和服務(wù)端差別太大導(dǎo)致不兼容
5、防火墻問題，關(guān)閉集群的防火墻實時
諸如此類，可能性太多就不一 一列舉了。
你這既然有打印堆棧，如果報錯肯定有異常信息的，可能卡住的時間比較長，耐心等待吧，祝你早日解決bug。
相關(guān)評說：
巴楚縣相貫： ______ +t)?＂1+2=幾.out:＂當然是; t=add(i,j).println(".println("public class j { static int add(int a,int b){ int s; s=a+b; System; } public static void main(String args[]){ int i=1,j=2; int t;); System; return s.out
巴楚縣相貫： ______ 看Java源代碼,發(fā)現(xiàn)有些方法是空實現(xiàn),在方法前面有一個修飾詞 native ; 查閱得知 該方法就是Java程序調(diào)用底層的C接口,你可以向這方面入手找些資料做參考!
巴楚縣相貫： ______ 2種方法:1、服務(wù)器主動發(fā)送時,客戶端也需要啟一個ServerSocket進行偵聽2、服務(wù)器被動發(fā)送時,客戶端發(fā)起連接請求詢問,服務(wù)器進行應(yīng)答
巴楚縣相貫： ______ 你沒明白 Socket 是一個全雙工通信,你一句它一句的模式只適合說完了就 close,不適合只 flush 不close 的情況.當下面情況出現(xiàn)時會死鎖:...
巴楚縣相貫： ______ 主要是為了數(shù)據(jù)的安全.因為分布式數(shù)據(jù)庫相當于單獨存在的個體,一旦發(fā)生意外也只影響到局部數(shù)據(jù)庫.另外,當數(shù)據(jù)傳送時,可以減輕中心服務(wù)器的壓力.具體的看下面: 分布式數(shù)據(jù)庫系統(tǒng)通常使用較小的計算機系統(tǒng),每臺計算機可單獨放在一個地方
巴楚縣相貫： ______ 1. Server代碼 package com.javacodegeeks.android.androidsocketserver; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.net.ServerSocket; import java.net.Socket; import android.app....
巴楚縣相貫： ______ public interface Calling param callPhoneNo 主叫號碼 * @param calledPhoneNo 被叫號碼 * @return 返回接電話成功失敗標識 *...
巴楚縣相貫： ______ 方法一:采用短信貓(適用小規(guī)模使用) 其實就是使用程序,想數(shù)據(jù)庫中指定表寫入短信內(nèi)容和手機號,即可 方法二:到電信局申請sp(使用大規(guī)模使用) 申請的時候,電信局會給你詳細的接口文檔
