Kafka 2.11-0.11.0.2 伪分布式 基于Ubuntu16.0.4 配置记录

Big-Data 2018-02

安装Zookpeer

sudo apt-get install zookeeperd

然后在终端中启动监听即可

netstat -ant | grep :2181

终端输出如下表示启动成功

tcp6       0      0 :::2181                 :::*                    LISTEN

下载Kafka

通过wget或者浏览器方式下载kafka以后,将其解压到/usr/local目录即可

sudo tar -xvf kafka_2.11-0.11.0.2.tgz -C /usr/local/

启动Kafka

sudo /usr/local/kafka_2.11-0.11.0.2/bin/kafka-server-start.sh /usr/local/kafka_2.11-0.11.0.2/config/server.properties 

启动成功以后,我们新开一个终端,测试kafka server

测试Kafka server

• 生成主题

 sudo /usr/local/kafka_2.11-0.11.0.2/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic testing

终端会提示

Created topic "testing".

• 通过Zookpeer询问kafka可用的主题

 sudo /usr/local/kafka_2.11-0.11.0.2/bin/kafka-topics.sh --list --zookeeper localhost:2181

终端会列举目前可用的主题

testing

• 通过kafka生产信息,输入How are you? I am fine.等一些信息即可

sudo /usr/local/kafka_2.11-0.11.0.2/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic testing
>How are you?
>I am fine.
>

• 接下来开启一个新终端,再通过kafka消费信息

sudo /usr/local/kafka_2.11-0.11.0.2/bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic testing --from-beginning

• 终端会提示上面生产出来的消息

How are you?
I am fine.

表示上述kafka配置完成,如下所示:

附注

参考文档 Install and Configure Apache Kafka on Ubuntu 16.04