Kafka 的安装及测试_2

本文涉及的产品
MSE Nacos/ZooKeeper 企业版试用,1600元额度,限量50份
服务治理 MSE Sentinel/OpenSergo,Agent数量 不受限
任务调度 XXL-JOB 版免费试用,400 元额度,开发版规格
简介: 快速学习 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

相关文章
|
2月前
|
消息中间件 Kafka Linux
Linux下安装Kafka 3.9.1
本文介绍Kafka 3.9.1版本的安装与配置,包括通过ZooKeeper或KRaft模式启动Kafka。涵盖环境变量设置、日志路径修改、集群UUID生成、存储格式化及服务启停操作,适用于Linux环境下的部署实践。
257 0
|
11月前
|
运维 关系型数据库 MySQL
os-copilot安装_配置_功能测试全集
我是一位中级运维工程师,我平时工作会涉及到 各类服务器的 数据库 与 java环境配置 操作。 我顺利使用了OS Copilot的 -t -f | 功能,我的疑惑是不能在自动操作过程中直接给与脚本运行权限,必须需要自己运行一下 chmod 这个既然有了最高的权限,为什么就不能直接给与运行权限呢。 我认为 -t 功能有用,能解决后台运行基础命令操作。 我认为 -f 功能有用,可以通过task文件中撰写连续任务操作。 我认为 | 对文件理解上有很直接的解读,可以在理解新程序上有很大帮助。
336 86
|
10月前
|
存储 人工智能 编译器
【03】鸿蒙实战应用开发-华为鸿蒙纯血操作系统Harmony OS NEXT-测试hello word效果-虚拟华为手机真机环境调试-为DevEco Studio编译器安装中文插件-测试写一个滑动块效果-介绍诸如ohos.ui等依赖库-全过程实战项目分享-从零开发到上线-优雅草卓伊凡
【03】鸿蒙实战应用开发-华为鸿蒙纯血操作系统Harmony OS NEXT-测试hello word效果-虚拟华为手机真机环境调试-为DevEco Studio编译器安装中文插件-测试写一个滑动块效果-介绍诸如ohos.ui等依赖库-全过程实战项目分享-从零开发到上线-优雅草卓伊凡
602 10
【03】鸿蒙实战应用开发-华为鸿蒙纯血操作系统Harmony OS NEXT-测试hello word效果-虚拟华为手机真机环境调试-为DevEco Studio编译器安装中文插件-测试写一个滑动块效果-介绍诸如ohos.ui等依赖库-全过程实战项目分享-从零开发到上线-优雅草卓伊凡
|
8月前
|
SQL 缓存 关系型数据库
MySQL8.4 Enterprise安装Firewall及测试
MySQL8.4 Enterprise安装Firewall及测试
251 0
|
9月前
|
人工智能 测试技术 API
Windows用户必备:Postman v11详细安装指南与API测试入门教程(附官网下载
Postman是全球领先的API开发与测试工具,支持REST、SOAP、GraphQL等协议调试。2025年最新版v11新增AI智能生成测试用例、多环境变量同步等功能,适用于前后端分离开发、自动化测试、接口文档自动生成及团队协作共享API资源。本文详细介绍Postman的软件定位、核心功能、安装步骤、首次配置、基础使用及常见问题解答,帮助用户快速上手并高效利用该工具进行API开发与测试。
|
10月前
|
消息中间件 Kafka Docker
docker compose 安装 kafka
通过本文的步骤,您可以快速在本地使用 Docker Compose 安装并配置 Kafka 和 Zookeeper。Docker Compose 简化了多容器应用的管理,方便快速搭建和测试分布式系统。
1302 2
|
11月前
|
弹性计算 Ubuntu Java
OS-Copilot-ubuntu镜像版本的具体测试使用(安装方式有单独注明)
作为一名个人开发者,我主要负责云资源的运维和管理。在使用OS Copilot的过程中,我遇到了一些配置问题,特别是在ECS实例中设置AccessKey时,但最终成功解决了。通过使用OS Copilot的-t/-f/管道功能,我大大提升了效率,减少了命令编写的工作量,特别是在搭建Java运行环境时效果显著。此外,| 功能帮助我快速理解文档,整体体验非常流畅,推荐给其他开发者使用。
260 6
|
11月前
|
弹性计算 运维 Ubuntu
os-copilot在Alibaba Cloud Linux镜像下的安装与功能测试
我顺利使用了OS Copilot的 -t -f 功能,我的疑惑是在换行的时候就直接进行提问了,每次只能写一个问题,没法连续换行更有逻辑的输入问题。 我认为 -t 管道 功能有用 ,能解决环境问题的连续性操作。 我认为 -f 管道 功能有用 ,可以单独创建可连续性提问的task问题。 我认为 | 对文件直接理解在新的服务器理解有很大的帮助。 此外,我还有建议 可以在非 co 的环境下也能进行连续性的提问。
245 7
|
消息中间件 Ubuntu Java
Ubuntu系统上安装Apache Kafka
Ubuntu系统上安装Apache Kafka
|
消息中间件 中间件 Kafka
解锁Kafka等消息队列中间件的测试之道
在这个数字化时代,分布式系统和消息队列中间件(如Kafka、RabbitMQ)已成为日常工作的核心组件。本次公开课由前字节跳动资深专家KK老师主讲,深入解析消息队列的基本原理、架构及测试要点,涵盖功能、性能、可靠性、安全性和兼容性测试,并探讨其主要应用场景,如应用解耦、异步处理和限流削峰。课程最后设有互动答疑环节,助你全面掌握消息队列的测试方法。