原文地址:http://blog.csdn.net/honglei915/article/details/37760631消息格式消息由一个固定长度的头部和可变长度的字节数组组成。头部包括了一个版本和CRC32校验码。	/** * 具有N个字节的消息的格式例如以下 * * 假设版本是0	...
                            
                            
                                分类:
其他好文   时间:
2014-08-09 15:45:28   
                                阅读次数:
339
                             
                         
                    
                        
                            
                            
                                Kafka提供了Producer类作为java producer的api,该类有sync和async两种发送方式。...
                            
                            
                                分类:
其他好文   时间:
2014-08-08 18:22:46   
                                阅读次数:
276
                             
                         
                    
                        
                            
                            
                                基于storm的online-ar算法(基于youtube视频推荐算法)...
                            
                            
                                分类:
其他好文   时间:
2014-08-08 18:11:16   
                                阅读次数:
226
                             
                         
                    
                        
                            
                            
                                本文将从以下两个方面去尝试讲解Kafka的设计理念,主要参考文献在这里: Kafka设计背景及原因 Kafka的设计特色 Kafka设计背景及原因 Kafka最初被LinkedIn设计来处理活动流数据(activity stream data)和系统处理数...
                            
                            
                                分类:
其他好文   时间:
2014-08-08 16:36:56   
                                阅读次数:
237
                             
                         
                    
                        
                            
                            
                                Apache kafka性能优化架构分析,分析了那些因素会影响kafka性能。kafka内部实现做了哪些优化和处理。...
                            
                            
                                分类:
其他好文   时间:
2014-08-08 16:06:46   
                                阅读次数:
298
                             
                         
                    
                        
                            
                            
                                什么时间使用高级应用? 针对一个消息读取多次 在一个process中,仅仅处理一个topic中的一组partitions 使用事务,确保每个消息只被处理一次 使用高级应用(调用较底层函数)的缺点? ????SimpleConsumer需要...
                            
                            
                                分类:
编程语言   时间:
2014-08-08 13:01:46   
                                阅读次数:
340
                             
                         
                    
                        
                            
                            
                                由于项目需要,最近对storm进行了预研,安装与使用方式网上有很多示例,在此记录一下,备忘。 一、storm简介 ????Storm的术语包括Stream、Spout、Bolt、Task、Worker、Stream Grouping和Topology。S...
                            
                            
                                分类:
其他好文   时间:
2014-08-06 12:04:11   
                                阅读次数:
409
                             
                         
                    
                        
                            
                            
                                1 背景 最近由于项目需要,需要使用kafka的producer。但是对于c++,kafka官方并没有很好的支持。 在kafka官网上可以找到0.8.x的客户端。可以使用的客户端有C版本客户端,此客户端虽然目前看来还较为活跃,但是代码问题还是较多的,而且对于c++的支持并不是很好。 还有c++版本,...
                            
                            
                                分类:
其他好文   时间:
2014-08-06 01:42:30   
                                阅读次数:
407
                             
                         
                    
                        
                            
                            
                                官方的解释这个类为:/** * A simple, durable, atomic K/V database. *Very inefficient*, should only be * used for occasional reads/writes. Every read/write hits d...
                            
                            
                                分类:
其他好文   时间:
2014-08-05 22:23:00   
                                阅读次数:
321