kafka安裝教程 -- 單節點-單Broker叢集：只在一個節點上部署一個Broker
①安裝jdk： yum install java-1.8.0-openjdk.x86_64
②.去官網下載kafka_2.12-0.11.0.0.tgz
③.上傳檔案並解壓壓縮檔案到/opt目錄下
[[email protected] /]# tar -xvzf kafka_2.12-0.11.0.0.tgz -C /opt/④進入kafka的資料夾下（cd /opt/kafka_2.12-0.11.0.0） 啟動ZooKeeper
bin/zookeeper-server-start.sh config/zookeeper.properties 埠2181是ZooKeeper的預設埠，可以通過編輯檔案config/zookeeper.properties 中的clientPort來修改監聽埠。
⑤ 啟動Kafka Broker
bin/kafka-server-start.sh config/server.properties ⑥ 建立一個Topic 名稱為HelloWorld
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 \
> --partitions 1 --topic HelloWorld⑦校驗Topic是否建立成功
bin/kafka-topics.sh --list --zookeeper localhost:2181 ⑧ 啟動一個Producer併發送訊息
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic HelloWorld>hello world !
>How are you!
⑨ 啟動一個Consumer並接受訊息
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic HelloWorld接下來你就可以看到從producer哪裡發過來的訊息
如果報錯記憶體不足的話就去bin/kafka-server-start.sh檔案裡把引數修改掉
相關推薦
kafka安裝教程 -- 單節點-單Broker叢集：只在一個節點上部署一個Broker
①安裝jdk： yum install java-1.8.0-openjdk.x86_64 ②.去官網下載kafka_2.12-0.11.0.0.tgz ③.上傳檔案並解壓壓縮檔案到/opt目錄下 [[email protected] /]# tar -xv
hadoop全分散式叢集：配置主從節點之間的免密登入
要想實現主節點 對 從節點的管理： 需要配置主節點對從節點的免密登入。 **主節點hostname：vdevops 從節點hostname：test2 hadoop版本：2.8.2 主從節點可以相互通訊** 1.主節點中產生RSA金鑰 1.1
Linux 基礎：如何在Ubuntu上檢查一個軟體包是否安裝
https://linux.cn/article-5154-1.html 如果你正在管理Debian或者Ubuntu伺服器，你也許會經常使用dpkg 或者 apt-get命令。這兩個命令用來安裝、解除安裝和更新包。 在本篇中，讓我們看下如何在基於DEB的系統下檢查是否安裝
Kafka 單節點單Kafka Broker叢集
下載與安裝 $ tar zxvf kafka_2.12-0.10.2.1.tgz $ cd kafka_2.12-0.10.2.1 執行 啟動 zookeeper 服務 $ bin/zookeeper-server-start.sh
hadoop安裝，並配置單節點hadoop叢集
前言：本文以申威伺服器raise系統為例，安裝部署hadoop-2.7.3 一、安裝Java 在安裝 hadoop 之前，請確保你的系統上安裝了 Java。使用java -version命令檢查已安裝 Java 的版本。 申威raise系統中預設安裝Java1.7版本，安裝路徑
Dubbo註冊中心安裝教程（單節點）
Dubbo建議使用Zookeeper作為服務的註冊中心。 註冊中心伺服器（192.168.3.71）配置，安裝Zookeeper: 1、 修改作業系統的/etc/hosts檔案中新增： # zookeeper servers 192.168.3.71 shop-
華為雲端計算——FusionCompute單節點部署詳細安裝教程（二）VRM的安裝
FusionCompute由兩部分組成 CNA(Computing Node Agent)計算節點代理 VRM( Virtualization Resource Management) 虛擬化資源管理功能 1. 實驗前提
Apache Spark漸進式學習教程(三): Spark單節點安裝和快速入門Demo
一，下載Spark 使用 Spark 的第一步是下載和解壓縮。我們先從下載預編譯版本的 Spark 開始。訪問 ht
Redis 的安裝與使用（單節點）
方式 ase kcon $path 配置文件 alt png ces 一個 Redis 的安裝與使用（單節點） 環境：CentOS 6.5 Redis 版本：redis-3.0 （考慮到Redis3.0 在集群和性能提升方面的特性，rc 版為正式版的候選版
分布式架構實戰--ActiveMQ的安裝與使用（單節點）
解壓 rain fin admins blank 生產者 new 安裝配置 節點 具體內容請參考樣例代碼和視頻教程： http://www.roncoo.com/course/view/85d6008fe77c4199b0cdd2885eaeee53 IP:192.16
Redis的安裝與使用（單節點）
做了 imp redis3.0 修改 .gz 環境 red redis配置 $1 IP：192.168.4.111 環境：CentOS 6.6 Redis版本：redis-3.0 （考慮到Redis3.0在集群和性能提升方面的特性，rc版為正式版的候選版，而且很快就出正
ActiveMQ 的安裝與使用（單節點）
環境：CentOS6.6、JDK8 1.下載：http://archive.apache.org/dist/activemq/5.11.1/apache-activemq-5.11.1-bin.tar.gz 2、 安裝 JDK 並配置環境變數（略） 3、 下載或上傳 Linux 版的 ActiveMQ（
centos7下安裝elasticSearch錯誤總結(單節點模式)
1、首先確定你安裝了jdk，版本需要1.8以上 2、上傳elasticsearchjar包，只需配置一個檔案即可 修改配置檔案config/elasticsearch.yml network.host: 192.168.100.211 3、啟動測試
單硬碟win10+ubuntu雙系統安裝教程
以下經驗純屬個人總結，參考了網上許多大佬，尤其是知乎的一個回答 https://www.zhihu.com/question/52092661 ，答主Wenyin Root的內容。 首先要說明，此教程針對以win10作為主系統，ubuntu作為次系統的情況， 並且
Jedis操作單節點redis，叢集及redisTemplate操作redis叢集（三）
package com.dream21th.dream21thredis.controller;import java.util.List;import java.util.Map;import org.springframework.beans.factory.annotation.Autowired;im
三節點單控Pike按照官方安裝+ceph整合
####安照官網安裝 ###主機資訊 13.13.59.11 controller 13.13.59.12 compute1 13.13.59.24 ceph24### 都做bond bond 模式為bond0 ### 網路 採用selfService
Redis之——Redis 的安裝與使用（單節點）
IP： 192.168.50.132 環境： CentOS 6.5 Redis 版本： redis-3.2.18 安裝目錄： /usr/local/redis 使用者： root 一、編譯和安裝所需的包 yum -y install wget gcc-c++ ncurs
activemq使用系列: linux環境下ActiveMQ 的安裝與使用（單節點）
1、 安裝 JDK 並配置環境變數（略） 2 下載 Linux 版的 ActiveMQ <span style="white-space:pre"> </span>wget http://apache.fayea.com/activemq/5.
FastDFS分散式檔案系統安裝與使用（單節點）
FastDFS是由淘寶的餘慶先生所開發，是一個輕量級、高效能的開源分散式檔案系統，用純C語言開發，包括檔案儲存、檔案同步、檔案訪問（上傳、下載）、存取負載均衡、線上擴容、相同內容只儲存一份等功能，適合有大容量儲存需求的應用或系統。做分散式系統開發時，其中要解
Jedis操作單節點redis，叢集及redisTemplate操作redis叢集（二）
package com.dream21th.dream21thredis.redis;import java.util.List;import java.util.Map;import java.util.Set;import com.dream21th.dream21thredis.key.KeyPrefi