在虚拟机安装的Linux上配置VNC需要注意一下几点，我装的是RedHat Enterprise 4：保证Linux拥有自己独立的IP。这个问题可以通过设置虚拟机的网络连接方式解决。在Network adapter里选择第一项：Bridged。这样可以保证虚拟机独立连接局域网，而不是和Host共享IP地址。设置改变后，一定要重启Linux才能生效。保证Linux上VNC使用的端口和VMware里允

在虚拟机安装的Linux上配置VNC需要注意一下几点，我装的是RedHat Enterprise 4：保证Linux拥有自己独立的IP。这个问题可以通过设置虚拟机的网络连接方式解决。在Network adapter里选择第一项：Bridged。这样可以保证虚拟机独立连接局域网，而不是和Host共享IP地址。设置改变后，一定要重启Linux才能生效。保证Linux上VNC使用的端口和VMware里允

当路径中的元素包括在方括号里比如[xyz],则表示xyz表示的值是不固定的，每个可能的值都有一个Zookeeper节点。比如/topics/[topic]表示每个topic名称对应/topics的一个子目录。也可以用类似[0...5]表示一个数值范围来表示含有子目录0,1,2,3,4的目录。箭头->表示znode的节点含有某个内容，比如/hello->word表示一个含有“world”的节点。

4.6 消息传输的事务定义之前讨论了consumer和producer是怎么工作的，现在来讨论一下数据传输方面。数据传输的事务定义通常有以下三种级别：最多一次: 消息不会被重复发送，最多被传输一次，但也有可能一次不传输。最少一次: 消息不会被漏发送，最少被传输一次，但也有可能被重复传输.精确的一次（Exactly once）:  不会漏传输也不会重复传输,每个消息都传输被一次而且仅

4.2 Persistence（持久化）不要畏惧文件系统!Kafka大量依赖文件系统去存储和缓存消息。对于硬盘有个传统的观念是硬盘总是很慢，这使很多人怀疑基于文件系统的架构能否提供优异的性能。实际上硬盘的快慢完全取决于使用它的方式。设计良好的硬盘架构可以和内存一样快。在6块7200转的SATA RAID-5磁盘阵列的线性写速度差不多是600MB/s，但是随即写的速度却是

读操作需要两个参数：一个64位的offset和一个S字节的最大读取量。S通常比单个消息的大小要大，但在一些个别消息比较大的情况下，S会小于单个消息的大小。这种情况下读操作会不断重试，每次重试都会讲读取量加倍，直到读取到一个完整的消息。可以配置单个消息的最大值，这样服务器就会拒绝大小超过这个值的消息。也可以给客户端指定一个尝试读取的最大上限，避免为了读到一个完整的消息而无限次的重试。

Kafka允许tipci的分区拥有若干副本，这个数量是可以配置的，你可以为每个topci配置一个副本数量。Kafka会自动的在个副本上备份数据，所以当一个server down掉时数据依然是可用的。Kafka的副本功能不是必须的，你可以配置只有一个副本，这样其实就相当于只有一份数据。创建副本的单位是topic的分区，每个分区都有一个leader和零或多个followers.所有的读写操作都

Consumer API有两个级别。低级别的和一个指定的broker保持连接，并在接收完消息后关闭连接，这个级别是无状态的，每次读取消息都带着offset。高级别的API隐藏了和brokers连接的细节，在不必关心服务端架构的情况下和服务端通信。还可以自己维护消费状态，并可以通过一些条件指定订阅特定的topic,比如白名单黑名单或者正则表达式。

Kakfa在提高效率方面做了很大努力。Kakfa的一个主要使用场景是处理网站活动日志，吞吐量是非常大的，每个页面都会产生好多次写操作。读方面，假设每个消息只被消费一次，读的量的也是很大的，Kafka也尽量使读的操作更轻量化。我们之前讨论了磁盘的性能问题，线性读写的情况下影响磁盘性能问题大约有两个方面：太多的琐碎的I/O操作和太多的字节拷贝。

上篇文章中我们搭建了kafka的服务器，并可以使用Kafka的命令行工具创建topci，发送和接收消息。下面我们来搭建kafka的开发环境。大家开发环境需要引入kafka的jar包，一种方式是将Kafka安装包中lib下的jar包加入到项目的classpath中，这种比较简单了。不过我们使用另一种更加流行的方式，使用maven管理jar包依赖。创建好maven项目后，在