多項選擇題在Kafka中，如下關(guān)于Producer發(fā)送數(shù)據(jù)的說法錯誤的是？（）

A.Producer負責(zé)生產(chǎn)數(shù)據(jù)，Consumer負責(zé)消費數(shù)據(jù)，Producer和Consumer之間需要建立Socket鏈接
B.Producer既可以發(fā)送數(shù)據(jù)到Broker上，又可以發(fā)送數(shù)據(jù)到Consumer上
C.Producer作為消息生產(chǎn)者，可以直接將數(shù)據(jù)寫入Zookeeper
D.Producer連接任意一個正常的Broker實例就可以生產(chǎn)數(shù)據(jù)


您可能感興趣的試卷

你可能感興趣的試題

1.多項選擇題在Solr的應(yīng)用查詢場景中，當(dāng)對查詢結(jié)果深度翻頁時，需使用游標進行深度翻頁。下面對游標說法正確的是？（）

A.必須對查詢字段進行排序
B.必須對uniqueKey字段進行排序
C.第一次查詢請求時，需指定查詢參數(shù)，操作方法如下，solrQuery.set（CursorMarkParams.CURSOR_MARK_PARAMCursorMarkParams.CURSOR_MARK_START）
D.查詢時，請求中不能帶有start參數(shù)，Solr的返回結(jié)果中會有nextCursorMark，在下次調(diào)動使用這個值為oursorMark

3.單項選擇題在Spark應(yīng)用開發(fā)中，以下哪項的代碼能正確進行單詞統(tǒng)計？（）

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（_+_）