kafka _命令行操作

#启动zk
zkServer.start
#启动kafka
kafka-server-start.sh -daemon /opt/kafka/config/server.properties#查看当前服务器中的所有topic
kafka-topics.sh --zookeeper henu4:2181 --list#创建topic
kafka-topics.sh --zookeeper henu4:2181 --create --replication-factor 3 --partitions 1 --topic first选项说明：
--topic 定义topic名
--replication-factor  定义副本数
--partitions  定义分区数#删除topic
kafka-topics.sh --zookeeper henu4:2181 --delete --topic first#发送消息创建second主题kafka-topics.sh --zookeeper henu4:2181 --create --replication-factor 3 --partitions 3 --topic second#换一个节点：kafka-console-producer.sh --broker-list henu2:9092 --topic second#消费信息
kafka-console-consumer.sh --zookeeper henu2:2181 --from-beginning --topic second
#如果版本问题不能使用，将--zookeeper 换成 --bootstrap-server--from-beginning：会把first主题中以往所有的数据都读取出来。根据业务场景选择是否增加该配置。#查看某个Topic的详情
kafka-topics.sh --zookeeper henu2:2181 --describe --topic second#关闭集群
kafka-server-stop.sh stop

结果展示：

另一个节点：

然后本节点消费信息：

查看某个Topic的详情

kafka _命令行操作相关推荐

Kafka的命令行操作
一.topic命令下面Windows命令需要把cmd路径切换到bin/windows下. 而Linux命令只需要在控制台切换到bin目录下即可. 下面都以Windows下的操作为例,在Linux下也 ...
Kafka 生产者、消费者命令行操作
Kafka 生产者.消费者命令行操作 1.查看操作生产者命令参数 bin/kafka-console-producer.sh 参数 --bootstrap-server <String: ser ...
【kafka】三、kafka命令行操作
kafka命令行操作 kafka的相关操作命令脚本文件在bin目录下查看所有的topic kafka-topics.sh --zookeeper hll1:2181 --list 或 kafka-t ...
简单的kafka命令行操作
目录一.主题topic命令行操作 1.查看操作主题的命令参数 2.连接kafka地址,创建名为kaf的主题,指定分区和副本数量 3.查看所有主题的名称 4.查看主题的详细信息 5.修改主题(修改分区 ...
数据仓库 — 07_Kafka的安装与部署（Kafka命令行操作指令、Kafka集群群起脚本、压力测试、节点数量计算、hadoop_zookeeper_flume_kafka群起脚本、默认端口总结）
文章目录 1 Kafka的安装与配置 2 Kafka命令行操作 2.1 查看当前服务器中的所有topic 2.2 创建topic 2.3 删除topic 2.4 发送消息 2.5 消费消息 2.6 查 ...
kafka 基础概念、命令行操作（查看所有topic、创建topic、删除topic、查看某个Topic的详情、修改分区数、发送消息、消费消息、查看消费者组、更新消费者的偏移位置）
文章目录前言 1. 基础概念 Broker Producer Consumer Consumer Group Topic Partition Replica 2. 命令行操作 2.1 查看所有top ...
kafka 命令行操作大全
kafka 命令行操作大全一.集群相关常用命令二.topic相关常用命令 2.1 脚本&参数简介 2.2 举例三.生产者命令行常用操作 3.1 脚本&参数简介 3.2 举例发送消 ...
gitlab ci 自动化部署_前端gitLab加jenkins自动化构建和部署，以及服务器常用的linux命令行操作，免密登录...
常用的linux命令行操作将项目部署到服务器后,需要查看文件是否已经部署成功,已经对文件进行增删改查操作,就需要用到命令行操作,常用操作如下: ll 罗列出当前文件或目录的详细信息,含有时间.读写权 ...
区块链之开发命令行操作模块
文章目录功能介绍 go语言中flag用法简介项目命令行具体实现链接: 区块链项目github地址项目目前进度: 功能介绍利用命令行操作区块链相较于图形用户界面来说,编写代码简单,同时也可以实 ...

kafka _命令行操作

kafka _命令行操作

kafka _命令行操作相关推荐

最新文章

热门文章