kafka集群測(cè)試正常,但是Java連接kafka出現(xiàn)異常,急求大神解答!!!_百度...

排查環(huán)境是否有問(wèn)題，zookeeper節(jié)點(diǎn)是否存活，kafka節(jié)點(diǎn)是否存活，通過(guò)命令行的方式能否發(fā)出去消息（使用kafka-console-producer.sh），如果通過(guò)命令行都發(fā)不出去那就是集群的問(wèn)題了。

成都地區(qū)優(yōu)秀IDC服務(wù)器托管提供商(創(chuàng)新互聯(lián)建站).為客戶(hù)提供專(zhuān)業(yè)的四川聯(lián)通機(jī)房服務(wù)器托管,四川各地服務(wù)器托管,四川聯(lián)通機(jī)房服務(wù)器托管、多線(xiàn)服務(wù)器托管.托管咨詢(xún)專(zhuān)線(xiàn)：13518219792

只有在jdk9并且kafka版本在0.x之前的版本才會(huì)出現(xiàn)。

Broker：Kafka集群包含一個(gè)或多個(gè)服務(wù)器，這種服務(wù)器被稱(chēng)為Broker。Kafka的整體架構(gòu)如下圖所示，典型的Kafka集群包含一組發(fā)布消息的Producer，一組管理Topic的Broker，和一組訂閱消息的Consumer。

1 啟動(dòng)zookeeper 啟動(dòng)zk有兩種方式，第一種是使用kafka自己帶的一個(gè)zk。bin/zookeeper-server-start.sh config/zookeeper.properties& 另一種是使用其它的zookeeper，可以位于本機(jī)也可以位于其它地址。

Java使用kafka發(fā)送消息沒(méi)有生效

1、很明顯是類(lèi)型轉(zhuǎn)換錯(cuò)誤。即Integer 類(lèi)型不能轉(zhuǎn)成String類(lèi)型。

2、在運(yùn)行/調(diào)試設(shè)置中，編輯配置對(duì)話(huà)框中有“Main”這個(gè)選項(xiàng)卡，我們可以勾選“Stop in main”這個(gè)復(fù)選框。如果選中，那么在調(diào)試一個(gè)基于main方法的Java程序時(shí)，程序會(huì)在main方法第一行位置便停止執(zhí)行。

3、啟動(dòng)consumer之后就可以在console中看到producer發(fā)送的消息了 可以開(kāi)啟兩個(gè)終端，一個(gè)發(fā)送消息，一個(gè)接受消息。如果這樣都不行的話(huà)，查看zookeeper進(jìn)程和kafka的topic，一步步排查原因吧。

4、因此分區(qū)實(shí)際上是調(diào)優(yōu)Kafka并行度的最小單元。

如何用Java向kafka發(fā)送json數(shù)據(jù)

示例中將向 test-topic 主題發(fā)送三條消息。消息消費(fèi)者 和消息生產(chǎn)者類(lèi)似，這里用 KafkaConsumer 類(lèi)來(lái)創(chuàng)建一個(gè)消息消費(fèi)者，該類(lèi)的構(gòu)造函數(shù)入?yún)⒁彩且幌盗袑傩灾?。bootstrap. servers 和生產(chǎn)者一樣，表示 Kafka 集群。

排查環(huán)境是否有問(wèn)題，zookeeper節(jié)點(diǎn)是否存活，kafka節(jié)點(diǎn)是否存活，通過(guò)命令行的方式能否發(fā)出去消息（使用kafka-console-producer.sh），如果通過(guò)命令行都發(fā)不出去那就是集群的問(wèn)題了。

創(chuàng)建好topic之后，使用Java客戶(hù)端往kafka發(fā)消息，使用confluent client發(fā)也可以。

google提供的Genson是一個(gè)完全的Java和JSON轉(zhuǎn)換的類(lèi)庫(kù)，提供了全面的數(shù)據(jù)綁定、流操作等?；贏(yíng)pache 0協(xié)議發(fā)布。轉(zhuǎn)換結(jié)果為 JsonObject對(duì)象。

kafka發(fā)出消息和接收消息都是基于topic，所以要先創(chuàng)建一個(gè)topic，才能向里面發(fā)消息。創(chuàng)建topic的腳本：topic創(chuàng)建好了，就可以向里邊發(fā)送消息了。

本文名稱(chēng)：kafkajava代碼 kafka示例代碼
URL標(biāo)題：http://chinadenli.net/article4/deiiiie.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站收錄、網(wǎng)站內(nèi)鏈、網(wǎng)站設(shè)計(jì)、靜態(tài)網(wǎng)站、外貿(mào)建站、App開(kāi)發(fā)

廣告

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