kafka使用（kafka使用与详解）

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

本文目录一览：

• 1、kafka使用常见报错及解决方法
• 2、kafka集群配置和使用
• 3、kafka命令行的管理使用

kafka使用常见报错及解决方法

server.properties中有两个listeners。 listeners：启动kafka服务监听的ip和端口，可以监听内网ip和0.0.0.0(不能为外网ip)，默亩斗认为java.net.InetAddress.getCanonicalHostName()获取的ip。advertised.listeners：卖饥生产者和消费者连接的地址，kafka会把该地址注册到zookeeper中，所以只能为除0.0.0.0之外的合法ip或域名 ，默认和listeners的配置一致。

只迅配磨有在jdk1.9并且kafka版本在1.0.x之前的版本才会出现。

kafka集群配置和使用

进入安装目录，修改server.properties文件

修改如下属性，除id外，其他每台主机一致：

语义配置：（可选）

先启动zookeeper集群，已经在三台主机上配置好了zookeeper集群，启动：

在各台主机上进入zookeeper目录，分别启动zk：

在各台主机上进入kafka目录，分别启动kafka：

启动结好悔果为：

kafka占据了前台，辩枯要使携袜洞用主机，需要打开新终端

在新打开的终端上，进入zk目录，

进入kafka目录，创建主体

[img]

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使用和kafka使用与详解的介绍到此就结束了，不知道你从中找到你需要的信息了吗 ？如果你还想了解更多这方面的信息，记得收藏关注本站。