首页 > 编程知识 正文

苹果笔记本电脑使用入门教程,苹果系统使用入门教程

时间:2023-05-06 21:14:35 阅读:179738 作者:2669

本入门教程涵盖Kafka的核心内容,通过实例和大量图表帮助学员理解,任何问题都欢迎留言。

目录:

kafka概述kafka核心概念kafka核心组件和流程---控制器kafka核心组件和流程---协调器kafka核心组件和流程- -日志管理器kafka核心组件

单机环境公式建议使用JDK 1.8版,因此本文使用的环境都是JDK 1.8。 虽然本文不详细介绍JDK的安装,但是已经提供了缺省的Java环境。

Kafka依赖zookeeper,因为Kafka通过zookeeper协调现实的分布式系统,所以必须先安装zookeeper。

然后,按照以下步骤安装kafka :

1、下载zookeeper并解压缩。

下载地址: https://zookeeper.Apache.org/releases.html # download

2、创建zookeeper配置文件

在zookeeper解压缩后的目录中找到conf文件夹,然后复制zoo_sample.cfg文件并将其命名为zoo.cfg

zoo.cfg共有四个配置项目,可以使用缺省配置。

3、启动zookeeper。

进入zookeeper根运行混乱的蝴蝶/zkServer.sh start

4、下载kafka并解压缩。

afka 2.0版下载到:

3359 www.Apache.org/dyn/closer.CGI? path=/kaf ka/2.0.0/kaf ka _ 2.11-2.0.0.tgz

5、修改kafka个人资料

进入kafka根目录下的config文件夹,打开server.properties,然后修改以下配置

zookeeper.connect=localhost :2181

broker.id=0

log.dirs=/tmp/kafka-logs

zookeeper.connect是指向zookeeper的链接信息,broker.id是当前kafka实例的id,log.dirs是kafka存储消息内容的路径。

6、启动kafka

进入kafka根目录运行混乱的蝴蝶/Kafka-server-start.sh config/server.properties

此命令指示kaka在启动时使用config/server.properties配置项

启动kafka后,如果控制台上没有显示错误消息,kafka应该成功启动。 可以通过查看zookeeper相关节点的值来确认。 步骤如下。

1、启动zookeeper客户端

进入zookeeper根下,运行混乱的小蝴蝶/ZK CLI.sh-server 127.0.0.133602181。 启动成功后如下图所示

2、输入命令ls /brokers,回到车上,可以看到以下信息。

这些子节点包含由kafka群集管理的数据。 broker是kafka的服务单元实例

3、查看ids节点下的数据,输入命令ls /brokers/ids,可以看到以下信息:

还记得配置独立环境时更改的kafka配置项目broker.id=0吗? 这里的0表示其kafka实例已经加入kafka集群。

集群环境集群环境的构筑也很简单,除了单体环境之外,将多个单体连接在同一个zookeeper上即可。 需要注意的两点:

1、为每个实例设置不同的broker.id。

2 .请注意,如果多个实例部署在同一服务器上,请将log.dirs更改为不同的目录,以避免消息存储库发生冲突。

关于集群环境的具体构筑,在本简化教程中省略详细的讨论。

发送你的第一条kafka信息。 我们用kafka拥有的工具制作topic,发送信息和消费,直观地感受kafka吧。

1、创建主题

进入kafka根目录,然后执行以下命令:

混乱的蝴蝶/Kafka-topics.sh---- create---zookeeper localhost :2181---replication-factor1--partitions1---。

如果执行成功,将创建一个名为study的topic,如下图所示。

该命令行提供了几个参数,其中包括指向zookeeper的链接信息、分区数量和副本数量。 稍后我会详细讨论分区和拷贝,但现在你不用太在意。

2、启动消费者

打开消费者,订阅名为study的topic,然后执行以下命令:

混乱的蝴蝶/Kafka-console-consumer.sh---bootstrap-server localhost 33609092-- topic study-- from-beginning

看下面的照片,光标停留在开头,没有输出任何信息。 表明消费者启动成功。 此时,正在等待新的信息。

3、开启生产者

打开新命令窗口并输入命令

混乱的蝴蝶/Kafka-console-producer.sh---broker-list localhost 33609092---topic study

启动成功后,如下图所示,等待输入新信息。

4、发送你的第一条信息

在上面的生产者窗口输入消息hello kafka,点击回车,如下图所示。

此时,如果切换到消费者窗口,就会发现消费者被该信息消费,并打印在了窗口上。

这样,我们就完成了发送消息的过程。 可以看出,经过topic的创建、生产者、消费者、生产者生产消息、消费者消费消息的开始这几个步骤。

总结:通过本章的学习,我相信我们成功地构建了kafka单体环境,甚至集群环境。 然后,通过kafka拥有的工具,直观地感受到了kafka工作的过程。 接下来的章节将进入kafka的核心领域,也是本教程的重点章节。 只有了解kafka内在的设计理念和原理,才能活用。

下一步:开始学习《kafka核心概念》

版权声明:该文观点仅代表作者本人。处理文章:请发送邮件至 三1五14八八95#扣扣.com 举报,一经查实,本站将立刻删除。