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

A.Producer負責生產(chǎn)數(shù)據(jù),Consumer負責消費數(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的應用查詢場景中,當對查詢結(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應用開發(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(_+_)

5.單項選擇題Fiume支持實時采集數(shù)據(jù)的source類型是哪項?()

A.taildir
B.Log4j
C.JMS
D.Thrift

最新試題

Redis不適用與下面那些場景?()

題型:多項選擇題

關(guān)于Kafka的Producer,如下說法正確的是?()

題型:多項選擇題

Fusionlnsight HD關(guān)于Oozie的作業(yè)操作命令,下列哪幾項敘述是正確的?()

題型:多項選擇題

Fusionlnsigt HD的Hive組件可以運行在哪些分布式計算機框架上?()

題型:多項選擇題

用戶要開發(fā)一個應用去訪問HBase服務,先申請了一個機機賬號teste1,并給它設(shè)置訪問HBase服務的權(quán)限:然后下載該賬戶的keytab文件,并使用該賬號運行應用。后續(xù)此應用增加業(yè)務需求,需訪問Hive服務,那么在給tested用戶補充授予了訪問Hive組件權(quán)限后,需重新下載該用戶的keytab文件。()

題型:判斷題

在HBase表設(shè)計中,對于多項業(yè)務共用rowkey,導致數(shù)據(jù)訪問矛盾的情況,可以有哪些應對策略?()

題型:多項選擇題

在Kafka中,如下關(guān)于Producer發(fā)送數(shù)據(jù)的說法錯誤的是?()

題型:多項選擇題

Fiume支持實時采集數(shù)據(jù)的source類型是哪項?()

題型:單項選擇題

存在如下業(yè)務場景:用戶上網(wǎng)日志文件已經(jīng)存放在HDFS上,日志文件內(nèi)容格式是:每條上網(wǎng)記錄三個字段,分別是姓名,性別,上網(wǎng)時間,字段之間用“,”護分隔;要求打印輸出所有上網(wǎng)總時間大于兩小時的女性網(wǎng)友。請問如下哪些代碼片段能實現(xiàn)上述業(yè)務場景?()

題型:單項選擇題

在集群正常的情況下,Redis客戶端發(fā)起一次get調(diào)用,客戶端跟服務端有()次消息交互。

題型:單項選擇題