近期，聽了王家林老師的2016年大數(shù)據(jù)Spark“蘑菇云”行動，需要將flume，kafka和Spark streaming進(jìn)行整合。感覺一時難以上手，先從簡單著手吧：

只為您設(shè)計(jì)更接底氣、較有營銷力的好網(wǎng)站，將營銷策劃與網(wǎng)頁設(shè)計(jì)互相結(jié)合的專業(yè)機(jī)構(gòu)，全網(wǎng)整合營銷推廣公司中較早掌握H5響應(yīng)式網(wǎng)站技術(shù)的機(jī)構(gòu)。一個好的品牌網(wǎng)站制作，不能只是一張名片，茫茫網(wǎng)海，想要快速吸引到您客戶的眼球，必須全方位的展現(xiàn)出企業(yè)突出的優(yōu)勢，以求達(dá)到主動營銷的效果，最終促成成交！

一、netcat方式+Logger日志顯示

Flume 配置文件如下：

# example.conf: A single-node Flume configuration

# Name the components on this agent
a1.sources = r1
a1.sinks = k1
a1.channels = c1

# Describe/configure the source
a1.sources.r1.type = netcat
a1.sources.r1.bind = localhost
a1.sources.r1.port = 44444

# Describe the sink
a1.sinks.k1.type = logger

# Use a channel which buffers events in memory
a1.channels.c1.type = memory
a1.channels.c1.capacity = 1000
a1.channels.c1.transactionCapacity = 100

# Bind the source and sink to the channel
a1.sources.r1.channels = c1
a1.sinks.k1.channel = c1

flume的啟動：

$ bin/flume-ng agent --conf conf --conf-file example.conf --name a1 -Dflume.root.logger=INFO,console

觸發(fā)數(shù)據(jù)：

telnet localhost 44444

會在flume的控制臺出現(xiàn)同樣的字符。

二、flume級聯(lián)方式

通過avro，在兩臺機(jī)器間傳送數(shù)據(jù)，源頭為netcat

當(dāng)前標(biāo)題：flume的幾種使用方式
新聞來源：http://chinadenli.net/article30/pijdso.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站制作、品牌網(wǎng)站設(shè)計(jì)、自適應(yīng)網(wǎng)站、全網(wǎng)營銷推廣、網(wǎng)站設(shè)計(jì)公司、網(wǎng)站改版

廣告

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