引言 Kafka中的Message是以topic为基本单位组织的，不同的 topic之间是相互独立的。每个topic又可以分成几个不同的partition(每个topic有几个partition是在创建topic时指定 的)，每个partition存储一部分Message...
分类：
其他好文 时间：
2015-09-29 19:07:13
阅读次数：
192
前言: 上周末自己学习了一下Kafka，参考网上的文章，学习过程中还是比较顺利的，遇到的一些问题最终也都解决了，现在将学习的过程记录与此，供以后自己查阅，如果能帮助到其他人，自然是更好的。======================================================.....
分类：
其他好文 时间：
2015-09-29 13:05:32
阅读次数：
279
class Producer implements Runnable{ private final Queue queue; private final static int MAX_SIZE = 200; Producer(Queue q) { queue =...
分类：
其他好文 时间：
2015-09-26 17:18:19
阅读次数：
149
基本操作 本节将列一下在Kafka集群上的最常用的操作。所有在本节被提到的工作都可以$KAFKA_HOME/bin目录下找到；并且每个工具都会较详细的打印命令的所有可能的选项。 添加和移除Topic 你可以手动创建一个Topic也...
分类：
其他好文 时间：
2015-09-26 16:02:25
阅读次数：
145
producer把消息发送到消息块，consumer从块读取消息。 安装： Install-Package Microsoft.Tpl.Dataflow using System.Threading.Tasks.Dataflow; 解释： Produce方法随机生成字节，并Post到ITargetB...
分类：
其他好文 时间：
2015-09-25 13:09:48
阅读次数：
287
一直在做技术选型，Kafka还要学习scala,蛋疼，MetaQ太重， 朋友推荐HTTPSQS,自己看了几个MQ,最终决定引入轻量级的ZBus. ---这里的版本号是 6.2.0 http://git.oschina.net/rushmore/zbus/tree/6.2.0-release/ 下载...
分类：
其他好文 时间：
2015-09-24 17:52:28
阅读次数：
426
kafka 监控插件 1.KafkaOffsetMonitor 项目地址：https://github.com/quantifind/KafkaOffsetMonitor KafkaOffsetMonitor是用来实时监控Kafka集群的consumers以及它们在partition中的offset(偏移量)。 You can se...
分类：
其他好文 时间：
2015-09-23 17:26:45
阅读次数：
368
博文作者：妳那伊抹微笑博客地址：http://blog.csdn.net/u012185296博文标题：_00023 Kafka 诡异操作_001自己定义Encoder实现Class级别的数据传送以及解析个性签名：世界上最遥远的距离不是天涯，也不是海角。而是我站在妳的面前，妳却感觉不到我的存在技术方...
分类：
Web程序 时间：
2015-09-20 20:37:01
阅读次数：
545
ActiveMQ发送和接收消息的过程和jdbc操作数据库很类似：首先创建Connection连接对象，再获取Session会话对象，之后通过Session会话对象创建Producer、Consumer、Message等对象，只不过ActiveMQ的Connection对象是...
分类：
其他好文 时间：
2015-09-18 12:16:14
阅读次数：
1586
