要查看kafka log保存的位置，可以打开kafka安装路径下的config文件夹( kafka_2.13-2.5.0\config) , 然后打开server.properties查看 log.dirs 默认位置是 log.dirs=/tmp/kafka-logs，这个路径 ...

代码共三部分组成 1.zookeeper 初始化 2.数据库连接池 3.代码逻辑 View Code 源码地址 ...

了消费位移对应的消息内容格式，上面是消息的 key ，下面是消息的 value 可以看到 key value 中都包含了 version 宇段，这个用来标识具体的 key value 的版 ...

进入kafka配置文件，修改 server.properties 文件。 ...

在用navicat连接mysql进行数据查询时，保存的.sql文件位置 在navicat左侧，选定对应的连接，然后右键，点击“前往设置保存路径”即可打开查询的保存地址。 ...

继续SparkStreaming整合Kafka 其实将offset保存在zookeeper上不适用于高并发的情况的，于是乎，借鉴上次的代码。将offset保存在Hbasea上的方法也大概写了一下，暂时运行起来是没有问题的。 直接上代码（代码比较粗糙，但是思路应该还算 ...

先来一段到处都有的原理（出处到处都有，就不注明了） Streaming和Kafka整合有两种方式--Receiver和Direct，简单理解为：Receiver方式是通过zookeeper来连接kafka队列，Direct方式是直接连接到kafka的节点上获取数据 Receiver ...

（一）kafka修改topic分区的位置 环境：kafka_2.10-0.8.2.1 + JDK1.7.0_80 1. 查看分区topic的分区分布 $ le-kafka-topics.sh --describe --topic http_zhixin_line1 结果如下： 2. ...