发布于 2016-10-21 00:31:50 | 220 次阅读 | 评论: 0 | 来源: 网友投递
Apache Kafka 开源消息系统
Apache Kafka是一个开源消息系统项目,由Scala写成。该项目的目标是为处理实时数据提供一个统一、高通量、低等待的平台。
Apache Kafka 0.10.1.0 发布了,该版本更新了大量内容,主要改进如下:
新特性
[KAFKA-1464] - Add a throttling option to the Kafka replication tool
[KAFKA-3176] - Allow console consumer to consume from particular partitions when new consumer is used.
[KAFKA-3492] - support quota based on authenticated user name
[KAFKA-3776] - Unify store and downstream caching in streams
[KAFKA-3858] - Add functions to print stream topologies
[KAFKA-3909] - Queryable state for Kafka Streams
[KAFKA-4015] - Change cleanup.policy config to accept a list of valid policies
[KAFKA-4093] - Cluster id
改进
[KAFKA-724] - Allow automatic socket.send.buffer from operating system
[KAFKA-1981] - Make log compaction point configurable
[KAFKA-2063] - Bound fetch response size (KIP-74)
[KAFKA-2547] - Make DynamicConfigManager to use the ZkNodeChangeNotificationListener introduced as part of KAFKA-2211
[KAFKA-2800] - Update outdated dependencies
[KAFKA-3158] - ConsumerGroupCommand should tell whether group is actually dead
[KAFKA-3281] - Improve message of stop scripts when no processes are running
[KAFKA-3282] - Change tools to use new consumer if zookeeper is not specified
[KAFKA-3283] - Remove beta from new consumer documentation
[KAFKA-3479] - Add new consumer metrics documentation
[KAFKA-3595] - Add capability to specify replication compact option for stream store
[KAFKA-3644] - Use Boolean protocol type for StopReplicaRequest delete_partitions
[KAFKA-3680] - Make Java client classloading more flexible
[KAFKA-3683] - Add file descriptor recommendation to ops guide
[KAFKA-3697] - Clean-up website documentation when it comes to clients
[KAFKA-3699] - Update protocol page on website to explain how KIP-35 should be used
[KAFKA-3711] - Allow configuration of MetricsReporter subclasses
[KAFKA-3732] - Add an auto accept option to kafka-acls.sh
[KAFKA-3748] - Add consumer-property to console tools consumer (similar to --producer-property)
[KAFKA-3749] - "BOOSTRAP_SERVERS_DOC" typo in CommonClientConfigs
[KAFKA-3753] - Add approximateNumEntries() to the StateStore interface for metrics reporting
[KAFKA-3760] - Set broker state as running after publishing to ZooKeeper
[KAFKA-3762] - Log.loadSegments() should log the message in exception
[KAFKA-3765] - Code style issues in Kafka
[KAFKA-3768] - Replace all pattern match on boolean value by if/elase block.
下载地址
源代码
https://www.apache.org/dyn/closer.cgi?path=/kafka/0.10.1.0/kafka-0.10.1.0-src.tgz
二进制文件
https://www.apache.org/dyn/closer.cgi?path=/kafka/0.10.1.0/kafka_2.11-0.10.1.0.tgz
https://www.apache.org/dyn/closer.cgi?path=/kafka/0.10.1.0/kafka_2.10-0.10.1.0.tgz