kafka原理及架构是什么


这篇文章主要介绍“kafka原理及架构是什么”,在日常操作中,相信很多人在kafka原理及架构是什么问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”kafka原理及架构是什么”的疑惑有所帮助!接下来,请跟着小编一起来学习吧!由LinkedIn 公司开发的一个分布式的消息系统;
高吞吐率;
支持Kafka Server间的消息分区,及分布式消费
同时支持离线数据处理和实时数据处理;
支持在线水平扩展。kafka基本名词解释kafka顺序写磁盘Kafka的文件存储机制Kafka的文件复制原理Kafka的数据可靠性的保证request.required.acks=-1参数来设置数据可靠性的级别
min.insync.replicas配合使用Kafka的发送模式,默认同步producer.type=sync,以下是异步的参数Kafka的消息传输保障At most once: 消息可能会丢,但绝不会重复传输
At least once:消息绝不会丢,但可能会重复传输
Exactly once:每条消息肯定会被传输一次且仅传输一次Kafka的单节点搭建Kafka版本下载
配置server.properties和consumer.properties
Kafka依赖zookeeper1:下载kafka
地址:http://kafka.apache.org/downloads2:上传安装包到服务器上面,并且进行解压3:进入kafka的安装目录下的con 香港云主机fig目录
1)编辑server.properties文件,修改zk的服务地址,比如:
zookeeper.connect=hm02:2181,hs0201:2181,hs0202:2181 2)编辑consumer.properties文件,修改zk的服务地址,比如:
zookeeper.connect=hm02:2181,hs0201:2181,hs0202:21814:启动zk集群
./zookeeper-3.4.8/bin/zkServer.sh start5:启动kafka的server
./bin/kafka-server-start.sh config/server.properties 启动kafka服务6:克隆一个会话来进行创建一个主题,topic
./bin/kafka-topics.sh –create –zookeeper hm02:2181,hs0201:2181,hs0202:2181 –replication-factor 1 –partitions 1 –topic mykaka 查看有那些topic:
./bin/kafka-topics.sh –list –zookeeper hm02:2181,hs0201:2181,hs0202:21817:创建一个生产者,这里是使用命令行的producer
./bin/kafka-console-producer.sh –broker-list localhost:9092 –topic mykaka8:创建一个消费者,这里也是用命令行的consumer
./bin/kafka-console-consumer.sh –bootstrap-server localhost:9092 –topic mykaka –from-beginning到此,关于“kafka原理及架构是什么”的学习就结束了,希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习,快去试试吧!若想继续学习更多相关知识,请继续关注开发云网站,小编会继续努力为大家带来更多实用的文章!

相关推荐: SpringCloud的入门概述以及如何进行Rest微服务案例构建

本篇文章给大家分享的是有关SpringCloud的入门概述以及如何进行Rest微服务案例构建,小编觉得挺实用的,因此分享给大家学习,希望大家阅读完这篇文章后可以有所收获,话不多说,跟着小编一起来看看吧。官网以Dept部门模块做一个微服务通用案例、Consume…

免责声明:本站发布的图片视频文字,以转载和分享为主,文章观点不代表本站立场,本站不承担相关法律责任;如果涉及侵权请联系邮箱:360163164@qq.com举报,并提供相关证据,经查实将立刻删除涉嫌侵权内容。

(0)
打赏 微信扫一扫 微信扫一扫
上一篇 08/16 10:24
下一篇 08/16 10:24

相关推荐