前言
本文講如何安裝啟動kafka,並進行測試，其中zookeepr是kafka自帶的，本文基本按照官網文件進行安裝啟動的，並提出可能會出現的問題。官方文件：http:/
2、解壓到指定目錄
tar -xzf kafka_2.11-1.1.0.tgz -c /opt/
3、修改配置檔案：
vim server.properties vim consumer.properties
3.1 server.proptises檔案 搜尋 listeners關鍵字，新增ip位址。
3.2 server.proptises檔案 搜尋 zookeeper.connect 新增ip位址。
3.3 vim consumer.properties
group
.id與配置檔案中的一致
3、啟動服務
kafka_2.11-2.3.0 路徑下
啟動zook:
bin/zookeeper-server-
start
.sh -daemon config/zookeeper.properties
ps-ef |grep zook
啟動kafka:
bin/kafka-server-
start
.sh -daemon config/server.properties -daemon
ps-ef |grep kafka
4、建立
1.建立分割槽主題
bin/kafka-topics.sh --create --zookeeper 192.168.1.157:2181 --replication-factor 1 --partitions 1 --topic test-consumer-
group
2.通過list topic命令檢視所有的主題
bin/kafka-topics.sh --list --zookeeper 192.168.1.157:2181
5、修改服務配置檔案
kafka:
producer:
retries: 123
batchsize: 16384
buffermemory: 33554432
keyserializer: org.apache.kafka.common.serialization.stringserializer
valueserializer: org.apache.kafka.common.serialization.stringserializer
bootstrapservers: 192.168.1.157:9092
topic: test-consumer-
group
isenable: false
consumer:
bootstrapservers: 192.168.1.157:9092
groupid: test
autooffsetreset: earliest
enableautocommit: true
autocommitinterval: 1000
keydeserializer: org.apache.kafka.common.serialization.stringdeserializer
valuedeserializer: org.apache.kafka.common.serialization.stringdeserializer
topics: test-consumer-
group
安裝啟動kafka
vim kafka config server.properties 確保唯一 broker.id 0 允許刪除主題 delete.topic.enable true 指定資料檔案所在目錄 log.dirs var local kafka logs zookeeper 的連線位址 zookeeper...
Kafka安裝部署啟動
解壓安裝包 tar zxvf opt software kafka 2.11 2.4.1.tgz c opt module 修改解壓後的檔名稱 mv opt module kafka 2.11 2.4.1 opt module kafka在 opt module kafka目錄下建立logs資料夾 ...
kafka 安裝,使用教程
記錄一下，安裝過程 風來了.fox 這裡選擇當前最新版 2016 09 07 scala 2.11 kafka 2.11 0.10.0.1.tgz asc,md5 wget tsinghua edu cn apache kafka 0.10 0.1 kafka 2.11 0.10 0.1 tgzta...