码迷,mamicode.com
首页 >  
搜索关键字:kafka 源码阅读 idea    ( 16514个结果
Kafka集群安装
安装Kafka集群 假设我们有集群中,需要配置4个broker,形成下面图表的Kafka集群。 2.1 配置文件        配置所有的Kafka的Producer文件,其中,brokerpid的值是独一无二的数字值。几个核心属性如下: # The id of the broker.This must be set to a unique integer for each broke...
分类:其他好文   时间:2014-08-29 11:05:47    阅读次数:293
Kafka编程实例
编程     Producer是一个应用程序,它创建消息并发送它们到Kafka broker中。这些producer在本质上是不同。比如,前端应用程序,后端服务,代理服务,适配器对于潜在的系统,Hadoop对于的Producer。这些不同的Producer能够使用不同的语言实现,比如java、C和Python。下面的这部图表解释了消息producer的Kafka API. 下面将详...
分类:其他好文   时间:2014-08-29 11:03:57    阅读次数:277
Kafka介绍
Apache Kafka是一个开源、分布式发布订阅消息系统,主要设计了下面这些特性:       l  持久化消息:从大数据中提取真正的数据值,任何类型的数据丢失都不能够再获取。Apache Kafka提供了持续时间存储大容量消息,其容量按顺心可以达到TB。       l  高吞吐量:为大数据而生,Kafka就是运行在商业硬件上而设计的,它支持每秒百万消息量。       l  分布式:A...
分类:其他好文   时间:2014-08-29 11:03:47    阅读次数:235
java 数据结构. 源码阅读
Collections工具类里的 Collections.synchronizedList public static List synchronizedList(List list) {     return (list instanceof RandomAccess ?                 new SynchronizedRandomAccessList(...
分类:编程语言   时间:2014-08-28 13:20:09    阅读次数:200
《java.util.concurrent 包源码阅读》19 PriorityBlockingQueue
前面讲ScheduledThreadPoolExecutor曾经重点讲到了DelayedWorkQueue,这里说的PriorityBlockingQueue其实是DelayedWorkQueue的简化版本,实现了按序排列元素的功能。也就是说PriorityBlockingQueue是维护一个按序排...
分类:编程语言   时间:2014-08-28 11:03:09    阅读次数:211
《java.util.concurrent 包源码阅读》18 Exchanger
Exchanger可以看做双向数据传输的SynchronousQueue,即没有生产者和消费者之分,任意两个线程都可以交换数据。在JDK5中Exchanger被设计成一个容量为1的容器,存放一个等待线程,直到有另外线程到来就会发生数据交换,然后清空容器,等到下一个到来的线程。从JDK6开始,Exch...
分类:编程语言   时间:2014-08-27 23:20:38    阅读次数:270
SpringMVC 防重复提交拦截
/** ?*?Created?with?IntelliJ?IDEA. ?*?User:?lijian ?*?Date:?14-7-11 ?*?Time:?上午10:38 ?*?description?:防止重复提交数据?????http://hi.baidu.com/uvmfawxtxzbknqe/item/3c87d422...
分类:编程语言   时间:2014-08-27 16:48:38    阅读次数:156
IntelliJ IDEA 13.1安卓的第一个项目开发
下载地址:1.IntelliJ IDEA 13.1安装文件http://yunpan.cn/QazdSvmCcZDsd 提取码 d388 2.IntelliJ IDEA 13.1激活工具 http://yunpan.cn/QazdeAsEuUyCH 提取码 6c1bNew Project相当...
分类:移动开发   时间:2014-08-26 21:23:46    阅读次数:328
《java.util.concurrent 包源码阅读》17 信号量 Semaphore
学过操作系统的朋友都知道信号量,在java.util.concurrent包中也有一个关于信号量的实现:Semaphore。从代码实现的角度来说,信号量与锁很类似,可以看成是一个有限的共享锁,即只能被有限数量的线程使用的共享锁。因为存在计数,因此Semaphore的构造函数有参数permits来设定...
分类:编程语言   时间:2014-08-26 17:00:06    阅读次数:208
Intellij Idea 配置database 连接SQL Server 2012
首先确认通过TCP IP来连接连接SQLServer 2012 确保 Server Authentication选择了SQL Server and Windows Authentication mode 打开 SQL SERVER CONFIGURATION MANAGER, 选择数据库实例,把Na...
分类:数据库   时间:2014-08-26 11:16:56    阅读次数:320
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!