内容简介：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]
以上就是本文的全部内容，希望本文的内容对大家的学习或者工作能带来一定的帮助，也希望大家多多支持 码农网
本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。
