240 发简信
IP属地:台湾
  • python导包错误 ImportError: cannot import name a

    开发工具pycharm 运行方式 pycharm右键运行 python命令执行 项目目录结构cloud_platform 代码 问题 在pych...

  • kafka消息格式

    kafka发送消息是有消息格式的,有三个版本V0,V1,V2 V0版本:主要指kafka0.10.0.0之前的版本,是kafka最早的消息版本,...

  • sparkStreaming拉取kafka010的bug

    目前kafka版本中,很多公司在用kafka010,但是在用sparkstreaming去消费kafka时,很多人都会碰到一个错误 解决步骤 根...

  • zookeeper的watcher

    利用zk的watcher功能实时监控zk节点的变化,可以利用这个功能做报警、监控,例如监控kafka的broker,otter的node等,如果...

  • sparkstreaming将offset存到hbase

    之前一直将offset存到zookeeper,由于streaming程序会对zk有大量的读取操作,故将offset存到zk不太好,现已将offs...

  • HikariCP数据库连接池

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

    0.2 7634 4 16
  • kafka删除topic

    删除kafka topic及其数据,严格来说并不是很难的操作。但是,往往给kafka 使用者带来诸多问题,发现都会偶然出现无法彻底删除kafka...

  • Resize,w 360,h 240
    flume监控inode变化的文件

    由于要实时读取redis的AOF文件,但是flume的taildir source在监控文件的时候,如果文件的inode变化了,那么会出现重复读...

  • HBase新版本Java API

    HBase新版本Java API 之前没有码全,这次增删改查全乎了,网上有很多例子,自己根据实际在用的收集总结了一下 导入的包 初始化连接对象 ...