Kafka 的安装及测试_2

本文涉及的产品
云原生网关 MSE Higress,422元/月
注册配置 MSE Nacos/ZooKeeper,118元/月
服务治理 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

相关文章
|
1月前
|
自然语言处理 机器人 Python
ChatGPT使用学习:ChatPaper安装到测试详细教程(一文包会)
ChatPaper是一个基于文本生成技术的智能研究论文工具,能够根据用户输入进行智能回复和互动。它支持快速下载、阅读论文,并通过分析论文的关键信息帮助用户判断是否需要深入了解。用户可以通过命令行或网页界面操作,进行论文搜索、下载、总结等。
49 1
ChatGPT使用学习:ChatPaper安装到测试详细教程(一文包会)
|
18天前
|
消息中间件 Ubuntu Java
Ubuntu系统上安装Apache Kafka
Ubuntu系统上安装Apache Kafka
|
1月前
|
前端开发 JavaScript 应用服务中间件
linux安装nginx和前端部署vue项目(实际测试react项目也可以)
本文是一篇详细的教程,介绍了如何在Linux系统上安装和配置nginx,以及如何将打包好的前端项目(如Vue或React)上传和部署到服务器上,包括了常见的错误处理方法。
284 0
linux安装nginx和前端部署vue项目(实际测试react项目也可以)
|
24天前
|
消息中间件 中间件 Kafka
解锁Kafka等消息队列中间件的测试之道
在这个数字化时代,分布式系统和消息队列中间件(如Kafka、RabbitMQ)已成为日常工作的核心组件。本次公开课由前字节跳动资深专家KK老师主讲,深入解析消息队列的基本原理、架构及测试要点,涵盖功能、性能、可靠性、安全性和兼容性测试,并探讨其主要应用场景,如应用解耦、异步处理和限流削峰。课程最后设有互动答疑环节,助你全面掌握消息队列的测试方法。
|
2月前
|
Linux
kickstart自动安装系统 --DHCP 配置及测试
PXE+Kickstart自动安装系统需配置DHCP服务器分配IP。dhcpd.conf示例:设置更新样式、忽略客户端更新、指定下一服务器及启动文件。定义子网、网关、掩码、动态地址池并预留特定MAC地址。重启xinetd、NFS、DHCP服务,确保新服务器与Kickstart服务器在同一网络,避免误装其他机器。注意隔离测试网络以防干扰生产环境。
80 18
|
1月前
|
测试技术 PHP 开发工具
php性能监测模块XHProf安装与测试
【10月更文挑战第13天】php性能监测模块XHProf安装与测试
29 0
|
2月前
|
安全 测试技术 Linux
CentOS7 安装vulhub漏洞测试环境
CentOS7 安装vulhub漏洞测试环境
|
2月前
|
消息中间件 Java Linux
linux 之centos7安装kafka;;;;;待补充,未完成
linux 之centos7安装kafka;;;;;待补充,未完成
|
2月前
|
Web App开发 Linux Python
linux上安装selenium环境及测试
该文章提供了在Linux CentOS上安装Selenium环境、Chrome浏览器及Chromedriver的详细步骤,并演示了如何以无头模式进行测试。
185 0
|
3月前
|
消息中间件 Kafka 测试技术
【Azure 事件中心】使用Kafka的性能测试工具(kafka-producer-perf-test)测试生产者发送消息到Azure Event Hub的性能
【Azure 事件中心】使用Kafka的性能测试工具(kafka-producer-perf-test)测试生产者发送消息到Azure Event Hub的性能