作者：程序猿DD   原文地址

我们在构建分布式系统的时候，经常需要控制对共享资源的互斥访问。这个时候我们就涉及到分布式锁（也称为全局锁）的实现，基于目前的各种工具，我们已经有了大量的实现方式，比如：基于Redis的实现、基于Zookeeper的实现。本文将介绍一种基于Consul 的Key/Value存储来实现分布式锁以及信号量的方法。

阅读全文

原文链接 译者：dan   QQ：903585177

请注意：这个指南并不是用户指南，它是开发 Netty 本身的指南，而不是使用Netty 开发其他程序的指南。

阅读全文

快速入门

• 翻译者：kimmking@163.com
• 原文：kafka.apache.org/quickstart

本教程假设读者完全从零开始，电脑上没有已经存在的Kafka和Zookeeper环境。以下内容需要注意的是：因为在类Unix平台和Windows平台上的Kafka控制脚本不同，在Windows平台上，需要使用路径\bin\windows代替/bin，脚本扩展名改为.bat。

阅读全文

原文链接

Kafka是一个分布式的流平台。这意味着什么？

我们认为流平台有3个核心的能力

1. 允许发布和订阅记录流。在这方面类似消息队列和企业级的消息系统。
2. 允许以容错的方式存储记录流。
3. 允许以流的形式处理记录。

阅读全文

原文链接  译者：hjjxd    校对：清英

Flink中的分析程序实现了对数据集的某些操作 (例如，数据过滤，映射，合并，分组)。这些数据最初来源于特定的数据源(例如来自于读文件或数据集合)。操作执行的结果通过数据池以写入数据到(分布式)文件系统或标准输出(例如命令行终端)的形式返回。Flink程序可以运行在不同的环境中，既能够独立运行，也可以嵌入到其他程序中运行。程序可以运行在本地的JVM上，也可以运行在服务器集群中。

阅读全文

作者：Base

Ambari 整体架构图，由图中可以看出，主要有4部分： 阅读全文

作者：Base

Ambari 是 Apache Software Foundation 的一个顶级开源项目，是一个集中部署、管理、监控 Hadoop 分布式集群的工具。但是这里的 Hadoop 是一个广义概念，并不仅仅指的是 Hadoop（HDFS、MapReduce），而是指 Hadoop 生态圈（包括 Spark、Hive、Hbase，Sqoop，Zookeeper、Flume 等），Ambari 可以使 Hadoop 大数据软件更容易使用，且可以方便的集成我们自己的服务让 Ambari 统一管理。
阅读全文

原文链接 译者：flystarfly

2. APIs

Kafka包含四种核心的API:

1. Producer API支持应用将数据流发送到Kafka集群的主题。
2. Consumer API支持应用从Kafka集群的主题中读取数据流。
3. Streams API支持数据流从输入主题转化到输出主题。
4. Connect API支持实现持续地从一些源系统或应用划入Kafka或者从Kafka推入一些源系统或应用的接口。

阅读全文

来讲解一下Maven 2.0 插件的发展

阅读全文

原文链接

批处理示例

下面的程序展示了从简单的单词词频统计到图算法等不同的Flink应用。代码展示了Flink数据集API的使用方法。

下面案例和更多案例的完整源码可以参见Flink源码中的flink-examples-batch和 flink-examples-streaming模块。

阅读全文

原文连接

以下是Apache Kafka™的一些常见使用场景的描述。有关这些实践领域的一些概述，请参阅此博文。

阅读全文

之前在北京面试，很多应聘者都提到自己使用过KAFAKA，所以计划组织同学们翻译《KAFKA官方指南》，欢迎有兴趣的同学参与。

阅读全文

原文链接 译者：ivansong

本文档针对的是Apache Flink的 1.2.0版本。

Apache Flink是一个分布式流式和批量数据处理程序的开源平台。Flink的核心是流式数据引擎，Flink通过数据流的分布式计算的方式提供数据的分发、通信和容错。Flink也构建了流引擎之上的批处理，覆盖本地迭代上的支持，内存管理和程序优化。

阅读全文

我总是在思考如何才能学得快学得精，学得和别人不一样。看过很多本书之后，我发现无论掌握何种技巧，最基本的原则是要努力的刻意练习，才能从新手走向大师。前段时间读了一本书叫《刻意练习-如何从新手到大师》觉得不错，我总结了一下分享给大家。

阅读全文