Kafka 的安装及测试_2

本文涉及的产品
服务治理 MSE Sentinel/OpenSergo,Agent数量 不受限
简介: 快速学习 Kafka 的安装及测试_2

开发者学堂课程【大数据实时计算框架 Spark 快速入门Kafka 的安装及测试_2】学习笔记,与课程紧密联系,让用户快速学习知识。

课程地址https://developer.aliyun.com/learning/course/100/detail/1728


Kafka 的安装及测试_2


内容简介:


一、Kafka 创建

二、查看

三、添加数据


[root@node21 kafka_2.10-0.8.2.1]# bash startkafka.sh 启动脚本,有的可能刚开始可以启动,不久后启动失败,所以需要多启动几次,如果一直在,说明启动成功。


一、创建

1.[root@node21 kafka_2.10-0.8.2.1]# 11 bin/

2.[root@node21 kafka_2.10-0.8.2.1]# ./bin/kafka-topics.sh 获取提示;

3.[root@node21 kafka_2.10-0.8.2.1]# ./bin/kafka-topics.sh create 创建(提示显示需要加“--”);

4.[root@node21 kafka_2.10-0.8.2.1]# ./bin/kafka-topics.sh --create(提示显示需要 zookeeper);

5.[root@node21 kafka_2.10-0.8.2.1]#./bin/kafka-topics.sh --create --zookeeper node21:2181,node22:2181,node23:2181(提示显示需要 topic);

6.[root@node21 kafka_2.10-0.8.2.1]#./bin/kafka-topics.sh --create --zookeeper node21:2181,node22:2181,node23:2181 --topic20161205(提示显示需要 partitions);

7.[root@node21 kafka_2.10-0.8.2.1]#./bin/kafka-topics.sh --create --zookeeper node21:2181,node22:2181,node23:2181 --topic20161205 --partitions 2(提示显示需要 replication);

8.[root@node21 kafka_2.10-0.8.2.1]#./bin/kafka-topics.sh --create --zookeeper node21:2181,node22:2181,node23:2181 --topic20161205 --partitions 2 --replication-factor 2


二、查看

1.[root@node21 kafka_2.10-0.8.2.1]# ./bin/kafka-topics.sh --list 查看创建好的topic(提示显示需要zookeeper);

2.[root@node21 kafka_2.10-0.8.2.1]#./bin/kafka-topics.sh --list --zookeeper node21:2181,node22:2181,node23:2181;

3.[root@node21 kafka_2.10-0.8.2.1]#./bin/kafka-topics.sh --describe --zookeeper node21:2181,node22:2181,node23:2181


三、添加数据

1.[root@node21 kafka_2.10-0.8.2.1]# 11 bin/添加数据;

2.[root@node21 kafka_2.10-0.8.2.1]# .bin/kafka-console-producer.sh;

3.[root@node21 kafka_2.10-0.8.2.1]# .bin/kafka-console-producer.sh --broker-list node21:9092,node22:9092,node23:9092 --topic 20161205(找 required);

4.[root@node21 kafka_2.10-0.8.2.1]# .bin/kafka-console-consumer.sh --topic 20161205 --zookeeper node21:2181,node22:2181,node23:2181

相关文章
|
3月前
|
C++
jrtplib开源库系列之一:jrtplib介绍、安装和测试(window 10环境介绍)
关于jrtplib库网上已经有很多介绍,而且目前jrtplib作者已经停止更新(Apr 18, 2020),最新版本为v3.11.2。本系列内容也以该版本进行介绍。 相信你已经对RTP/RTCP协议有一定的了解,并想更深入的了解RTP协议的具体实现,jrtplib就是使用使用C++实现的RTP/RTCP协议。具体标准为RFC3550,如果想仔细阅读原文,但是对英文又有点吃力,可以参考我的博客RTP/RTCP中英文对照,在博客的后面有百度链接,是对RFC3550的中文翻译,可能很多地方不太准确,有些内容是自己添加进去的,希望不会影响你的阅读。
34 0
|
1月前
|
消息中间件 Java Kafka
Kafka【环境搭建 01】kafka_2.12-2.6.0 单机版安装+参数配置及说明+添加到service服务+开机启动配置+验证+chkconfig配置说明(一篇入门kafka)
【2月更文挑战第19天】Kafka【环境搭建 01】kafka_2.12-2.6.0 单机版安装+参数配置及说明+添加到service服务+开机启动配置+验证+chkconfig配置说明(一篇入门kafka)
55 1
|
4天前
|
分布式计算 Hadoop Scala
Spark【环境搭建 01】spark-3.0.0-without 单机版(安装+配置+测试案例)
【4月更文挑战第13天】Spark【环境搭建 01】spark-3.0.0-without 单机版(安装+配置+测试案例)
8 0
|
1月前
|
消息中间件 Kafka Linux
Kafka【付诸实践 03】Offset Explorer Kafka 的终极 UI 工具安装+简单上手+关键特性测试(一篇学会使用 Offset Explorer)
【2月更文挑战第21天】Kafka【付诸实践 03】Offset Explorer Kafka 的终极 UI 工具安装+简单上手+关键特性测试(一篇学会使用 Offset Explorer)
189 2
|
2月前
|
消息中间件 Java Kafka
docker安装kafka(wurstmeister)
docker安装kafka(wurstmeister)
122 0
|
3月前
|
测试技术 API 芯片
阿萨聊测试:如何在Mac 电脑上安装Postman?
阿萨聊测试:如何在Mac 电脑上安装Postman?
140 0
阿萨聊测试:如何在Mac 电脑上安装Postman?
|
3月前
|
网络协议 网络安全 Go
Kali下安装渗透测试常用工具dnsx和dirsearch
Kali下安装渗透测试常用工具dnsx和dirsearch
66 0
|
3月前
|
消息中间件 Kafka Linux
linux如何安装KafKa
linux如何安装KafKa
961 0
|
3月前
|
消息中间件 Java Kafka
使用Java编写代码安装Kafka及启动Zookeeper和Kafka
如何使用Java编写代码安装Kafka及启动Zookeeper和Kafka?其中包括安装前准备、修改配置文件、创建日志目录和数据目录等步骤,请提供详细实现过程。
43 0
|
3月前
|
Kubernetes NoSQL Linux
linux安装Lua及代码测试
linux安装Lua及代码测试