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] – 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)

转自 https://www.oschina.net/news/101820/kafka-2-0-1-released