A.Producer負(fù)責(zé)生產(chǎn)數(shù)據(jù)，Consumer負(fù)責(zé)消費(fèi)數(shù)據(jù)，Producer和Consumer之間需要建立Socket鏈接
B.Producer既可以發(fā)送數(shù)據(jù)到Broker上，又可以發(fā)送數(shù)據(jù)到Consumer上
C.Producer作為消息生產(chǎn)者，可以直接將數(shù)據(jù)寫(xiě)入Zookeeper
D.Producer連接任意一個(gè)正常的Broker實(shí)例就可以生產(chǎn)數(shù)據(jù)
您可能感興趣的試卷
你可能感興趣的試題
A.必須對(duì)查詢字段進(jìn)行排序
B.必須對(duì)uniqueKey字段進(jìn)行排序
C.第一次查詢請(qǐng)求時(shí)，需指定查詢參數(shù)，操作方法如下，solrQuery.set（CursorMarkParams.CURSOR_MARK_PARAMCursorMarkParams.CURSOR_MARK_START）
D.查詢時(shí)，請(qǐng)求中不能帶有start參數(shù)，Solr的返回結(jié)果中會(huì)有nextCursorMark，在下次調(diào)動(dòng)使用這個(gè)值為oursorMark
A.valcounts=textFile.map（line=>line.split（“”））.map（-rd=>（word，1））.reduceByKey（_+_）
B.valcounts=textFile.flatMap（line=>line.split（“”））.map（word=>（word，1））.reduceByKey（_+_）
C.valcounts=textFile.map（line=>line.split（“”））.map（word=>（word，1））.groupByKey（_+_）
D.valcounts=textFile.flatMap（line=>line.split（“”））.map（word=>（word，1））.groupByKey（_+_）
A.taildir
B.Log4j
C.JMS
D.Thrift
最新試題
在Kafka中，關(guān)于Consumer說(shuō)法正確的是（）。
Fusionlnsight HD大數(shù)據(jù)平臺(tái)提供了哪些分布式計(jì)算框架？（）
Fiume支持實(shí)時(shí)采集數(shù)據(jù)的source類(lèi)型是哪項(xiàng)？（）
在Spark應(yīng)用開(kāi)發(fā)中，以下哪項(xiàng)的代碼能正確進(jìn)行單詞統(tǒng)計(jì)？（）
在通過(guò)Fusionlnsight manager界面創(chuàng)建用戶時(shí)，想要該用戶對(duì)所有Topic具有讀寫(xiě)權(quán)限，但不具有常見(jiàn)Topic的權(quán)限，應(yīng)該加入Kafka服務(wù)的那個(gè)組？（）
FusionLnsigh HD，Oozie支持HDFS Action。（）
在MapReduce應(yīng)用程序開(kāi)發(fā)中，setMapOutputCompressorClass類(lèi)的作用是什么？（）
Fusionlnsight HD中，一個(gè)部署在Tomcat上的應(yīng)用，需訪問(wèn)HBase服務(wù)，這種場(chǎng)景下推薦使用機(jī)機(jī)賬號(hào)。（）
關(guān)于Kafka的Producer，如下說(shuō)法正確的是？（）
在Kafka中，如下關(guān)于Producer發(fā)送數(shù)據(jù)的說(shuō)法錯(cuò)誤的是？（）