kafka命令

启动kafka：
./kafka-server-start.sh ../config/server.properties &

查看topic
./kafka-topics.sh --zookeeper 192.168.8.56:2181,192.168.8.70:2181,192.168.8.147:2181 --describe --topic liuhangjun
./kafka-topics.sh --zookeeper 192.168.8.147:2181,192.168.8.56:2181,192.168.8.70:2181 --list

生产消息
./kafka-console-producer.sh --broker-list 10.166.112.149:9092 --topic test1

消费消息
./kafka-console-consumer.sh --zookeeper 192.168.8.56:2181,192.168.8.70:2181,192.168.8.147:2181 --topic liuhangjun --from-beginning

删除topic
./kafka-run-class.sh kafka.admin.DeleteTopicCommand --zookeeper 192.168.8.14:6831,192.168.8.15:6831,192.168.8.149:6831 --topic test

消息数量
./kafka-simple-consumer-shell.sh --broker-list 127.0.0.1:9092 --topic test --partition 0 --max-messages 1

时间： 2024-10-11 01:30:54

kafka命令的相关文章

kafka 命令笔记

以下命令都是在kafka根目录下 启动自带的zookeeper bin/zookeeper-server-start.sh config/zookeeper.properties 启动kafka(启动完zookeeper后,应再新开个窗口启动kafka,不然会报超时错误,可能由于我用的linux命令有问题,ctrl+z让它后台运行,没有起作用.回头在研究一下) bin/kafka-server-start.sh config/server.properties 查看所有的topic相信信息(描述

Kafka命令行详细介绍

常用的几个命令如下: kafka-server-start.shkafka-console-consumer.shkafka-console-producer.shkafka-topics.sh在这几个命令中,第一个仅用于启动Kafka,后两个console常用于测试,用途最多的是最后一个命令,所以下面命令中主要介绍的就是 kafka-topics.sh. kafka-server-start.sh用法:> bin/kafka-server-start.sh [-daemon] server.p

kafka命令使用

1.创建 topic /usr/local/kafka/bin/kafka-topics.sh --create --zookeeper zoo1:2181,zoo2:2181,zoo3:2181 --replication-factor 3 --partitions 3 --topic kafka_test--topic 名字--replication-factor 副本数--partitions 分区数 2.列出所有的topic/usr/local/kafka/bin/kafka-topic

kafka 命令

启动 [root@node1 kafka]# ./bin/kafka-server-start.sh -daemon config/server.properties 创建主题 ./bin/kafka-topics.sh --create --zookeeper 192.168.23.101:2181,192.168.23.102:2181,192.168.23.103:2181 --replication-factor 3 --partitions 3 --topic test 原文地址:ht

kafka命令行

1.创建topic ./kafka-topics.sh --create --zookeeper 172.17.0.25:2181 --topic test --partitions 1 --replication-factor 1 2.查询topic列表 ./kafka-topics.sh --zookeeper 172.17.0.25:2181 --list 3.查询某个topic的详细信息 ./kafka-topics.sh --zookeeper 172.17.0.25:2181 --d

kafka命令大全

创建主题: 创建主题(4个分区,2个副本)kafka-topics.sh --create --zookeeper 192.168.130.37:2181,192.168.130.38:2181,192.168.130.39:2181 --replication-factor 2 --partitions 4 --topic test 查看集群详情: kafka-topics.sh --describe --zookeeper 192.168.130.37:2181,192.168.130.38

Apache Kafka系列(二) 命令行工具（CLI）

Apache Kafka系列(一) 起步 Apache Kafka系列(二) 命令行工具(CLI) Apache Kafka命令行工具(Command Line Interface,CLI),下文简称CLI. 1. 启动Kafka 启动Kafka需要两步: 1.1. 启动ZooKeeper [[email protected] kafka_2.12-0.11.0.0]# bin/zookeeper-server-start.sh config/zookeeper.properties 1.2.

kafka控制台命令

Kafka 命令 Kafka启动的时候使用 –daemon 后台运行,其命令如下: ./kafka-server-start.sh –daemon ../config/server.properties 1)      查看当前某个group 消费的 ./kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper localhost:2181 --group 1 --topic 000B_7F14 得到的结果为: 其中各参数解

kafka基础命令

kafka名词解释 1.producer: 消息生产者,发布消息到 kafka 集群的终端或服务. 2.broker: kafka 集群中包含的服务器. 3.topic: 每条发布到 kafka 集群的消息属于的类别,即 kafka 是面向 topic 的. 4.partition: partition 是物理上的概念,每个 topic 包含一个或多个 partition.kafka 分配的单位是 partition. 5.consumer: 从 kafka 集群中消费消息的终端或服务. 6.C