查看当前服务器中的所有topic
bin/kafka-topics.sh --list --zookeeper amie01:2181
创建topic
bin/kafka-topics.sh --create --zookeeper amie01:2181 --replication-factor 3 --partitions 3 --topic myTopic
删除topic
sh bin/kafka-topics.sh --delete --zookeeper amie01:2181 --topic myTopic
需要server.properties中设置delete.topic.enable=true否则只是标记删除或者直接重启。
通过shell命令发送消息
kafka-console-producer.sh --broker-list amie01:9092 --topic myTopic
通过shell消费消息
sh bin/kafka-console-consumer.sh --zookeeper amie01:2181 --from-beginning --topic myTopic
查看消费位置
sh kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper amie01:2181 --group myGroup
查看某个Topic的详情
sh kafka-topics.sh --topic myTopic --describe --zookeeper amie01:2181
对分区数进行修改
kafka-topics.sh --zookeeper amie01:2181 --alter --partitions 15 --topic myTopic
查看topic 详细信息
kafka-topics.sh --describe --zookeeper amie01:2181 --topic myTopic
相关推荐
### Kafka常用命令归纳 #### 一、环境设置与概述 本文档主要针对Kafka的日常运维及开发过程中经常使用的命令进行归纳整理。所涉及的命令适用于以下环境： - **Zookeeper地址**: localhost:2181 - **Bootstrap ...
### Kafka 常用命令详解 #### 一、概述 Apache Kafka 是一款开源的消息队列系统，被广泛应用于日志收集、流处理、实时数据整合等场景。在使用 Kafka 进行开发或运维的过程中，掌握一些常用的命令对于提高工作效率...
### Kafka的常用命令集锦 ...以上就是Kafka常用的命令集锦，这些命令涵盖了Kafka的基本管理和操作流程，对于快速上手Kafka具有重要的参考价值。在实际使用过程中，可以根据具体需求进一步探索更多高级特性。
日记月累，收录kafka各种命令，会持续更新。 在0.9.0.0之后的Kafka，出现了几个新变动，一个是在Server端增加了GroupCoordinator这个角色，另一个较大的变动是将topic的offset 信息由之前存储在zookeeper上改为...
本文主要总结了Apache Kafka的相关命令和操作，包括安装、服务启停、Topic管理、消息生产和消费以及一些实用工具。Kafka是一个分布式流处理平台，它被广泛用于实时数据管道和流应用。 1. **Kafka的安装与服务启停**...
### Kafka 3.2 常用命令详解 #### 一、启动 ZooKeeper 服务 在启动 Kafka 之前，必须先启动 ZooKeeper 服务。ZooKeeper 为 Kafka 提供了集群协调服务。 ##### 操作步骤： 1. **打开命令行窗口**： - 打开 cmd ...
### Kafka 常用操作命令解析 #### 一、启动Kafka服务 **命令：** ```bash kafka-server-start.sh config/server.properties ``` **解释：** 此命令用于启动Kafka服务。其中`kafka-server-start.sh`是启动脚本，`...
Kafka常用命令操作包括查看所有topic、查看topic详情、停止和启动Kafka等。 kafka集群搭建需要完成以下步骤： 1. 准备工作，关闭防火墙和配置hosts和hostname。 2. Java环境配置，解压安装Java安装包和配置环境...
Kafka常见运维命令文档，Kafka常见运维命令文档，Kafka常见运维命令文档
本人积累的一些Kafka调试的常用命令，主要包含：启动Kafka、创建Topic、 查看topic列表、创建生产者、创建消费者、修改分区数、删除Topic、自带生产者性能测试
4. **Kafka常用命令和参数**： Kafka提供了丰富的命令行工具，用于管理Topics、Producers、Consumers等。例如： - `kafka-topics.sh`：创建、查看、修改Topic。 - `kafka-console-producer.sh`：启动命令行...
### Kafka常用命令 1. **查看topic列表**：`kafka-topics.sh --list --zookeeper zookeeper_host:port` 2. **创建topic**：`kafka-topics.sh --create --topic topic_name --partitions num_partitions --...
**常用命令** 1. **创建 Topic**：使用 `kafka-topics.sh --create` 命令创建新的主题，例如 `--topic test --bootstrap-server 10.168.18.168:9092`。 2. **查看 Topic 列表**：使用 `kafka-topics.sh --list` 命令...
了解并熟练运用这些命令，可以帮助你更好地管理和监控Kafka集群，确保系统的稳定运行。在实际环境中，你可能还需要结合Zookeeper、JMX监控、日志分析等多种工具来全面掌握Kafka集群的健康状况。同时，对于大数据处理...
以下是一些Kafka的常用功能点，将根据提供的文件名进行详细解释。 1. **创建Topic** 创建Kafka Topic是使用Kafka的第一步。Topic是消息的逻辑存储单元，可以理解为数据库中的表。在Kafka中，你可以使用命令行工具`...
以下是对 Kafka 常用命令行的详细说明： 1. **查看 Topic 详细信息**： 使用 `kafka-topics.sh` 命令行工具，配合 `-zookeeper` 参数指定 ZooKeeper 地址，`-describe` 参数来获取 Topic 的详细信息，例如： ```...
五、常用的Kafka操作命令 1、查询Linux操作系统版本信息 输入"uname -a ",可显示电脑以及操作系统的相关信息；输入"cat /proc/version",说明正在运行的内核版本；输入"cat /etc/issue", 显示的是发行版本信息；...