klion26
  • Archives
  • Categories
  • Tags
  • Resume
  • About

kafka

2017

  • 2017-06-03 » Streaming 程序调用 Producer.close hang 住问题追查复盘
  • 2017-06-01 » 如何在不重启 Spark Streaming 作业的情况下,增加消费的 topic
  • 2017-02-16 » Spark Streaming 统一在每分钟的 00 秒消费 Kafka 数据的问题解决
  • 2017-01-15 » Spark Streaming 往 HDFS 追加 LZO 文件

2016

  • 2016-12-16 » Spark Streaming Ran out of messages before reaching ending offset 异常
  • 2016-12-02 » Spark Streaming 从指定时间戳开始消费 kafka 数据
  • 2016-11-01 » Spark Streaming 自适应上游 kafka topic partition 数目变化
  • 2016-08-27 » Spark Streaming 从 Kafka 读取 binlog 转换成 Json
  • 2016-07-15 » Spark Streaming 中使用 zookeeper 保存 offset 并重用(二)
  • 2016-07-14 » Spark Streaming 中使用 zookeeper 保存 offset 并重用

Categories

  • ACM16
  • Algorithm14
  • HDU1
  • HDU9
  • Linux32
  • POJ6
  • TeX1
  • USACO21
  • Uncategorized3
  • Visual C++1
  • problem_solve1
  • wordpress8
  • 具体数学2
  • 分布式系统9
  • 复盘1
  • 实时计算7
  • 实时计算5
  • 想清楚2
  • 想清楚1
  • 成长3
  • 我的生活9
  • 所谓开源3
  • 数学1
  • 数学2
  • 数学2
  • 源码阅读1
  • 源码阅读1
  • 计算机图形学图像处理1
  • 计算机图形学图像处理1
  • 计算机基础1
  • 计算机基础1
  • 计算机基础2
  • 计算机基础22
  • 计算机基础1
  • 计算机安全3
  • 语言学习1
  • 语言学习2

Tag Cloud

  • problem_solve2
  • ran_out_of_messages1
  • english1
  • real_time-computing2
  • algorithm14
  • 数学5
  • zookeeper3
  • spark-streaming7
  • fedora15
  • binary-tree1
  • ndbm1
  • 线程堆栈2
  • 教师1
  • array1
  • 数论5
  • HDFS1
  • apache-storm2
  • daemon1
  • receiver1
  • mapreduce1
  • ...312

Recent Posts

  • 一次 InputStream#read 使用不当导致的问题
  • Flink-State
  • Java 内存泄漏分析和对内存设置
  • 通过 Java 线程堆栈进行性能瓶颈分析
  • 线程堆栈分析

Links

  • My Github
  • Debug0
  • 代码疯子
  • NARUTOACM
  • tanglei的blog
  • 微空间
  • 小昭的荒地
  • 异想天开
  • 远行
  • 张学程

日历云

© 2018 klion26 with help from Hexo and Twitter Bootstrap. Theme by Freemind.

▲