kafka集群測試正常,但是Java連接kafka出現異常,急求大神解答!!!_百度...

排查環境是否有問題，zookeeper節點是否存活，kafka節點是否存活，通過命令行的方式能否發出去消息（使用kafka-console-producer.sh），如果通過命令行都發不出去那就是集群的問題了。

成都地區優秀IDC服務器托管提供商(創新互聯建站).為客戶提供專業的四川聯通機房服務器托管,四川各地服務器托管,四川聯通機房服務器托管、多線服務器托管.托管咨詢專線：13518219792

只有在jdk9并且kafka版本在0.x之前的版本才會出現。

Broker：Kafka集群包含一個或多個服務器，這種服務器被稱為Broker。Kafka的整體架構如下圖所示，典型的Kafka集群包含一組發布消息的Producer，一組管理Topic的Broker，和一組訂閱消息的Consumer。

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

Java使用kafka發送消息沒有生效

1、很明顯是類型轉換錯誤。即Integer 類型不能轉成String類型。

2、在運行/調試設置中，編輯配置對話框中有“Main”這個選項卡，我們可以勾選“Stop in main”這個復選框。如果選中，那么在調試一個基于main方法的Java程序時，程序會在main方法第一行位置便停止執行。

3、啟動consumer之后就可以在console中看到producer發送的消息了 可以開啟兩個終端，一個發送消息，一個接受消息。如果這樣都不行的話，查看zookeeper進程和kafka的topic，一步步排查原因吧。

4、因此分區實際上是調優Kafka并行度的最小單元。

如何用Java向kafka發送json數據

示例中將向 test-topic 主題發送三條消息。消息消費者 和消息生產者類似，這里用 KafkaConsumer 類來創建一個消息消費者，該類的構造函數入參也是一系列屬性值。bootstrap. servers 和生產者一樣，表示 Kafka 集群。

排查環境是否有問題，zookeeper節點是否存活，kafka節點是否存活，通過命令行的方式能否發出去消息（使用kafka-console-producer.sh），如果通過命令行都發不出去那就是集群的問題了。

創建好topic之后，使用Java客戶端往kafka發消息，使用confluent client發也可以。

google提供的Genson是一個完全的Java和JSON轉換的類庫，提供了全面的數據綁定、流操作等。基于Apache 0協議發布。轉換結果為 JsonObject對象。

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

本文名稱：kafkajava代碼 kafka示例代碼
URL標題：http://vcdvsql.cn/article4/deiiiie.html

成都網站建設公司_創新互聯，為您提供網站收錄、網站內鏈、網站設計、靜態網站、外貿建站、App開發

廣告

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