从0.8.x，0.9.x，0.10.0.x，0.10.1.x，0.10.2.x，0.11.0.x，1.0.x或1.1.x升级到2.0.0 Kafka 2.0.0引入了线程协议的变化。通过遵循下面建议的滚动升级计划，您可以保证在升级期间不会出现停机...

JavaEE应用的分层模型 大致分为如下几层： Domain Object(领域对象)层：此层由一系列的POJO(Plain Old Java Object，普通的、传统的Java对象)组成，这些对象时该系统的Domain Object，往往包...

3.1 环境与profile 3.1.1 配置profile bean Spring为不同的环境提供相关的bean，在这个过程中需要根据环境决定该创建哪个bean和不创建哪个bean。不过Spring并不是在构建的时候做出这样的决策...

随机访问：数组在内存中是按顺序存放的，可以通过下标直接定位到某一个元素存放的位置。 顺序访问：链表在内存中不是按顺序存放的，而是通过指针连在一起，为了访问某一元素，必须从链头开始...

作为Java程序员，幸运的是，Java 拥有功能和性能都非常强大的日志库；不幸的是，这样的日志库有不止一个——相信每个人都曾经迷失在JUL(Java Util Log), JCL(Commons Logging), Log4j, SLF4...

转自 Is Hadoop secure for the enterprise? This is the question that data analysts must answer if they want to bring Hadoop to lar......

菜单栏->选项->全局选项->常规->默认会话->编辑默认设置 终端->仿真 终端->外观

在Core Concepts中介绍了三种语义Event time、Processing-time、Ingestion time。 这里需要注意的是：punctuate方法必须使用新数据才能触发。 时间语义设置 如何实现不同的时间语义主要取决于...

To build a processor topology using the Streams DSL, developers can apply the KStreamBuilder class, which is extended from the TopologyBuilder. A simple example is included with...

Processor Stream processor 是processor topology中的一个节点。 Processor API developers定义任意的流处理器，这些流处理器中包括接收数据的处理器、以及与状态存储相关的处理器，共同组成...

Core Concepts Kafka Streams is a client library for processing and analyzing data stored in Kafka. It builds upon important stream processing concepts such as properly distingui...

0.8 version # Licensed to the Apache Software Foundation (ASF) under one or more # contributor license agreements. See the NOTICE file distributed with # this work for additiona...

Using SimpleConsumer Why use SimpleConsumer? The main reason to use a SimpleConsumer implementation is you want greater control over partition consumption than Consumer Groups g...

Using the High Level Consumer Why use the High Level Consumer Sometimes the logic to read messages from Kafka doesn't care about handling the message offsets, it just wants the ...

这个指南提供了一个关于HDFS Federation 特性和怎么配置管理一个联邦集群的概览。 Background HDFS主要包括两层： Namespace 由目录，文件和块组成 支持所有文件系统操作包括增加，删除，修改...