码仙丶

利用zk的watcher功能实时监控zk节点的变化，可以利用这个功能做报警、监控，例如监控kafka的broker，otter的node等，如果有节点挂掉，立时通知

码仙丶

目前kafka版本中，很多公司在用kafka010，但是在用sparkstreaming去消费kafka时，很多人都会碰到一个错误 解决步骤 根据报错信息 可以看出是在这里跑...

焉知非鱼

用 parquet 数据模拟实时数据流 再将 JSON 数据逐行发到 Kafka 的不同 topic：

门朝大海

经常使用mysql 的查询功能，比较少使用删除。最近在网上做了几个sql题，有一个删除的问题，本以为挺简单，确报出如题目的错误，在网上一搜索才发现了这个问题。谨以此作为自己的...

焉知非鱼

Use Spark to read and write HBase data 启动 hbase 在 HBase 中准备 sample 数据 1、运行 HBase shell ...

码仙丶

快速，简单，可靠。HikariCP是一个“零开销”生产就绪JDBC连接池。大约130Kb,它的性能几乎是C3P0、DBCP的25倍，十分强悍引用大话数据库连接池 配置也是十分...

焉知非鱼

https://github.com/scopt/scopt 简单的 scala 命令行选项解析 scopt 是一个小小的命令行选项解析库。 Sonatype 查看上面的 M...