撰写于    浏览:1392 次  分类: kafka研究
上面一篇文章,我说了一点自己的学习经验,其中第(4)点,我提到了Linux的io复用,主要是epoll,我突然感觉可以把这个给大家讲一讲,当做一次公开课内容,因为大家都是搞java的,很少有人即精通c/c++,又精通java的。在我看来:不懂c/c++的人,绝对是不能称之为java大牛的,如果不懂epoll,那就是压根不懂并发。虽然这个观点有点绝对[...]

撰写于    浏览:1904 次  分类: kafka研究
个人感觉,学好Kafka还是有一定难度的。比起mybatis框架而言,它需要掌握更多的知识点。依照个人经验来看,学习Kafka应该做到以下几点:(1)熟悉zookeeper,要把它的命令搞清楚,能熟练使用,还有它的应用场景也要吃透,不光大数据框架离不开zookeeper,现在做web开发的人一旦涉及到分布式的应用,往往也需要zookeeper来支撑[...]

撰写于    浏览:833 次  分类: kafka研究
server.properties是Kafka的主要配置文件,下面简单介绍其中的相关配置项的含义。必须修改的配置项就是log.dirs,其他配置可以根据需求自行修改。# 每一个Broker在集群中的唯标识。即使Broker的IP地址发生了变化,broker.id只要没变,则不会影响consumers的消息情况 broker.id=0 # 是否允许T[...]

撰写于    浏览:697 次  分类: kafka研究
kafka-server-start脚本通过kafka-run-class脚本调用Kafka类来启动Broker,在调用kafka-run-class脚本之前会进行检测命令行参数、设置log4j配置文件、设置JVM内存参数等操作。#!/bin/bash if [$# -lt 1]; #检查参数个数 then #打印命令用法 echo &quo[...]

撰写于    浏览:661 次  分类: kafka研究
为了方便管理和使用,Kafka提供了很多管理脚本,Linux版本的管理脚本存放在$KAFKA_ HOME/bin目录下(在$KAFKA_ HOME/bin/windows 目录下可以找到对应的Windows脚本)。下面先来介绍常用脚本的功能。kafka-server-start脚本:启动Kafka Server。kafka-server-stop脚[...]