[关闭]
@linux1s1s 2018-02-11T02:32:36.000000Z 字数 1120 阅读 737

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

Big-Data 2018-02

安装Zookpeer

  1. sudo apt-get install zookeeperd

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

  1. netstat -ant | grep :2181

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

  1. tcp6 0 0 :::2181 :::* LISTEN

下载Kafka

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

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

启动Kafka

  1. 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

  1. 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".

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

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

testing

  1. sudo /usr/local/kafka_2.11-0.11.0.2/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic testing
  2. >How are you?
  3. >I am fine.
  4. >
  1. sudo /usr/local/kafka_2.11-0.11.0.2/bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic testing --from-beginning
  1. How are you?
  2. I am fine.

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

此处输入图片的描述

附注

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

添加新批注
在作者公开此批注前,只有你和作者可见。
回复批注