kafka启动（kafka启动后jps无进程）

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

本文目录一览：

• 1、Kafka 运行命令
• 2、kafka集群启动和停止
• 3、kafka启动报错（转）
• 4、Linux版kafka&zookeeper启动方式
• 5、docker启动kafka

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 命令用于检查哪个代理正在侦听当前创建的主题

输出

八、修改主题

[img]

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启动报错（转）

原文链接：

报错

C:\H\software\kafka_2.12-1.1.1\bin\windowskafka-server-start.bat ..\..\config\

server.properties

[2018-12-11 21:13:46,490] INFO Registered kafka:type=kafka.Log4jController MBean

(kafka.utils.Log4jControllerRegistration$)

[2018-12-11 21:13:46,998] ERROR Exiting Kafka due to fatal exception (kafka.Kafk

a$)

java.lang.VerifyError: Uninitialized object exists on backward branch 209

Exception Details:

  Location:

    scala/collection/immutable/HashMap$HashTrieMap.split()Lscala/collection/immu

table/Seq; @249: goto

  Reason:

    Error exists in the bytecode

  Bytecode:

    0000000: 2ab6 0060 04a0 001e b200 b8b2 00bd 04bd

    0000010: 0002 5903 2a53 c000 bfb6 00c3 b600 c7c0

    ......

    0000170: b200 bd05 bd00 0259 0319 0b53 5904 190c

    0000180: 53c0 00bf b600 c3b6 0102 b02a b600 3803

    0000190: 32b6 0104 b0

  Stackmap Table:

    same_frame(@35)

    full_frame(@141,{Object[#2],Integer,Integer,Integer,Integer,Integer,Object[#

114]},{})

    append_frame(@151,Object[#134],Object[#134])

    full_frame(@209,{Object[#2],Integer,Integer,Integer,Integer,Integer,Object[#

......

解决办法 升级jdk

将1.8.0_11 升级为 1.8.0_251

Linux版kafka&zookeeper启动方式

Linux版kafka启动方式

方法一：

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

加守护进程启动

方法二：

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

通过后台来启动

ZooKeeper服务命令:

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

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就可以了。

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

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