flume 在配置source 訪問(wèn)netcat 的時(shí)候，java怎么創(chuàng)建socket發(fā)送數(shù)據(jù)給netcat接收

etcat-0.7.1.tar.gz 然后當(dāng)然是解壓了 tar zxvf netcat-0.7.1.tar.gz 解壓完畢之后會(huì)生成目錄，要cd進(jìn)去 cd netcat-0.7.1 然后進(jìn)行編譯前的配置。 ./configure 配置完了之后就可以make編譯了。 編譯成功就生成了netcat可執(zhí)行的文件了

創(chuàng)新互聯(lián)公司是一家專(zhuān)業(yè)提供榆樹(shù)企業(yè)網(wǎng)站建設(shè),專(zhuān)注與網(wǎng)站制作、網(wǎng)站建設(shè)、html5、小程序制作等業(yè)務(wù)。10年已為榆樹(shù)眾多企業(yè)、政府機(jī)構(gòu)等服務(wù)。創(chuàng)新互聯(lián)專(zhuān)業(yè)網(wǎng)站制作公司優(yōu)惠進(jìn)行中。

flume-ng的數(shù)據(jù)傳輸功能怎么通過(guò)java代碼的形式進(jìn)行實(shí)現(xiàn)

TCP傳輸需要建立客戶(hù)端和服務(wù)器端，即Socket和Server Socket ， 建立連接后，通過(guò)Socket中的IO流進(jìn)行數(shù)據(jù)的傳輸 。傳輸結(jié)束后關(guān)閉Socket。

客戶(hù)端和服務(wù)器端是兩個(gè)獨(dú)立的應(yīng)用程序。

在flume中采集數(shù)據(jù)時(shí)，stop后，在start重新采集，出現(xiàn)java.io.IOException: Write error？

你好，不知道你stop的時(shí)候有沒(méi)有把相應(yīng)的IO或者句柄關(guān)掉？

最好把代碼貼出來(lái)看下！

求助flume + kafka 異常 java.nio.BufferUnderflowException

求助flume + kafka 異常 java.nio.BufferUnderflowException

緩沖的長(zhǎng)度不匹配，，，，，，，，，使用短緩沖，接收/處理 長(zhǎng)緩沖

框架處理原理分析：可以根據(jù)實(shí)際情況，設(shè)置buffersize的大小，讓buffersize處在平均略高的狀態(tài)下工作，節(jié)省由于初始設(shè)置過(guò)大，而浪費(fèi)內(nèi)存。

解決方案：

1，最簡(jiǎn)單的修改框架原碼。將其中的NioSocketSession類(lèi)重寫(xiě)即可，里面有TransportMetadata創(chuàng)建的地方修改。

2，通過(guò)對(duì)斷包或粘包的處理。

當(dāng)前題目：flume的java代碼,flume java
轉(zhuǎn)載來(lái)于：http://www.rwnh.cn/article22/dsigecc.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供微信公眾號(hào)、、軟件開(kāi)發(fā)、App開(kāi)發(fā)、企業(yè)建站、網(wǎng)站建設(shè)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶(hù)投稿、用戶(hù)轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)