kafaka之简单安装

本文一起来看下在Linux环境如何安装单机版的卡夫卡，用于测试之用，下面我们就开始吧！

在这里 下载，然后tar -zxf 解压，如下是我本地的解压目录：

[root@localhost kafka]# pwd
/usr/local/study/kafka
[root@localhost kafka]# ls
kafka_2.11-2.2.1

修改server.properties，修改broker-id，以及日志目录：

broker.id=1
log.dir=/data/kafka/logs-1

/usr/local/study/kafka/kafka_2.11-2.2.1/bin/zookeeper-server-start.sh -daemon /usr/local/study/kafka/kafka_2.11-2.2.1/config/zookeeper.properties

/usr/local/study/kafka/kafka_2.11-2.2.1/bin/kafka-server-start.sh /usr/local/study/kafka/kafka_2.11-2.2.1/config/server.properties

• 创建主题

[root@localhost logs]# /usr/local/study/kafka/kafka_2.11-2.2.1/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
Created topic test.

• 查看主题

[root@localhost logs]# /usr/local/study/kafka/kafka_2.11-2.2.1/bin/kafka-topics.sh --list --zookeeper localhost:2181
test

• 生产消息

[root@localhost ~]# /usr/local/study/kafka/kafka_2.11-2.2.1/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic jianguan_workflow_test
>你好
>好哈好

• 消费消息

[root@localhost ~]# /usr/local/study/kafka/kafka_2.11-2.2.1/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic jianguan_workflow_test --from-beginning
你好
好哈好