网友收藏文章浏览阅读562次。kafka启动命令：kafka-server-start.shkafka关闭命令：kafka-server-stop.sh创建topic命令：kafka-topics.sh --create --zookeeper master:2181,slave1:2181,slave2:2181 --topic test1 --partitions 3 --replication-factor 3查看所有的topic命令：kafka-topics.sh --l......
2024-01-23 05:03 阅读 一、Kafka 命令行操作1. Kafka 是要用到zookeeper，那么zookeeper帮Kafka做了什么事呢？①. 启动zookeeper②.先看没启动Kafka的zookeeper有什么，这边是空没任何东西yexiang@hadoop2:<zookeeper-3.4.10>$ zkCli.sh -server hadoop3:2181 ...[zk: hadoop3:2181(CONNECTE......
2023-10-09 22:58 阅读 文章浏览阅读216次。命令：Kafka依赖于zookeeper，所以需要先启动zookeeper。zkServer.sh start启动Kafkakafka-server-start.sh /opt/soft/kafka211/config/server.properties 或nohup kafka-server-start.sh /opt/soft/kafka211/config/server.properties &关闭Kafkakafka-server-stop.sh......
2024-01-23 07:23 阅读 文章浏览阅读2.7k次。启动kafka(到每个节点启动)node01： nohup ./bin/kafka-server-start.sh config/server.properties &node02： nohup ./bin/kafka-server-start.sh config/server.properties &node03s： nohup ./bin/kafka-server-start.sh config/server.properties &创建topicb......
2024-01-23 01:47 阅读 11.1.Zookeeper的启动命令首先，进入安装zookeeper的bin目录下。 启动命令为zkServer.sh.start 。1.2.Zookeeper的关闭命令在安装zookeeper的bin目录下，关闭命令为zkServer.sh stop。1.3.Zookeeper的重启命令在安装zookeeper的bin目录下，重启命令为zkServer.......
2023-10-11 21:22 阅读 kafka配置1、kafka配置server.properties文件1.1、进入kafka的config目录下1.2、然后进入server.properties进行配置[root@cjh1 config]# vi ./server.properties1.3、 通过显示行号进行查找并修改 :set nu然后分别在下面指定行号修改以下内容（137行是最后加......
2023-10-11 21:22 阅读 文章浏览阅读895次。Kafka常用命令#启动ZK./bin/zookeeper-server-start.sh ./config/zookeeper.properties#启动Kafka./bin/kafka-server-start.sh ./config/server.properties#创建主题kafka-topics.sh --zookeeper localhost:2181 --create --topic test --partitions 1 --replication-facto..._kafk......
2024-01-21 12:50 阅读 文章浏览阅读4.3k次。查看topic信息：bin/kafka-topics.sh --list --bootstrap-server common1:9092查看topic内容：bin/kafka-console-consumer.sh --bootstrap-server common1:9092 --topic hbcs_db --from-beginning创建topic:bin/kafka-topics.sh --create --bootstrap-server common1:9092 --topic......
2024-01-23 10:23 阅读 为了方便将来进行一键启动、关闭Kafka，我们可以编写一个shell脚本来操作。将来只要执行一次该脚本就可以快速启动/关闭Kafka。Kafka的所有执行脚本都在这里。例如：启动Kafka服务器、创建Topic、生产者、消费者程序等等。Kafka的......
2023-10-11 21:22 阅读 一、前言最近生产遇到一个类似kafka消息丢失的问题，不太好排查，可能是以下几种情况：1.生产者把消息发送给kafka前就失败了2.生产者把消息发送给kafka的途中消息丢失，kafka没有收到消息3.生产者把消息发送给了kafka，但是kafka......
2023-10-11 21:22 阅读 
