Kakfa安裝使用，springboot封裝

啟動

安裝配置完成，先啟動zookeeper然後後台啟動kakfa。

nohup bin/kafka-server-start.sh config/server.properties >>kafka.log &

partions和replication-factor引數的理解

# 建立 副本為1 分割槽為1 名為 test 的主題

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
# 檢視建立的主題
bin/kafka-topics.sh --list --zookeeper localhost:2181
# 刪除主題
bin/kafka-topics.sh --delete --zookeeper localhost:2181 --topic test
# 檢視test主題的詳細資訊
bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test
# 啟動乙個個訊息生產者
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
#啟動乙個訊息消費者
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

>

>
org.springframework.kafkagroupid
>
>
spring-kafkaartifactid
>
dependency
>

spring

:kafka
:# 指定kafka **位址，可以多個
bootstrap-servers
: 192.168.0.71:
9092
producer
:retries:0
# 每次批量傳送訊息的數量
batch-size
:16384
buffer-memory
:33554432

@component

public
class
kafkasender}.
..while
(true
)

kafka

:bootstrap-servers
: 192.168.0.71:
9092
group-id
: test-consumer-group

@configuration

@enablekafka
public
class
kafkaconsumerconfig")
private string bootstrapservers;
/** * the topic.
*/@value
("$"
)private string groupid;
@bean
public consume***ctory
consume***ctory()
@bean
public concurrentkafkalistenercontaine***ctory
kafkalistenercontaine***ctory()
}

@slf4j

@component
public
class
kafkaconsumer
}

Kakfa安裝部署

tar zxvf kafka安裝包 vi bash profile export kafka home 安裝包解壓位置 export path kafka home bin path 安裝kafka前提 jdkzookeeper 進入 kafka home conf 目錄 修改server.prop...

Kakfa概述及安裝過程

1.kafka是由linkedin 領英 開發的乙個分布式的訊息系統，最初是用作linkedin的活動流 activity stream 和運營資料處理的基礎 a.活動流資料報括頁面訪問量 page view 被檢視內容方面的資訊以及搜尋情況等內容。這種資料通常的處理方式是先把各種活動以日誌的形式寫...

安裝Spring外掛程式以及搭建Spring執行環境

1 安裝spring外掛程式 1 外掛程式包 springsource tool suite 3.4.0.release e4.3.1 updatesite.zip 2 操作步驟 參照 尚矽谷 參考資料 安裝springtools外掛程式.doc 2 搭建spring執行環境 加入jar包 spri...