進(jìn)程沒有重啟?應(yīng)該所有人的第一反應(yīng)就是這個,所以重啟進(jìn)行咯…
重啟進(jìn)程,盯日志…
發(fā)現(xiàn)請求發(fā)送到nginx的9000端口..這次應(yīng)該是對了…
緊接著出來建立鏈接 kafka1:9092,kafka2:9092,kafka3:9092
一臉懵逼,重啟依然是這樣…盯了一下nginx服務(wù)器的網(wǎng)絡(luò),最近幾天的帶寬太低了…
查找原因
基于以上問題,基本可以判斷。producer發(fā)送的數(shù)據(jù)絕對沒有通過nginx。查詢相關(guān)文檔發(fā)現(xiàn)。
Kafka無法把數(shù)據(jù)通過nginx代理方式進(jìn)行傳輸,而通過nginx的只有首次連接。producer節(jié)點通過nginx獲取到kafka的metadata信息。然后通過metadata里面的IP進(jìn)行訪問…
也就是說實際通過nginx的方式是這樣的,首次發(fā)送只是通過nginx獲取到metadata的信息,metadata包含kafka的broker各ip地址。然后producer則會直接把數(shù)據(jù)發(fā)送到kafka集群。
看完上述內(nèi)容,你們對Kafka數(shù)據(jù)中轉(zhuǎn)傳輸?shù)氖纠治鲇羞M(jìn)一步的了解嗎?如果還想了解更多知識或者相關(guān)內(nèi)容,請關(guān)注資訊頻道,感謝大家的支持。
更多關(guān)于云服務(wù)器,域名注冊,虛擬主機的問題,請訪問西部數(shù)碼官網(wǎng):m.ps-sw.cn