连接器开发指引 该指引介绍开发者如何为Kafka Connect写一个新连接器，来在Kafka和其它系统间移动数据。先简要的回顾一些概念，然后介绍如果创建一个简单连接 核心概念和API 连接器和任务 为了在Kafka和其…

0 前言 Kafka作为近几年十分流行，虽然它自己定位为一个分布式流结构平台’distributed streaming platform’，但是我们大部分时间还是当做是一个MQ来使用:P。 刚好…

1.架构流程 telegraf 收集数据 kafka 消息队列 java 消费程序 clickhousen 存放数据 grafana 展示数据 2.telegraf 介绍 Telegraf 是收集和报告指标和数据的代理。…

Kafka集群安装、配置和启动 Kafka需要依赖zookeeper，并且自身集成了zookeeper，zookeeper至少需要3个节点保证集群高可用，下面是在单机linux下创建kafka3个节点伪集群模式。 1、下…

今天解读的内容是来自 Spark Summit East 2017 关于 Spark Streaming 应用程序开发的一个介绍： What No One Tells You About Writing a Stream…

Kafka Coordinator.

Spring for Apache Kafka 2.2 已经发布，该版本修复了一些问题。 目前，2.1.x版本与2.0.0 kafka-clients jar兼容（从2.1.9开始），但此版本需要2.0.0（并提供2.0…

1.算法学习 《Algorithms Part 1》第一周问题集（1） 《Algorithms Part 1》第一周问题集（2） 《Algorithms Part 1》第一周问题集（3） 《Algorithms Part…

用kafka connect做ETL，会造成数据丢失或者数据重复吗？如果是的话，有什么办法解决吗

Log4j Java的爱好者们，一定对log4j是特别的熟悉，基本大多数项目都会选择log4j、slg4j来进行log记录。 但是对于log4j.properties的配置可能理解的不是特别熟悉，所有我准备整理一下，同时…

第一，谈谈final， finally， finalize的区别。 最常被问到。final修饰符（关键字）如果一个类被声明为final，意味着它不能再派生出新的子类，不能作为父类被继承。因此一个类不能既被声明为 abst…

TIPS本文基于Spring Cloud Greenwich SR1 + spring-cloud-starter-stream-rocketmq 0.9.0理论兼容：Spring Cloud Finchley+ + s…