`
文章列表
背景介绍 Kafka简介   Kafka是一种分布式的,基于发布/订阅的消息系统。主要设计目标如下: 以时间复杂度为O(1)的方式提供消息持久化能力,即使对TB级以上数据也能保证常数时间的访问性能 高吞吐率。即使在非常廉价的 ...
原文地址:http://www.aboutyun.com/thread-9938-1-1.html 问题导读1.Kafka提供了Producer类作为java producer的api,此类有几种发送方式?2.总结调用producer.send方法包含哪些流程?3.Producer难以理解的在什么地方? producer的发送方式剖析Kafka提供了Producer类作为java producer的api,该类有sync和async两种发送方式。sync架构图async架构图
介绍      http://kafka.apache.org     kafka是一种高吞吐量的分布式发布订阅消息系统     kafka是linkedin用于日志处理的分布式消息队列,linkedin的日志数据容量大,但对可靠性要求不高,其日志数据主要包括用户行为(登录、浏览、点击、分享、喜欢)以及系统运行日志(CPU、内存、磁盘、网络、系统及进程状态) 
前言: Kafka是一个轻量级的/分布式的/具备replication能力的日志采集组件,通常被集成到应用系统中,收集"用户行为日志"等,并可以使用各种消费终端(consumer)将消息转存到HDFS等其他结构化数据存储系统中.因为日志消息通常为文本数据,尺寸较小,且对实时性以及数据可靠性要求不严格,但是需要日志存储端具备较高的数据吞吐能力,这种"宽松"的设计要求,非常适合使用kafka。 一.入门 1.1 简介 Kafka是一个"分布式的"/"可分区的(partitioned)"/"基于备份的(r ...
当我觉得对Linux系统下修改hostname已经非常熟悉的时候,今天碰到了几个个问题,这几个问题给我好好上了一课,很多知识点,当你觉得你已经掌握的时候,其实你了解的还只是皮毛。技术活,切勿浅尝则止! 实验环境:Red Hat Enterprise Linux Server release 5.7 (Tikanga) ,其它版本Linux可能有所不同。请以实际环境为准。 其实我多次修改过hostname,一般只需要修改 /etc/hosts 和 /etc/sysconfig/network 两个文件下相关配置即可。但是,今天我遇到了两个问题:    问题1: 为什么/etc/syscon ...
Properties Editor 是一款properties文件编辑器。   需求:一般我们在做“国际化”功能时,我们需要properties中文表示方式用unicode表示。eclipse默认properties文件编辑器不方便查看,需要我们查看常常查找unicode编码表。   Properties Editor刚好满足了这个需求,不需要用户常常查看unicode编码表,默认直观表示为中文,用户可以通过文件点击右键Unicode表示查看对应的unicode表示的properties文件。当然这只是Properties Editor的一种功能,其他的功能可以自己熟悉。   Pr ...
maven的依赖管理是基于版本管理的,在maven2之后,把版本管理细化snapshot 快照仓库和release发布仓库。release版本,对于发布状态的artifact(就是被依赖的jar包),如果版本号相同,即使我们内部的镜像服务器上的组件比本地新,ma ...
在abator中可生成iBatis的代码。其中,Sql_map中带有的两个函数是: updateByPrimaryKeySelective updateByPrimaryKey 前者只是更新新的model中不为空的字段。 后者则会将为空的字段在数据库中置为NULL。 例如:Action   [java] view plaincopy  
  目录[-] 1、下载shiro-freemarker-tags 2、Spring MVC配置 3、使用Shiro Tag 目前Freemarker对Shrio的标签还不支持,不过已经有人贡献出来第三方面解决方案,如下: 1、下载shiro-freemarker-tags
公司内部同事分享的一篇文章 周末看到一个用jstack查看死锁的例子。昨天晚上总结了一下jstack(查看线程)、jmap(查看内存)和jstat(性能分析)命令。供大家参考 1.Jstack 1.1   jstack能得到运行java程序的java stack和native stack的信息。可以轻松得知当前线程的运行情况。如下图所示  注:这个和thread dump是同样的结果。但是thread dump是用kill -3 pid命令,还是服务器上面少用kill为妙 1.2   命名行格式 jstack [ option ] pid jstack [ option ] executable ...
准备工作: a. 在pom.xml中配置jetty插件:  Xml代码   <plugins>       <plugin>  
SpringMVC的各种参数绑定方式   1. 基本数据类型(以int为例,其他类似):Controller代码: @RequestMapping("saysth.do") public void test(int count) { } 表单代码: <form action="saysth.do" method="p
使用Request里的Attribute值最简单的方法就是直接${AttributeName}或者安全一点:${AttributeName!"default Value"} 1.取Application范围的对象 xml 代码    1. <#if Application.myApplicationAttribute?exists>      2.      ${Application.myApplication ...
在jsp和class文件中调用的相对路径不同。在jsp里,根目录是WebRoot 在class文件中,根目录是WebRoot/WEB-INF/classes 当然你也可以用System.getProperty("user.dir")获取你工程的绝对路径。 另:在Jsp,Servlet,Java中详细获得路径的方法! 1.jsp中取得路径:以工程名为TEST为例:(1)得到包含工程名的当前页面全路径:request.getRequestURI()结果:/TEST/test.jsp(2)得到工程名:request.getContextPath()结果:/TEST(3)得到当 ...
使用了listener监听器来加载配置,一般在Struts+Spring+Hibernate的项目中都是使用listener监听器的。如下 <listener> <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class> </listener>   Spring会创建一个WebApplicationContext上下文,称为容器 
Global site tag (gtag.js) - Google Analytics