10026---Kafka詳解二、如何配置Kafka叢集

阿新 • • 發佈：2019-02-08

Kafka叢集配置比較簡單，為了更好的讓大家理解，在這裡要分別介紹下面三種配置
單節點：一個broker的叢集
單節點：多個broker的叢集
多節點：多broker叢集

一、單節點單broker例項的配置

1. 首先啟動zookeeper服務

Kafka本身提供了啟動zookeeper的指令碼（在kafka/bin/目錄下）和zookeeper配置檔案（在kafka/config/目錄下），首先進入Kafka的主目錄（可通過 whereis kafka命令查詢到）：

 [[email protected] kafka-0.8]# bin/zookeeper-server-start.sh config/zookeeper.properties

zookeeper配置檔案的一些重要屬性:

     # Data directory where the zookeeper snapshot is stored.
     dataDir=/tmp/zookeeper
     # The port listening for client request
     clientPort=2181

預設情況下，zookeeper伺服器會監聽 2181埠，更詳細的資訊可去zookeeper官網查閱。

2. 啟動Kafka broker

執行kafka提供的啟動kafka服務指令碼即可：
[[email protected]

kafka-0.8]# bin/kafka-server-start.sh config/server.properties
broker配置檔案中的重要屬性：

     # broker的id. 每個broker的id必須是唯一的.
     Broker.id=0
     # 存放log的目錄
     log.dir=/tmp/kafka8-logs
     # Zookeeper 連線串
     zookeeper.connect=localhost:2181

3. 建立一個僅有一個Partition的topic

  bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic kafkatopic

4. 用Kafka提供的生產者客戶端啟動一個生產者程序來發送訊息

 [[email protected] kafka-0.8]# bin/kafka-console-producer.sh --broker-list localhost:9092 --topic kafkatopic

其中有兩個引數需要注意：
broker-list:定義了生產者要推送訊息的broker地址，以<IP地址:埠>形式
topic：生產者傳送給哪個topic
然後你就可以輸入一些訊息了，如下圖：

10026---Kafka詳解二、如何配置Kafka叢集

原文 Kafka叢集配置比較簡單，為了更好的讓大家理解，在這裡要分別介紹下面三種配置單節點：一個broker的叢集單節點：多個broker的叢集多節點：多broker叢集一、單節點單broker例項的配置 1. 首先啟動zookeeper服務 Kafka本身提供

kafka詳解三：開發Kafka應用

問題導讀1.Kafka系統由什麼組成？2.Kafka中和producer相關的API是什麼？一、整體看一下Kafka我們知道，Kafka系統有三大元件：Producer、Consumer、broker 。 file:///C:/Users/ADMINI~1/AppData/

Kafka 詳解（二）------集群搭建

需要 kafka ast enter 安裝過程簡單 keep 三臺 sof 　　這裏通過 VMware ，我們安裝了三臺虛擬機，用來搭建 kafka集群，虛擬機網絡地址如下：　　　hostname ipaddress

Kafka 詳解（二）------叢集搭建

　　這裡通過 VMware ，我們安裝了三臺虛擬機器，用來搭建 kafka叢集，虛擬機器網路地址如下：　　　hostname ipaddress &nbs

Kafka概念和關於springboot配置Kafka引數詳解

1.基本概念 *Producer: 訊息生產者，往Topic釋出訊息 *Consumer: 訊息消費者，往Topic取訊

JAVAWEB開發之mybatis詳解(二)——高階對映、查詢快取、mybatis與Spring整合以及懶載入的配置和逆向工程

<?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE generatorConfiguration PUBLIC "-//mybatis.org//DTD MyBatis Generator Configuration 1.0//EN" "ht

大數據入門第十七天——storm上遊數據源之kafka詳解（一）入門

不同這也接受 blog 存儲發送 records ant post 一、概述　　1.kafka是什麽　　　　根據標題可以有個概念：kafka是storm的上遊數據源之一，也是一對經典的組合，就像郭德綱和於謙　　　　根據官網：http://kafka.apa

虛擬機網絡配置詳解(NAT、橋接、Hostonly)

dev 設置包括 gem f11 key 註意 box ccf VirtualBox中有四種網絡連接方式: NAT Bridged Adapter Internal Host-only Adapter VMWare中有三種，其實它跟VMWare的網絡連接方式都是一樣的

Java併發（十八）：阻塞佇列BlockingQueue BlockingQueue（阻塞佇列）詳解二叉堆(一)之圖文解析和 C語言的實現多執行緒程式設計：阻塞、併發佇列的使用總結 Java併發程式設計：阻塞佇列 java阻塞佇列 BlockingQueue（阻塞佇列）詳解

阻塞佇列（BlockingQueue）是一個支援兩個附加操作的佇列。這兩個附加的操作是：在佇列為空時，獲取元素的執行緒會等待佇列變為非空。當佇列滿時，儲存元素的執行緒會等待佇列可用。阻塞佇列常用於生產者和消費者的場景，生產者是往佇列裡新增元素的執行緒，消費者是從佇列裡拿元素的執行緒。阻塞佇列就是生產者

10026---Kafka詳解二、如何配置Kafka叢集

一、單節點單broker例項的配置

1. 首先啟動zookeeper服務

2. 啟動Kafka broker

3. 建立一個僅有一個Partition的topic

4. 用Kafka提供的生產者客戶端啟動一個生產者程序來發送訊息

10026---Kafka詳解二、如何配置Kafka叢集

kafka詳解三：開發Kafka應用

Kafka 詳解（二）------集群搭建

Kafka 詳解（二）------叢集搭建

Kafka概念和關於springboot配置Kafka引數詳解

JAVAWEB開發之mybatis詳解(二)——高階對映、查詢快取、mybatis與Spring整合以及懶載入的配置和逆向工程

大數據入門第十七天——storm上遊數據源之kafka詳解（一）入門

虛擬機網絡配置詳解(NAT、橋接、Hostonly)

Java併發（十八）：阻塞佇列BlockingQueue BlockingQueue（阻塞佇列）詳解二叉堆(一)之圖文解析和 C語言的實現多執行緒程式設計：阻塞、併發佇列的使用總結 Java併發程式設計：阻塞佇列 java阻塞佇列 BlockingQueue（阻塞佇列）詳解

互斥量、條件變數與pthread_cond_wait()函式的使用，詳解(二)

B族樹詳解(二叉搜尋樹、B-樹、B+樹、B*樹)

logback 配置詳解—logger、root

Elasticsearch增、刪、改、查操作深入詳解(二)

詳解二維陣列與指標、指標陣列、陣列指標

java實現標準化考試系統詳解(二)-----資料庫、資料表的規劃和題庫增刪改查

FastDFS的配置、部署與API使用解讀（4）FastDFS配置詳解之Client配置

kafka入門：簡介、使用場景、設計原理、配置及叢集搭建

流式計算--Kafka詳解

【STM庫應用】stm32 之 TIM （詳解二脈衝寬度、週期測量）

Kafka詳解安裝

10026---Kafka詳解二、如何配置Kafka叢集

一、單節點單broker例項的配置

1. 首先啟動zookeeper服務

2. 啟動Kafka broker

3. 建立一個僅有一個Partition的topic

4. 用Kafka提供的生產者客戶端啟動一個生產者程序來發送訊息

相關推薦