Kafka 搭建和测试等问题

  |  
阅读次数
  |  
字数 316
  |  
时长 ≈ 2 分钟

1)安装启动kafka

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
#跳转到下载目录
cd /opt/setup

# 下载安装包
wget http://mirror.bit.edu.cn/apache/kafka/0.10.2.0/kafka_2.12-0.10.2.0.tgz

# 解压
tar -xzf kafka_2.10-0.8.1.1.tgz
mv kafka_2.12-0.10.2.0 /usr/program
# 启动 Zookeeper
cd /usr/program/zookeeper-3.4.9
bin/zookeeper-server-start.sh config/zookeeper.properties

# 启动 Kafka

cd /usr/program/kafka_2.12-0.10.2.0
bin/kafka-server-start.sh config/server.properties

2)

启动过程中,发现提示“未知的名称或服务”需要修改host配置,在127.0.0.1后面最佳goukaiHost,,为主机名称。

1
2
3
4
vim /etc/hosts

127.0.0.1 localhost localhost.localdomain localhost4 localhost4.localdomain4 goukaiHost
::1 localhost localhost.localdomain localhost6 localhost6.localdomain6

3)

创建一个叫做“test”的topic,它只有一个分区,一个副本。

1
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

查看创建的topic

1
bin/kafka-topics.sh --list --zookeeper localhost:2181

4)发送消息

1
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

输入命令之后,输入字符串按回车进行发送即可。可另开一个窗口使用消费命令监听消息发送情况。
Ctrl+c可以结束当前操作。

5)启动consumer

1
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning