设为首页收藏本站

LUPA开源社区

 找回密码
 注册
文章 帖子 博客
LUPA开源社区 首页 业界资讯 软件追踪 查看内容

Apache Kafka 0.11.0.0发布,分布式消息发布订阅系统

2017-6-29 21:25| 发布者: joejoe0332| 查看: 913| 评论: 0|原作者: oschina|来自: oschina

摘要: Apache Kafka 0.11.0.0 发布了。kafka 是一种高吞吐量的分布式发布订阅消息系统。New Feature - KIP-146: Support per-connector/per-task classloaders in Connect - Add Record Headers - Add purgeDataBefore() A ...

Apache Kafka 0.11.0.0 发布了。kafka 是一种高吞吐量的分布式发布订阅消息系统。

New Feature

  • [KAFKA-3487] - KIP-146: Support per-connector/per-task classloaders in Connect

  • [KAFKA-4208] - Add Record Headers

  • [KAFKA-4586] - Add purgeDataBefore() API in AdminClient

  • [KAFKA-4720] - Add KStream.peek(ForeachAction

    )
  • [KAFKA-4743] - Add a tool to Reset Consumer Group Offsets

  • [KAFKA-4881] - Add internal leave.group.on.close config to consumer

  • [KAFKA-4923] - Add Exactly-Once Semantics to Streams

  • [KAFKA-5059] - Implement Transactional Coordinator

  • [KAFKA-5192] - Range Scan for Windowed State Stores

Improvement

  • [KAFKA-1449] - Extend wire protocol to allow CRC32C

  • [KAFKA-2358] - Cluster collection returning methods should never return null

  • [KAFKA-2955] - Add Prompt to kafka-console-producer

  • [KAFKA-3714] - Allow users greater access to register custom streams metrics

  • [KAFKA-3878] - Exponential backoff for broker reconnect attempts (KIP-144)

  • [KAFKA-3989] - Add JMH module for Benchmarks

  • [KAFKA-3995] - Split the ProducerBatch and resend when received RecordTooLargeException

  • [KAFKA-4144] - Allow per stream/table timestamp extractor

  • [KAFKA-4195] - support throttling on request rate

  • [KAFKA-4266] - Replication Quota Tests: Ensure ZK updated before tests start

  • [KAFKA-4276] - REST configuration not visible in connector properties config files

  • [KAFKA-4291] - TopicCommand --describe shows topics marked for deletion as under-replicated and unavailable (KIP-137)

  • [KAFKA-4317] - RocksDB checkpoint files lost on kill -9

  • [KAFKA-4613] - Treat null-key records the same way for joins and aggreations

  • [KAFKA-4636] - Per listener security setting overrides (KIP-103)

  • [KAFKA-4684] - Kafka does not offer kafka-configs.bat on Windows box

  • [KAFKA-4702] - Parametrize streams benchmarks to run at scale

  • [KAFKA-4709] - Error message from Struct.validate() should include the name of the offending field.

  • [KAFKA-4722] - Add application.id to StreamThread name

  • [KAFKA-4733] - Improve Streams Reset Tool console output

  • [KAFKA-4769] - Add Float serializer, deserializer, serde

  • [KAFKA-4772] - Exploit #peek to implement #print() and other methods

  • [KAFKA-4773] - The Kafka build should run findbugs

  • [KAFKA-4774] - Inner classes which don't need a reference to the outer class should be static

  • [KAFKA-4775] - Fix findbugs warnings in kafka-tools

  • [KAFKA-4839] - throw NoOffsetForPartitionException once for all assigned partitions from poll

  • [KAFKA-4843] - Stream round-robin scheduler is inneficient

  • [KAFKA-4922] - Fix several FindBugs warnings in Clients and Connect

  • [KAFKA-4943] - SCRAM secret's should be better protected with Zookeeper ACLs

  • [KAFKA-4965] - set internal.leave.group.on.close to false in KafkaStreams

  • [KAFKA-4982] - Add listener tag to socket-server-metrics.connection-... metrics (KIP-136)

  • [KAFKA-5036] - Followups from KIP-101

  • [KAFKA-5052] - We shouldn't pass the underlying exception to RetriableCommitFailedException when an async offset commit fails.

  • [KAFKA-5068] - Optionally print out metrics after running the perf tests

  • [KAFKA-5091] - ReassignPartitionsCommand should protect against empty replica list assignment

  • [KAFKA-5094] - Censor SCRAM config change logging

  • [KAFKA-5104] - DumpLogSegments should not open index files with `rw`

  • [KAFKA-5108] - Add support for reading PID snapshot files to DumpLogSegments

  • [KAFKA-5111] - Improve internal Task APIs

  • [KAFKA-5112] - Trunk compatibility tests should test against 0.10.2

  • [KAFKA-5118] - Improve message for Kafka failed startup with non-Kafka data in data.dirs

  • [KAFKA-5137] - Controlled shutdown timeout message improvement

  • [KAFKA-5161] - reassign-partitions to check if broker of ID exists in cluster

  • [KAFKA-5166] - Add option "dry run" to Streams application reset tool

  • [KAFKA-5176] - AdminClient: add controller and clusterId methods to DescribeClusterResults

  • [KAFKA-5194] - KIP-153: Include only client traffic in BytesOutPerSec metric

  • [KAFKA-5210] - Application Reset Tool does not need to seek for internal topics

  • [KAFKA-5218] - New Short serializer, deserializer, serde

  • [KAFKA-5257] - Change Default unclean.leader.election.enabled from True to False

  • [KAFKA-5277] - Sticky Assignor should not cache the calculated assignment (KIP-54 follow-up)

  • [KAFKA-5311] - Support ExtendedDeserializer in Kafka Streams

  • [KAFKA-5333] - Remove Broker ACL resource type

  • [KAFKA-5405] - Request log should log throttle time

  • [KAFKA-5411] - Generate javadoc for AdminClient and show configs in documentation

  • [KAFKA-5446] - Annoying braces showed on log.error using streams

发布详情参见:http://www.mirrorservice.org/sites/ftp.apache.org/kafka/0.11.0.0/RELEASE_NOTES.html

下载地址:

http://kafka.apache.org/downloads

酷毙

雷人

鲜花

鸡蛋

漂亮
  • 快毕业了,没工作经验,
    找份工作好难啊?
    赶紧去人才芯片公司磨练吧!!

最新评论

关于LUPA|人才芯片工程|人才招聘|LUPA认证|LUPA教育|LUPA开源社区 ( 浙B2-20090187 浙公网安备 33010602006705号   

返回顶部