关于启动kafka的信息

本篇文章给大家谈谈启动kafka，以及对应的知识点，希望对各位有所帮助，不要忘了收藏本站喔。

本文目录一览：

• 1、docker启动kafka
• 2、windows系统下启动kafka CMD报错：输入行太长，语法错误
• 3、kafka命令行的管理使用
• 4、Kafka 运行命令
• 5、Linux版kafka&zookeeper启动方式
• 6、kafka集群启动和停止

docker启动kafka

记录下自己的操作，避免下次用的时候又去踩坑

docker pull wurstmeister/zookeeper

docker pull wurstmeister/kafka

docker run -d --name zookeeper -p 2181:2181 -t wurstmeister/zookeeper

docker exec -it zookeeper /bin/sh

这时查看zk节点只有一个zookeeper

docker退出当前容器 快捷键：

第一次尝试启动容器是用的第一种方式，后面发衡码粗现在容器外面连接不了kafka，可能是因为生成的kafka地址咐镇是容器内地址模段。所以换了第二种方式启动。

{"datas":[{"name":"jianshu","value":"10"}],"ver":"1.0"}

发现和图3相比 创建了很多关于kafka的节点

我们可以看到我们创建的主题及其信息

kafka在启动时连接zookeeper失败，报错信息如下

上网查了之后，发现是本机ip变化导致的...这就很骚。这里我修改一下KAFKA_ZOOKEEPER_CONNECT的ip就可以了。

贴一下别人的解决方案吧：

[img]

windows系统下启动kafka CMD报错：输入行太长，语法错误

        在windows系统用cmd输命令：.\bin\windows\kafka-server-start.bat .\config\server.properties  启动kafka居然报错：输入行太长，语法错误，折磨了我一个小时棚亮。

        在网上查到一个解决方法：  孝和伍kafka目录不要建太深，直接在放在D盘

 巧或

kafka命令行的管理使用

首先要启动好kafka集群

1、集群时间同步

2、启动zookeeper集群

3、启动kafka集群

启动kafka集群的方式就是在集群中每台机器 kafka目录 下运行

nohup bin/kafka-server-start.sh config/server.properties /dev/null 21

kafka发出消息和接收消息都是基于topic，所以要先创建一个燃睁topic，才能向里面发消息。创建topic的脚本：

topic创建好了，就可以向里边发送消息了。

通过命令行实现数据的发送 producer 生产者

kafka-console-producer.sh 就是用来测圆森试用的脚本，可以模拟kafka消息的发送端。

直接运行 kafka-console-producer.sh 查看帮助

--broker-list 指定我们kafka集群的地址

--topic 指定我们的消息发送到哪个topic里面去

通过命令行实现皮腔岁数据的接收 consumer 消费者

--bootstrap-server 表示我们的kafak集群的地址，在旧版本中使用的是--zookeeper参数，两者至少使用一个

--from-beginning 表示我们从最开始的数据进行消费

--topic指定我们topic的名字

在producer端发送数据，在consumer端可以收到数据

Kafka 运行命令

一、启动ZooKeeper

打开一个新终端并键入以下命令

二、要启动Kafka Broker，请键入以下命令

启动Kafka Broker后，在ZooKeeper终端上键入命令 jps ，您将看到以下响应

现在你可以看到两个守护进程运行在终端上，QuorumPeerMain是ZooKeeper守护进程，另一个是Kafka守护进程。

三、创建Kafka主题

四、主题列表

要获取Kafka服务器中的主题列表，可以使用以下命令

输出

五、启世盯动生产者以发送消息

六、启动消费者以接收消息

七、单节点多代理配置

创建多个Kafka Brokers，我们在配置/ server.properties中已有一个Kafka代理实例。 现在我们需要多个代理实例，因此将现有的server.prop-erties文搜带和件复制到两个新的配置文件中，并将其重命名为server-one.properties和server-two.properties。 然后编辑这两个新文件并分配以下更改

config / server-one.properties

创建主题

让我们为此主题将复制因子值指定为三个，因为我们有三个不同的代理运行。 如果您有两个代理，那么分配的副本值将是行袭两个。

Describe 命令用于检查哪个代理正在侦听当前创建的主题

输出

八、修改主题

Linux版kafka&zookeeper启动方式

Linux版kafka启动方式

方法一：

在bin的上一级目录执行命令肆团兆：

加守护进程启动

方法二：

在bin的上一级目录执行命令：

通过后台来启动

ZooKeeper服务命令:

在准备好相应的配或改置之后，可以直接通裂租过zkServer.sh 这个脚本进行服务的相关操作

kafka集群启动和停止

1、启动

先启动zk集群

然后在所有节点执行脚本

nohup kafka-server-start.sh /颂李举kkb/install/kafka/config/server.properties /dev/null 21

一键启动kafka

start_kafka.sh

for host in node01 node02 node03

do

ssh host kafka is running"

done

2、停止

所有节点执行扰族关闭kafka脚本

kafka-server-stop.sh

一键停止kafka

stop_kafka.sh

for host in node01 node02 node03

do

ssh host kafka is stopping"

done

3、一野碧键启动和停止脚本

kafkaCluster.sh

case host "source /etc/profile; nohup /kkb/install/kafka/bin/kafka-server-start.sh /kkb/install/kafka/config/

server.properties /dev/null 21 "

echo "$host kafka is running..."

done

};;

"stop"){

for host in node01 node02 node03

do

ssh host kafka is stopping..."

done

};;

esac

启动

sh kafkaCluster.sh start

停止

sh kafkaCluster.sh stop

关于启动kafka和的介绍到此就结束了，不知道你从中找到你需要的信息了吗 ？如果你还想了解更多这方面的信息，记得收藏关注本站。