240 发简信
码仙丶
IP属地：天津
  • python导包错误 ImportError: cannot import name a

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

    11414 0 2
  • kafka消息格式

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

    5333 0 0
  • sparkStreaming拉取kafka010的bug

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

    0.2 5739 0 4
  • zookeeper的watcher

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

    0.1 448 3 2
  • sparkstreaming将offset存到hbase

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

    1509 6 3
  • HikariCP数据库连接池

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

    0.2 7631 4 16
  • kafka删除topic

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

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

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

    1793 5 3
  • HBase新版本Java API

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

    2938 5 5 1
暂无个人介绍