Apache Kafka 2.0.1 发布，分布式消息发布订阅系统

内容简介：Apache Kafka 2.0.1 已发布，这是针对 2.0 版本的修复和改进版本。 Improvement [KAFKA-6914] - Kafka Connect - Plugins class should have a constructor that can take in parent ClassLoader [KAFKA-7131] - ...

Apache Kafka 2.0.1 已发布，这是针对 2.0 版本的修复和改进版本。

Improvement

• [KAFKA-6914] - Kafka Connect - Plugins class should have a constructor that can take in parent ClassLoader

• [KAFKA-7131] - Update release script to generate announcement email text

• [KAFKA-7198] - Enhance KafkaStreams start method javadoc

• [KAFKA-7278] - replaceSegments() should not call asyncDeleteSegment() for segments which have been removed from segments list

• [KAFKA-7285] - Streams should be more fencing-sensitive during task suspension under EOS

• [KAFKA-7414] - Do not fail broker on out of range offsets in replica fetcher

• [KAFKA-7454] - Use lazy allocation for SslTransportLayer buffers

Bug

• [KAFKA-4950] - ConcurrentModificationException when iterating over Kafka Metrics

• [KAFKA-5891] - Cast transformation fails if record schema contains timestamp field

• [KAFKA-6648] - Fetcher.getTopicMetadata() should return all partitions for each requested topic

• [KAFKA-7044] - kafka-consumer-groups.sh NullPointerException describing round robin or sticky assignors

• [KAFKA-7119] - Intermittent test failure with GSSAPI authentication failure

• [KAFKA-7128] - Lagging high watermark can lead to committed data loss after ISR expansion

• [KAFKA-7144] - Kafka Streams doesn't properly balance partition assignment

• [KAFKA-7158] - Duplicates when searching kafka stream state store with caching

• [KAFKA-7164] - Follower should truncate after every leader epoch change

• [KAFKA-7180] - In testHWCheckpointWithFailuresSingleLogSegment, wait until server1 has joined the ISR before shutting down server2

• [KAFKA-7192] - State-store can desynchronise with changelog

• [KAFKA-7196] - Remove heartbeat delayed operation for those removed consumers at the end of each rebalance

• [KAFKA-7216] - Exception while running kafka-acls.sh from 1.0 env on target Kafka env with 1.1.1

• [KAFKA-7225] - Kafka Connect ConfigProvider not invoked before validation

• [KAFKA-7242] - Externalized secrets are revealed in task configuration

• [KAFKA-7250] - Kafka-Streams-Scala DSL transform shares transformer instance

• [KAFKA-7255] - Timing issue in SimpleAclAuthorizer with concurrent create/update

• [KAFKA-7261] - Request and response total metrics record bytes instead of request count

• [KAFKA-7280] - ConcurrentModificationException in FetchSessionHandler in heartbeat thread

• [KAFKA-7284] - Producer getting fenced may cause Streams to shut down

• [KAFKA-7287] - Set open ACL permissions for old consumer znode path

• [KAFKA-7296] - Producer should handle COORDINATOR_LOADING error in TxnOffsetCommit

• [KAFKA-7298] - Concurrent DeleteRecords can lead to fatal OutOfSequence error in producer

• [KAFKA-7301] - KTable to KTable join invocation does not resolve in Scala DSL

• [KAFKA-7316] - Use of filter method in KTable.scala may result in StackOverflowError

• [KAFKA-7353] - Connect logs 'this' for anonymous inner classes

• [KAFKA-7354] - Fix IdlePercent and NetworkProcessorAvgIdlePercent metric calculation

• [KAFKA-7369] - Retry when possible in AdminClient.listConsumerGroups

• [KAFKA-7385] - Log cleaner crashes when empty batches are retained with idempotent or transactional producers

• [KAFKA-7386] - Streams Scala wrapper should not cache serdes

• [KAFKA-7415] - OffsetsForLeaderEpoch may incorrectly respond with undefined epoch causing truncation to HW

• [KAFKA-7434] - DeadLetterQueueReporter throws NPE if transform throws NPE

• [KAFKA-7453] - Enable idle expiry of connections which are never selected

• [KAFKA-7459] - Concurrency bug in updating RequestsPerSec metric

• [KAFKA-7460] - Connect Values converter uses incorrect date format string

• [KAFKA-7464] - Fail to shutdown ReplicaManager during broker cleaned shutdown

• [KAFKA-7467] - NoSuchElementException is raised because controlBatch is empty

• [KAFKA-7476] - SchemaProjector is not properly handling Date-based logical types

• [KAFKA-7519] - Transactional Ids Left in Pending State by TransactionStateManager During Transactional Id Expiration Are Unusable

• [KAFKA-7535] - KafkaConsumer doesn't report records-lag if isolation.level is read_committed

Task

• [KAFKA-7228] - DeadLetterQueue throws a NullPointerException

Sub-task

• [KAFKA-7299] - batch LeaderAndIsr requests during auto preferred leader election

下载地址 

• 源码下载: kafka-2.0.1-src.tgz (asc, sha512)

• 二进制下载:

• Scala 2.11  - kafka_2.11-2.0.1.tgz (asc, sha512)

• Scala 2.12  - kafka_2.12-2.0.1.tgz (asc, sha512)

【声明】文章转载自：开源中国社区 [http://www.oschina.net]

以上就是本文的全部内容，希望本文的内容对大家的学习或者工作能带来一定的帮助，也希望大家多多支持 码农网

查看所有标签

猜你喜欢:

• Apache Kafka 2.6.1 发布，分布式消息发布订阅系统
• Apache Kafka 2.0.1 发布，分布式消息发布订阅系统
• Apache Kafka 2.3.1 发布，分布式消息发布订阅系统
• 雅虎的分布式消息发布平台 Apache Pulsar 发布 1.21.0
• Apache Kafka 2.0.0 正式发布，分布式消息发布订阅系统
• Apache Pulsar 2.1.0 发布，雅虎的分布式消息发布平台

本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。