Author: stanislavkozlovski
Date: Mon Feb 26 11:54:36 2024
New Revision: 67584
Log:
Release 3.7.0
Added:
dev/kafka/3.7.0/RELEASE_NOTES.html
dev/kafka/3.7.0/RELEASE_NOTES.html.asc
dev/kafka/3.7.0/RELEASE_NOTES.html.md5
dev/kafka/3.7.0/RELEASE_NOTES.html.sha1
dev/kafka/3.7.0/RELEASE_NOTES.html.sha512
dev/kafka/3.7.0/kafka-3.7.0-src.tgz (with props)
dev/kafka/3.7.0/kafka-3.7.0-src.tgz.asc
dev/kafka/3.7.0/kafka-3.7.0-src.tgz.md5
dev/kafka/3.7.0/kafka-3.7.0-src.tgz.sha1
dev/kafka/3.7.0/kafka-3.7.0-src.tgz.sha512
dev/kafka/3.7.0/kafka_2.12-3.7.0-site-docs.tgz (with props)
dev/kafka/3.7.0/kafka_2.12-3.7.0-site-docs.tgz.asc
dev/kafka/3.7.0/kafka_2.12-3.7.0-site-docs.tgz.md5
dev/kafka/3.7.0/kafka_2.12-3.7.0-site-docs.tgz.sha1
dev/kafka/3.7.0/kafka_2.12-3.7.0-site-docs.tgz.sha512
dev/kafka/3.7.0/kafka_2.12-3.7.0.tgz (with props)
dev/kafka/3.7.0/kafka_2.12-3.7.0.tgz.asc
dev/kafka/3.7.0/kafka_2.12-3.7.0.tgz.md5
dev/kafka/3.7.0/kafka_2.12-3.7.0.tgz.sha1
dev/kafka/3.7.0/kafka_2.12-3.7.0.tgz.sha512
dev/kafka/3.7.0/kafka_2.13-3.7.0-site-docs.tgz (with props)
dev/kafka/3.7.0/kafka_2.13-3.7.0-site-docs.tgz.asc
dev/kafka/3.7.0/kafka_2.13-3.7.0-site-docs.tgz.md5
dev/kafka/3.7.0/kafka_2.13-3.7.0-site-docs.tgz.sha1
dev/kafka/3.7.0/kafka_2.13-3.7.0-site-docs.tgz.sha512
dev/kafka/3.7.0/kafka_2.13-3.7.0.tgz (with props)
dev/kafka/3.7.0/kafka_2.13-3.7.0.tgz.asc
dev/kafka/3.7.0/kafka_2.13-3.7.0.tgz.md5
dev/kafka/3.7.0/kafka_2.13-3.7.0.tgz.sha1
dev/kafka/3.7.0/kafka_2.13-3.7.0.tgz.sha512
Added: dev/kafka/3.7.0/RELEASE_NOTES.html
==============================================================================
--- dev/kafka/3.7.0/RELEASE_NOTES.html (added)
+++ dev/kafka/3.7.0/RELEASE_NOTES.html Mon Feb 26 11:54:36 2024
@@ -0,0 +1,322 @@
+<h1>Release Notes - Kafka - Version 3.7.0</h1>
+<p>Below is a summary of the JIRA issues addressed in the 3.7.0 release of
Kafka. For full documentation of the
+ release, a guide to get started, and information about the project, see
the <a href="https://kafka.apache.org/";>Kafka
+ project site</a>.</p>
+
+ <p><b>Note about upgrades:</b> Please carefully review the
+ <a href="https://kafka.apache.org/37/documentation.html#upgrade";>upgrade
documentation</a> for this release thoroughly
+ before upgrading your cluster. The upgrade notes discuss any critical
information about incompatibilities and breaking
+ changes, performance changes, and any other changes that might impact your
production deployment of Kafka.</p>
+
+ <p>The documentation for the most recent release can be found at
+ <a
href="https://kafka.apache.org/documentation.html";>https://kafka.apache.org/documentation.html</a>.</p>
+<h2>New Feature</h2>
+<ul>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-9800";>KAFKA-9800</a>] -
[KIP-580] Client Exponential Backoff Implementation</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15215";>KAFKA-15215</a>] - The
default.dsl.store config is not compatible with custom state stores</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15428";>KAFKA-15428</a>] -
Cluster-wide dynamic log adjustments for Connect</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15445";>KAFKA-15445</a>] -
KIP-975: Docker Image for Apache Kafka</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15448";>KAFKA-15448</a>] -
Streams StandbyTaskUpdateListener</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15470";>KAFKA-15470</a>] -
Allow creating connectors in a stopped state</li>
+</ul>
+<h2>Improvement</h2>
+<ul>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-9693";>KAFKA-9693</a>] - Kafka
latency spikes caused by log segment flush on roll</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-10199";>KAFKA-10199</a>] -
Separate state restoration into separate threads</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-14127";>KAFKA-14127</a>] -
KIP-858: Handle JBOD broker disk failure in KRaft</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-14780";>KAFKA-14780</a>] -
Make RefreshingHttpsJwksTest#testSecondaryRefreshAfterElapsedDelay
deterministic</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-14855";>KAFKA-14855</a>] -
Harden integration testing logic for asserting that a connector is deleted</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-14912";>KAFKA-14912</a>] -
Introduce a configuration for remote index cache size, preferably a dynamic
config.</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15022";>KAFKA-15022</a>] -
Support rack aware task assignment in Kafka streams </li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15046";>KAFKA-15046</a>] -
Produce performance issue under high disk load</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15047";>KAFKA-15047</a>] -
Handle rolling segments when the active segment's retention is breached incase
of tiered storage is enabled.</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15141";>KAFKA-15141</a>] -
High CPU usage with log4j2</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15147";>KAFKA-15147</a>] -
Measure pending and outstanding Remote Segment operations</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15208";>KAFKA-15208</a>] -
Upgrade Jackson dependencies to version 2.16.0</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15241";>KAFKA-15241</a>] -
Compute tiered offset by keeping the respective epochs in scope.</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15248";>KAFKA-15248</a>] - Add
BooleanConverter to Kafka Connect</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15273";>KAFKA-15273</a>] - Log
common name of expired client certificate</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15315";>KAFKA-15315</a>] - Use
getOrDefault rather than get</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15401";>KAFKA-15401</a>] -
Segment with corrupted index should not be uploaded to remote storage</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15415";>KAFKA-15415</a>] - In
Java-client, backoff should be skipped for retried producer-batch to a new
leader</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15418";>KAFKA-15418</a>] -
Update statement on decompression location </li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15432";>KAFKA-15432</a>] - RLM
Stop partitions should not be invoked for non-tiered storage topics</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15464";>KAFKA-15464</a>] -
Allow dynamic reloading of certificates with different DN / SANs</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15471";>KAFKA-15471</a>] -
Allow independently stop KRaft controllers or brokers</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15476";>KAFKA-15476</a>] -
Improve checkstyle performance</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15485";>KAFKA-15485</a>] -
Support building with Java 21 (LTS release)</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15492";>KAFKA-15492</a>] -
Enable spotbugs when building with Java 21</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15493";>KAFKA-15493</a>] -
Ensure system tests work with Java 21</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15521";>KAFKA-15521</a>] -
Refactor build.gradle to align gradle swagger plugin with swagger
dependencies</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15527";>KAFKA-15527</a>] - Add
reverseRange and reverseAll query over kv-store in IQv2</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15536";>KAFKA-15536</a>] -
dynamically resize remoteIndexCache</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15542";>KAFKA-15542</a>] -
Release member assignments on errors</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15563";>KAFKA-15563</a>] -
Provide informative error messages when Connect REST requests time out</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15566";>KAFKA-15566</a>] -
Flaky tests in FetchRequestTest.scala in KRaft mode</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15596";>KAFKA-15596</a>] -
Upgrade ZooKeeper to 3.8.3</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15629";>KAFKA-15629</a>] -
proposal to introduce IQv2 Query Types: TimestampedKeyQuery and
TimestampedRangeQuery</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15685";>KAFKA-15685</a>] - Add
missing compatibility for MinGW and MSYS2 (windows)</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15769";>KAFKA-15769</a>] - Fix
wrong log with exception</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15774";>KAFKA-15774</a>] -
Respect default.dsl.store Configuration Without Passing it to
StreamsBuilder</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15831";>KAFKA-15831</a>] -
List Client Metrics Configuration Resources</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15837";>KAFKA-15837</a>] -
Throw error on use of Consumer.poll(long timeout)</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15866";>KAFKA-15866</a>] -
Refactor OffsetFetchRequestState Error handling to be more consistent with
OffsetCommitRequestState</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15868";>KAFKA-15868</a>] -
KIP-951 - Leader discovery optimisations for the client</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15906";>KAFKA-15906</a>] -
Emit offset syncs more often than offset.lag.max for low-throughput/finite
partitions</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15922";>KAFKA-15922</a>] - Add
MetadataVersion for JBOD</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15971";>KAFKA-15971</a>] -
Re-enable consumer integration tests for new consumer</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15980";>KAFKA-15980</a>] - Add
KIP-1001 CurrentControllerId metric</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16007";>KAFKA-16007</a>] - ZK
migrations can be slow for large clusters</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16210";>KAFKA-16210</a>] -
Upgrade jose4j to 0.9.4</li>
+</ul>
+<h2>Bug</h2>
+<ul>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-12679";>KAFKA-12679</a>] -
Rebalancing a restoring or running task may cause directory livelocking with
newly created task</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-13327";>KAFKA-13327</a>] -
Preflight validations of connectors leads to 500 responses</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-13973";>KAFKA-13973</a>] -
block-cache-capacity metrics worth twice as much as normal</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-13988";>KAFKA-13988</a>] -
Mirrormaker 2 auto.offset.reset=latest not working</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-14067";>KAFKA-14067</a>] -
Sink connector override.consumer.group.id can conflict with worker group.id</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-14616";>KAFKA-14616</a>] -
Topic recreation with offline broker causes permanent URPs</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-14767";>KAFKA-14767</a>] -
Gradle build fails with missing commitId after git gc</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-14927";>KAFKA-14927</a>] -
Prevent kafka-configs.sh from setting non-alphanumeric config key names</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15000";>KAFKA-15000</a>] -
High vulnerability PRISMA-2023-0067 reported in jackson-core</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15117";>KAFKA-15117</a>] -
SslTransportLayerTest.testValidEndpointIdentificationCN fails with Java 20 &
21</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15152";>KAFKA-15152</a>] - Fix
incorrect format specifiers when formatting string</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15221";>KAFKA-15221</a>] -
Potential race condition between requests from rebooted followers</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15230";>KAFKA-15230</a>] -
ApiVersions data between controllers is not reliable</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15311";>KAFKA-15311</a>] - Fix
docs about reverting to ZooKeeper mode during KRaft migration</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15372";>KAFKA-15372</a>] - MM2
rolling restart can drop configuration changes silently</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15392";>KAFKA-15392</a>] -
RestServer starts but does not stop ServletContextHandler</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15412";>KAFKA-15412</a>] -
Reading an unknown version of quorum-state-file should trigger an error</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15465";>KAFKA-15465</a>] - MM2
not working when its internal topics are pre-created on a cluster that
disallows topic creation</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15473";>KAFKA-15473</a>] -
Connect connector-plugins endpoint shows duplicate plugins</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15481";>KAFKA-15481</a>] -
Concurrency bug in RemoteIndexCache leads to IOException</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15489";>KAFKA-15489</a>] -
split brain in KRaft cluster </li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15491";>KAFKA-15491</a>] -
RackId doesn't exist error while running WordCountDemo</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15500";>KAFKA-15500</a>] -
Code bug in SslPrincipalMapper.java</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15502";>KAFKA-15502</a>] -
Handle large keystores in SslEngineValidator</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15507";>KAFKA-15507</a>] -
adminClient should not throw retriable exception when closing instance</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15510";>KAFKA-15510</a>] -
Follower's lastFetchedEpoch wrongly set when fetch response has no record</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15511";>KAFKA-15511</a>] -
Exception not handled correctly if indexFile is corrupted.</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15537";>KAFKA-15537</a>] -
Unsafe metadata.version downgrade is not supported</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15571";>KAFKA-15571</a>] -
StateRestoreListener#onRestoreSuspended is never called because wrapper
DelegatingStateRestoreListener doesn't implement onRestoreSuspended</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15602";>KAFKA-15602</a>] -
Breaking change in 3.4.0 ByteBufferSerializer</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15605";>KAFKA-15605</a>] -
Topics marked for deletion in ZK are incorrectly migrated to KRaft</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15607";>KAFKA-15607</a>] -
Possible NPE is thrown in MirrorCheckpointTask</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15644";>KAFKA-15644</a>] - Fix
CVE-2023-4586 in netty:handler</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15653";>KAFKA-15653</a>] - NPE
in ChunkedByteStream</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15658";>KAFKA-15658</a>] -
Zookeeper.jar | CVE-2023-44981 </li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15680";>KAFKA-15680</a>] -
Partition-Count is not getting updated Correctly in the Incremental
Co-operative Rebalancing(ICR) Mode of Rebalancing</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15689";>KAFKA-15689</a>] -
KRaftMigrationDriver not logging the skipped event when expected state is
wrong</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15693";>KAFKA-15693</a>] -
Disabling scheduled rebalance delay in Connect can lead to indefinitely
unassigned connectors and tasks</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15695";>KAFKA-15695</a>] -
Local log start offset is not updated on the follower after rebuilding remote
log auxiliary state</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15704";>KAFKA-15704</a>] -
ControllerRegistrationRequest must set ZkMigrationReady field if
appropriate</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15755";>KAFKA-15755</a>] -
LeaveGroupResponse v0-v2 should handle no members</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15771";>KAFKA-15771</a>] -
ProduceRequest#partitionSizes() is not an atomic operation</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15799";>KAFKA-15799</a>] - ZK
brokers incorrectly handle KRaft metadata snapshots</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15800";>KAFKA-15800</a>] -
Malformed connect source offsets corrupt other partitions with
DataException</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15802";>KAFKA-15802</a>] -
Trying to access uncopied segments metadata on listOffsets</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15817";>KAFKA-15817</a>] -
Avoid reconnecting to the same IP address if multiple addresses are
available</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15819";>KAFKA-15819</a>] -
KafkaServer leaks KafkaRaftManager when ZK migration enabled</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15824";>KAFKA-15824</a>] -
SubscriptionState's maybeValidatePositionForCurrentLeader should handle
partition which isn't subscribed yet</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15825";>KAFKA-15825</a>] -
KRaft controller writes empty state to ZK after migration</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15836";>KAFKA-15836</a>] -
KafkaConsumer subscribes to multiple topics does not respect
max.poll.records</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15860";>KAFKA-15860</a>] -
ControllerRegistration must be written out to the metadata image</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15888";>KAFKA-15888</a>] -
DistributedHerder log context should not use the same client ID for each
Connect worker by default</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15890";>KAFKA-15890</a>] -
Consumer.poll with long timeout unaware of assigned partitions</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15904";>KAFKA-15904</a>] -
Downgrade tests are failing with directory.id </li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15932";>KAFKA-15932</a>] -
Flaky test - PlaintextConsumerTest.testSeek("kraft+kip-848","consumer")</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15946";>KAFKA-15946</a>] -
AsyncKafkaConsumer should retry commits on the application thread instead of
auto-retry</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15965";>KAFKA-15965</a>] -
Test failure:
org.apache.kafka.common.requests.BrokerRegistrationRequestTest</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15967";>KAFKA-15967</a>] - Fix
revocation in reconcilation logic</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15978";>KAFKA-15978</a>] - New
consumer sends OffsetCommit with empty member ID</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15986";>KAFKA-15986</a>] - New
consumer group protocol integration test failures</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16005";>KAFKA-16005</a>] -
ZooKeeper to KRaft migration rollback missing disabling controller and
migration configuration on brokers</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16012";>KAFKA-16012</a>] -
Incomplete range assignment in consumer</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16015";>KAFKA-16015</a>] -
kafka-leader-election timeout values always overwritten by default values </li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16017";>KAFKA-16017</a>] -
Checkpointed offset is incorrect when task is revived and restoring </li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16029";>KAFKA-16029</a>] -
Investigate cause of "Unable to find FetchSessionHandler for node X" in
logs</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16046";>KAFKA-16046</a>] -
Stream Stream Joins fail after restoration with deserialization exceptions</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16078";>KAFKA-16078</a>] - Be
more consistent about getting the latest MetadataVersion</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16085";>KAFKA-16085</a>] -
remote copy lag bytes/segments metrics don't update all topic value</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16094";>KAFKA-16094</a>] -
BrokerRegistrationRequest.logDirs field must be ignorable</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16101";>KAFKA-16101</a>] -
KRaft migration rollback documentation is incorrect</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16120";>KAFKA-16120</a>] - Fix
partition reassignment during ZK migration</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16131";>KAFKA-16131</a>] -
Repeated UnsupportedVersionException logged when running Kafka 3.7.0-RC2 KRaft
cluster with metadata version 3.6</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16133";>KAFKA-16133</a>] -
Commits during reconciliation always time out</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16141";>KAFKA-16141</a>] -
StreamsStandbyTask##test_standby_tasks_rebalanceArguments:{
âmetadata_quorumâ: âISOLATED_KRAFTâ, âuse_new_coordinatorâ: false}
fails consistently in 3.7</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16144";>KAFKA-16144</a>] -
Controller leader checkQuorum timer should skip only 1 controller case</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16157";>KAFKA-16157</a>] -
Topic recreation with offline disk doesn't update leadership/shrink ISR
correctly</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16162";>KAFKA-16162</a>] - New
created topics are unavailable after upgrading to 3.7</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16216";>KAFKA-16216</a>] -
Reduce batch size for initial metadata load during ZK migration</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16221";>KAFKA-16221</a>] -
IllegalStateException from Producer</li>
+</ul>
+<h2>Task</h2>
+<ul>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-14438";>KAFKA-14438</a>] -
Throw error when consumer configured with empty/whitespace-only group.id for
AsyncKafkaConsumer</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15093";>KAFKA-15093</a>] - Add
3.5.0 to broker/client and streams upgrade/compatibility tests</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15378";>KAFKA-15378</a>] -
Rolling upgrade system tests are failing</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15479";>KAFKA-15479</a>] -
Remote log segments should be considered once for retention breach</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15535";>KAFKA-15535</a>] - Add
documentation of "remote.log.index.file.cache.total.size.bytes" configuration
property. </li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15661";>KAFKA-15661</a>] -
KIP-951: Server side and protocol changes</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15664";>KAFKA-15664</a>] - Add
3.4.0 streams upgrade/compatibility tests</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15714";>KAFKA-15714</a>] -
KRaft support in DynamicNumNetworkThreadsTest</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15725";>KAFKA-15725</a>] -
KRaft support in FetchRequestTest</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15730";>KAFKA-15730</a>] -
KRaft support in ProducerFailureHandlingTest</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15731";>KAFKA-15731</a>] -
KRaft support in ListOffsetsIntegrationTest</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15732";>KAFKA-15732</a>] -
KRaft support in LogAppendTimeTest</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15733";>KAFKA-15733</a>] -
KRaft support in FetchRequestMaxBytesTest</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15765";>KAFKA-15765</a>] -
Remove task level metric "commit-latency"</li>
+</ul>
+<h2>Test</h2>
+<ul>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15169";>KAFKA-15169</a>] - Add
tests for RemoteIndexCache</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15179";>KAFKA-15179</a>] - Add
integration tests for the FileStream Sink and Source connectors</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15439";>KAFKA-15439</a>] - Add
transaction tests enabled with tiered storage</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15547";>KAFKA-15547</a>] -
Thread leak in MirrorMakerConfigTest#testClientConfigProperties</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15659";>KAFKA-15659</a>] -
Flaky test
RestoreIntegrationTest.shouldInvokeUserDefinedGlobalStateRestoreListener </li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15671";>KAFKA-15671</a>] -
Flaky test RemoteIndexCacheTest.testClearCacheAndIndexFilesWhenResizeCache</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15780";>KAFKA-15780</a>] -
Wait for consistent kraft metadata when creating topics in tests</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15793";>KAFKA-15793</a>] -
Flaky test ZkMigrationIntegrationTest.testMigrateTopicDeletions</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15991";>KAFKA-15991</a>] -
Flaky new consumer test testGroupIdNotNullAndValid</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16035";>KAFKA-16035</a>] - add
integration test for ExpiresPerSec and RemoteLogSizeComputationTime metrics</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16139";>KAFKA-16139</a>] -
StreamsUpgradeTest fails consistently in 3.7.0</li>
+</ul>
+<h2>Sub-task</h2>
+<ul>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-14247";>KAFKA-14247</a>] -
Implement EventHandler interface and DefaultEventHandler for Consumer</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-14252";>KAFKA-14252</a>] -
Create background thread skeleton for new Consumer threading model</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-14274";>KAFKA-14274</a>] -
Introduce FetchRequestManager to integrate fetch into new consumer threading
refactor</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-14481";>KAFKA-14481</a>] -
Move LogSegment/LogSegments to storage module</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-14499";>KAFKA-14499</a>] -
Implement OffsetFetch/OffsetCommit APIs</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-14502";>KAFKA-14502</a>] -
Implement LeaveGroup API</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-14503";>KAFKA-14503</a>] -
Implement ListGroups</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-14515";>KAFKA-14515</a>] -
Implement optimized uniform broker side assignor</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-14516";>KAFKA-14516</a>] -
Implement static membeship</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-14519";>KAFKA-14519</a>] - Add
metrics to the new coordinator</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-14581";>KAFKA-14581</a>] -
Move GetOffsetShell to tools</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-14593";>KAFKA-14593</a>] -
Move LeaderElectionCommand to tools</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-14595";>KAFKA-14595</a>] -
Move ReassignPartitionsCommand to tools</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-14596";>KAFKA-14596</a>] -
Move TopicCommand to tools</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-14675";>KAFKA-14675</a>] -
Extract metadata-related tasks from Fetcher into MetadataFetcher</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-14684";>KAFKA-14684</a>] -
Replace EasyMock and PowerMock with Mockito in WorkerSinkTaskThreadedTest</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-14724";>KAFKA-14724</a>] -
Port tests in FetcherTest to FetchRequestManagerTest</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-14875";>KAFKA-14875</a>] -
Implement Wakeup()</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-14960";>KAFKA-14960</a>] -
Metadata Request Manager and listTopics/partitionsFor API</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-14965";>KAFKA-14965</a>] -
Introduce OffsetsRequestManager to integrate ListOffsets requests into new
consumer threading refactor</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-14987";>KAFKA-14987</a>] -
Implement Group/Offset expiration</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15026";>KAFKA-15026</a>] -
Implement min-cost flow balancing tasks for same subtopology</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15061";>KAFKA-15061</a>] -
CoordinatorPartitionWriter should reuse buffer</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15081";>KAFKA-15081</a>] -
Implement new consumer offsetsForTimes</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15115";>KAFKA-15115</a>] -
Implement resetPositions functionality in OffsetsRequestManager</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15158";>KAFKA-15158</a>] - Add
metrics for RemoteDeleteRequestsPerSec, RemoteDeleteErrorsPerSec,
BuildRemoteLogAuxStateRequestsPerSec, BuildRemoteLogAuxStateErrorsPerSec</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15163";>KAFKA-15163</a>] -
Implement validatePositions functionality for new KafkaConsumer</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15164";>KAFKA-15164</a>] -
Extract reusable logic from OffsetsForLeaderEpochClient</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15174";>KAFKA-15174</a>] -
Ensure the correct thread is executing the callbacks</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15184";>KAFKA-15184</a>] - New
consumer internals refactoring and clean up</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15188";>KAFKA-15188</a>] -
Implement more of the remaining PrototypeAsyncConsumer APIs</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15200";>KAFKA-15200</a>] -
verify pre-requisite at start of release.py</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15237";>KAFKA-15237</a>] -
Implement write operation timeout</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15275";>KAFKA-15275</a>] -
Implement consumer group membership state machine</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15276";>KAFKA-15276</a>] -
Implement event plumbing for ConsumerRebalanceListener callbacks</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15277";>KAFKA-15277</a>] -
Design & implement support for internal Consumer delegates</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15278";>KAFKA-15278</a>] -
Implement client support for KIP-848 ConsumerGroupHeartbeat protocol RPC</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15280";>KAFKA-15280</a>] -
Implement client support for selecting KIP-848 server-side assignor</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15281";>KAFKA-15281</a>] -
Implement the groupMetadata Consumer API</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15304";>KAFKA-15304</a>] -
CompletableApplicationEvents aren't being completed when the consumer is
closing</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15306";>KAFKA-15306</a>] -
Integrate committed offsets logic when updating fetching positions</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15316";>KAFKA-15316</a>] -
CommitRequestManager not calling RequestState callbacks </li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15317";>KAFKA-15317</a>] - Fix
for async consumer access to committed offsets with multiple consumers</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15327";>KAFKA-15327</a>] -
Client consumer should commit offsets on close</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15346";>KAFKA-15346</a>] -
Single-Key_single-timestamp IQs with versioned state stores</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15347";>KAFKA-15347</a>] -
Single-Key_multi-timestamp IQs with versioned state stores</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15355";>KAFKA-15355</a>] -
Message schema changes</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15358";>KAFKA-15358</a>] -
QueuedReplicaToDirAssignments metric</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15365";>KAFKA-15365</a>] -
Broker-side replica management changes</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15366";>KAFKA-15366</a>] - Log
directory failure integration test</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15438";>KAFKA-15438</a>] -
Review exception caching logic used for reset/validate positions in async
consumer</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15454";>KAFKA-15454</a>] - Add
support for OffsetCommit version 9 in admin client</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15455";>KAFKA-15455</a>] - Add
support for OffsetCommit version 9 in consumer</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15456";>KAFKA-15456</a>] - Add
support for OffsetFetch version 9 in consumer</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15457";>KAFKA-15457</a>] - Add
support for OffsetFetch version 9 in admin</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15461";>KAFKA-15461</a>] - Add
integration test for the ListGroup API</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15484";>KAFKA-15484</a>] -
Implement general uniform broker side assignor</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15508";>KAFKA-15508</a>] -
Method always return the same value ApplicationEventProcessor.java</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15531";>KAFKA-15531</a>] -
Ensure coordinator node is removed upon disconnection exception</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15533";>KAFKA-15533</a>] -
Ensure HeartbeatRequestManager only send out some fields once</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15534";>KAFKA-15534</a>] -
Propagate client response time when timeout to the request handler</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15544";>KAFKA-15544</a>] -
Enable existing client integration tests for new protocol </li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15548";>KAFKA-15548</a>] -
Send GroupConsumerHeartbeatRequest on Consumer.close()</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15550";>KAFKA-15550</a>] -
OffsetsForTimes validation for negative timestamps in new consumer</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15554";>KAFKA-15554</a>] -
Update client state machine to align with protocol sending one assignment at a
time </li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15555";>KAFKA-15555</a>] -
Ensure wakeups are handled correctly in PrototypeAsyncConsumer.poll()</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15562";>KAFKA-15562</a>] -
Ensure fetch offset and commit offset handler handles both timeout and various
error types</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15574";>KAFKA-15574</a>] -
Update states and transitions for membership manager state machine</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15582";>KAFKA-15582</a>] -
Clean shutdown detection, broker side</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15593";>KAFKA-15593</a>] - Add
3.6.0 to broker/client upgrade/compatibility tests</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15594";>KAFKA-15594</a>] - Add
3.6.0 to streams upgrade/compatibility tests</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15598";>KAFKA-15598</a>] - Add
integration tests for DescribeGroups API, DeleteGroups API and OffsetDelete
API</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15604";>KAFKA-15604</a>] - Add
Telemetry RPCs Definitions</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15613";>KAFKA-15613</a>] - Add
Client API in interfaces and client configurations.</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15614";>KAFKA-15614</a>] -
Define interfaces/classes for capturing telemetry metrics </li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15616";>KAFKA-15616</a>] -
Define client telemetry states and their transitions</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15618";>KAFKA-15618</a>] -
Implement MetricsCollector which collects metrics in OTLP format</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15628";>KAFKA-15628</a>] -
Refactor ConsumerRebalanceListener invocation for reuse</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15633";>KAFKA-15633</a>] -
Bug: Generated Persistent Directory IDs are overwritten on startup.</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15643";>KAFKA-15643</a>] -
Improve unloading logging</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15645";>KAFKA-15645</a>] -
Move ReplicationQuotasTestRig to tools</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15647";>KAFKA-15647</a>] - Fix
the different behavior in error handling between the old and new group
coordinator</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15663";>KAFKA-15663</a>] -
Implement ClientTelemetryReporter which manages telemetry lifecyclye</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15668";>KAFKA-15668</a>] - Add
Opentelemetry Proto library with shadowed classes</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15669";>KAFKA-15669</a>] -
Implement telemetry naming strategy</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15673";>KAFKA-15673</a>] -
Define new client_metrics resource type configuration to store metric config.
</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15679";>KAFKA-15679</a>] -
Client support for new consumer configs</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15681";>KAFKA-15681</a>] - Add
support of client-metrics in kafka-configs.sh</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15684";>KAFKA-15684</a>] - Add
support to describe all subscriptions through utility</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15696";>KAFKA-15696</a>] -
Revoke partitions on Consumer.close()</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15705";>KAFKA-15705</a>] - Add
integration tests for Heartbeat API and GroupLeave API</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15775";>KAFKA-15775</a>] -
Implement listTopics() and partitionFor() for the AsyncKafkaConsumer</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15778";>KAFKA-15778</a>] -
Implement ClientMetricsManager to process request</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15779";>KAFKA-15779</a>] -
Define broker configurations and exceptions</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15794";>KAFKA-15794</a>] -
Implement request and response handling for telemetry APIs</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15803";>KAFKA-15803</a>] -
Update last seen epoch during commit</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15818";>KAFKA-15818</a>] -
Implement max poll interval</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15830";>KAFKA-15830</a>] - Add
request/response handling in KafkaApis and update metrics plugin</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15833";>KAFKA-15833</a>] -
Restrict Consumer API to be used from one thread</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15842";>KAFKA-15842</a>] -
Correct handling of KafkaConsumer.committed for new consumer</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15849";>KAFKA-15849</a>] - Fix
ListGroups API when runtime partition size is zero</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15854";>KAFKA-15854</a>] -
Move Java classes from kafka.server to the server module</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15856";>KAFKA-15856</a>] - Add
integration tests for JoinGroup API and SyncGroup API</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15865";>KAFKA-15865</a>] -
Ensure consumer.poll() execute autocommit callback</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15870";>KAFKA-15870</a>] -
Move new group coordinator metrics from Yammer to Metrics</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15871";>KAFKA-15871</a>] -
Implement kafka-client-metrics.sh tool</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15874";>KAFKA-15874</a>] - Add
metric and request log attribute for deprecated request api versions
(KIP-896)</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15879";>KAFKA-15879</a>] - Add
documentation and examples for the Docker image</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15880";>KAFKA-15880</a>] - Add
github actions workflow for promoting RC docker image</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15881";>KAFKA-15881</a>] -
Make changes in Release Process Wiki and Release Process</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15883";>KAFKA-15883</a>] -
Implement RemoteCopyLagBytes</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15887";>KAFKA-15887</a>] -
Autocommit during close consistently fails with exception in background
thread</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15893";>KAFKA-15893</a>] -
Bump MetadataVersion for directory assignments</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15901";>KAFKA-15901</a>] -
Implement client changes to support telemetry APIs</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15903";>KAFKA-15903</a>] - Add
github actions workflow for building and pushing RC Docker Image</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15910";>KAFKA-15910</a>] - New
group coordinator needs to generate snapshots while loading</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15913";>KAFKA-15913</a>] -
Migrate AsyncKafkaConsumerTest away from ConsumerTestBuilder</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15953";>KAFKA-15953</a>] -
Refactor polling delays</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-15981";>KAFKA-15981</a>] -
update Group size only when groups size changes</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16002";>KAFKA-16002</a>] -
Implement RemoteCopyLagSegments, RemoteDeleteLagBytes and
RemoteDeleteLagSegments</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16013";>KAFKA-16013</a>] -
Implement ExpiresPerSec metric</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16014";>KAFKA-16014</a>] -
Implement RemoteLogSizeComputationTime, RemoteLogSizeBytes,
RemoteLogMetadataCount</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16026";>KAFKA-16026</a>] -
AsyncConsumer does not send a poll event to the background thread</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16030";>KAFKA-16030</a>] - new
group coordinator should check if partition goes offline during load</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16036";>KAFKA-16036</a>] - Add
`group.coordinator.rebalance.protocols` and publish all new configs</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16040";>KAFKA-16040</a>] -
Rename `Generic` to `Classic`</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16053";>KAFKA-16053</a>] - Fix
leaked Default DirectoryService</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16058";>KAFKA-16058</a>] - Fix
leaked in ControllerApiTest</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16059";>KAFKA-16059</a>] - Fix
leak of ExpirationReaper-1-AlterAcls threads in :core:test</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16062";>KAFKA-16062</a>] -
Upgrade mockito to 5.8.0</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16065";>KAFKA-16065</a>] - Fix
leak in DelayedOperationTest</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16074";>KAFKA-16074</a>] - Fix
thread leaks in ReplicaManagerTest</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16079";>KAFKA-16079</a>] - Fix
leak in
LocalLeaderEndPointTest/FinalizedFeatureChangeListenerTest/KafkaApisTest/ReplicaManagerConcurrencyTest</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16099";>KAFKA-16099</a>] -
Handle timeouts for AsyncKafkaConsumer.commitSync</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/KAFKA-16118";>KAFKA-16118</a>] -
Coordinator unloading fails when replica is deleted</li>
+</ul>
Added: dev/kafka/3.7.0/RELEASE_NOTES.html.asc
==============================================================================
--- dev/kafka/3.7.0/RELEASE_NOTES.html.asc (added)
+++ dev/kafka/3.7.0/RELEASE_NOTES.html.asc Mon Feb 26 11:54:36 2024
@@ -0,0 +1,7 @@
+-----BEGIN PGP SIGNATURE-----
+
+iHUEABYKAB0WIQR8OML2599A5SfHyZbeDZ0S+xNg2gUCZcYp8wAKCRDeDZ0S+xNg
+2hLTAP9+Nh0Te+g+mdRzNYztRjbuHEY7OwUBnanPA3PkTB2m/wD+ItghbwHAnyBg
+Ub6OUhzEBp8JJbprjLtlECGnLxz8Vwc=
+=YiJt
+-----END PGP SIGNATURE-----
Added: dev/kafka/3.7.0/RELEASE_NOTES.html.md5
==============================================================================
--- dev/kafka/3.7.0/RELEASE_NOTES.html.md5 (added)
+++ dev/kafka/3.7.0/RELEASE_NOTES.html.md5 Mon Feb 26 11:54:36 2024
@@ -0,0 +1 @@
+RELEASE_NOTES.html: 86 50 19 D3 EA 40 D7 8E 82 2C C8 37 79 CE C4 B0
Added: dev/kafka/3.7.0/RELEASE_NOTES.html.sha1
==============================================================================
--- dev/kafka/3.7.0/RELEASE_NOTES.html.sha1 (added)
+++ dev/kafka/3.7.0/RELEASE_NOTES.html.sha1 Mon Feb 26 11:54:36 2024
@@ -0,0 +1 @@
+RELEASE_NOTES.html: 5021 E6E0 846E CB70 4DF6 75E0 2704 19A7 0C2E AD03
Added: dev/kafka/3.7.0/RELEASE_NOTES.html.sha512
==============================================================================
--- dev/kafka/3.7.0/RELEASE_NOTES.html.sha512 (added)
+++ dev/kafka/3.7.0/RELEASE_NOTES.html.sha512 Mon Feb 26 11:54:36 2024
@@ -0,0 +1,3 @@
+RELEASE_NOTES.html: 08CA134C 7F411A50 D99F5C49 0566702F 49B97859 88351DCD
+ 2434E66F 3F2B2EE6 DB09E5F5 6BA96D02 CCDCFD58 BE5C0831
+ 7F4ABAE6 F9C49BB9 BAEA190D 67E947E4
Added: dev/kafka/3.7.0/kafka-3.7.0-src.tgz
==============================================================================
Binary file - no diff available.
Propchange: dev/kafka/3.7.0/kafka-3.7.0-src.tgz
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: dev/kafka/3.7.0/kafka-3.7.0-src.tgz.asc
==============================================================================
--- dev/kafka/3.7.0/kafka-3.7.0-src.tgz.asc (added)
+++ dev/kafka/3.7.0/kafka-3.7.0-src.tgz.asc Mon Feb 26 11:54:36 2024
@@ -0,0 +1,7 @@
+-----BEGIN PGP SIGNATURE-----
+
+iHUEABYKAB0WIQR8OML2599A5SfHyZbeDZ0S+xNg2gUCZcYp8wAKCRDeDZ0S+xNg
+2sSjAQDTMkAlxHNUn2PXEvxnJWLEWHhD5S3SSuiPMiSvZwETOAEA0fTqxJK82X2Z
+SawghWHCYNAtRK/K7mzrjPau4MVu4AM=
+=CLk2
+-----END PGP SIGNATURE-----
Added: dev/kafka/3.7.0/kafka-3.7.0-src.tgz.md5
==============================================================================
--- dev/kafka/3.7.0/kafka-3.7.0-src.tgz.md5 (added)
+++ dev/kafka/3.7.0/kafka-3.7.0-src.tgz.md5 Mon Feb 26 11:54:36 2024
@@ -0,0 +1 @@
+kafka-3.7.0-src.tgz: F6 E8 FF A9 D7 42 B1 A1 D7 0C 2C 51 29 EE E4 72
Added: dev/kafka/3.7.0/kafka-3.7.0-src.tgz.sha1
==============================================================================
--- dev/kafka/3.7.0/kafka-3.7.0-src.tgz.sha1 (added)
+++ dev/kafka/3.7.0/kafka-3.7.0-src.tgz.sha1 Mon Feb 26 11:54:36 2024
@@ -0,0 +1 @@
+kafka-3.7.0-src.tgz: 9C87 E130 AC13 438F E473 0FC4 D57D 9239 9B86 048E
Added: dev/kafka/3.7.0/kafka-3.7.0-src.tgz.sha512
==============================================================================
--- dev/kafka/3.7.0/kafka-3.7.0-src.tgz.sha512 (added)
+++ dev/kafka/3.7.0/kafka-3.7.0-src.tgz.sha512 Mon Feb 26 11:54:36 2024
@@ -0,0 +1,3 @@
+kafka-3.7.0-src.tgz: 89A50353 9C0BCA81 57CFF62F 803AB836 DC7E37E3 5863E279
+ 55E03046 88B9CED0 4FA8FF72 60B74D1A 0E875CC6 D55D0021
+ C0B18970 5458EB39 CB70DEBB B7899E09
Added: dev/kafka/3.7.0/kafka_2.12-3.7.0-site-docs.tgz
==============================================================================
Binary file - no diff available.
Propchange: dev/kafka/3.7.0/kafka_2.12-3.7.0-site-docs.tgz
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: dev/kafka/3.7.0/kafka_2.12-3.7.0-site-docs.tgz.asc
==============================================================================
--- dev/kafka/3.7.0/kafka_2.12-3.7.0-site-docs.tgz.asc (added)
+++ dev/kafka/3.7.0/kafka_2.12-3.7.0-site-docs.tgz.asc Mon Feb 26 11:54:36 2024
@@ -0,0 +1,7 @@
+-----BEGIN PGP SIGNATURE-----
+
+iHUEABYKAB0WIQR8OML2599A5SfHyZbeDZ0S+xNg2gUCZcYp9AAKCRDeDZ0S+xNg
+2vI+AQCbvIwTNaErZgKreN4yw/ouY7eSKIlEiP+tLEcJvWxCkgD/bPOEs63TKs8t
+o0kPX2J0AbUg3c4AhWg5eWbvc+DABwc=
+=C6/I
+-----END PGP SIGNATURE-----
Added: dev/kafka/3.7.0/kafka_2.12-3.7.0-site-docs.tgz.md5
==============================================================================
--- dev/kafka/3.7.0/kafka_2.12-3.7.0-site-docs.tgz.md5 (added)
+++ dev/kafka/3.7.0/kafka_2.12-3.7.0-site-docs.tgz.md5 Mon Feb 26 11:54:36 2024
@@ -0,0 +1 @@
+kafka_2.12-3.7.0-site-docs.tgz: 86 E3 DA 70 C1 9E 62 5F 07 E8 43 B5 58 52 81
83
Added: dev/kafka/3.7.0/kafka_2.12-3.7.0-site-docs.tgz.sha1
==============================================================================
--- dev/kafka/3.7.0/kafka_2.12-3.7.0-site-docs.tgz.sha1 (added)
+++ dev/kafka/3.7.0/kafka_2.12-3.7.0-site-docs.tgz.sha1 Mon Feb 26 11:54:36 2024
@@ -0,0 +1,2 @@
+kafka_2.12-3.7.0-site-docs.tgz: 5C98 5B3B C1C1 D57B BE81 7803 9EE0 85F9 9C1C
+ 1930
Added: dev/kafka/3.7.0/kafka_2.12-3.7.0-site-docs.tgz.sha512
==============================================================================
--- dev/kafka/3.7.0/kafka_2.12-3.7.0-site-docs.tgz.sha512 (added)
+++ dev/kafka/3.7.0/kafka_2.12-3.7.0-site-docs.tgz.sha512 Mon Feb 26 11:54:36
2024
@@ -0,0 +1,4 @@
+kafka_2.12-3.7.0-site-docs.tgz: 9D2C0B45 ACD13C49 02A19647 EE5F2505 8B12642A
+ CB57A073 D08A9C1D 368301CF 780EABF1 49694F5B
+ 0512DB7A 4BC29DD7 27F775D7 0EBC4AA3 BC5D1B73
+ 8167731D
Added: dev/kafka/3.7.0/kafka_2.12-3.7.0.tgz
==============================================================================
Binary file - no diff available.
Propchange: dev/kafka/3.7.0/kafka_2.12-3.7.0.tgz
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: dev/kafka/3.7.0/kafka_2.12-3.7.0.tgz.asc
==============================================================================
--- dev/kafka/3.7.0/kafka_2.12-3.7.0.tgz.asc (added)
+++ dev/kafka/3.7.0/kafka_2.12-3.7.0.tgz.asc Mon Feb 26 11:54:36 2024
@@ -0,0 +1,7 @@
+-----BEGIN PGP SIGNATURE-----
+
+iHUEABYKAB0WIQR8OML2599A5SfHyZbeDZ0S+xNg2gUCZcYp9gAKCRDeDZ0S+xNg
+2nYkAQCNtWIxKSQDAuJQMCh//McpYx0Bwv19NMelGXaBnDlrSgEAm7kFuSNzOo6f
+k6GIyfLkAJAGHP9dme4QGF6+bu48sgM=
+=EUTy
+-----END PGP SIGNATURE-----
Added: dev/kafka/3.7.0/kafka_2.12-3.7.0.tgz.md5
==============================================================================
--- dev/kafka/3.7.0/kafka_2.12-3.7.0.tgz.md5 (added)
+++ dev/kafka/3.7.0/kafka_2.12-3.7.0.tgz.md5 Mon Feb 26 11:54:36 2024
@@ -0,0 +1 @@
+kafka_2.12-3.7.0.tgz: 65 3C F1 0C 12 86 F5 51 F8 0F BD 75 BA B2 13 C9
Added: dev/kafka/3.7.0/kafka_2.12-3.7.0.tgz.sha1
==============================================================================
--- dev/kafka/3.7.0/kafka_2.12-3.7.0.tgz.sha1 (added)
+++ dev/kafka/3.7.0/kafka_2.12-3.7.0.tgz.sha1 Mon Feb 26 11:54:36 2024
@@ -0,0 +1 @@
+kafka_2.12-3.7.0.tgz: 328E 7088 C758 6695 5D4A 413B 0960 4F92 8981 0B76
Added: dev/kafka/3.7.0/kafka_2.12-3.7.0.tgz.sha512
==============================================================================
--- dev/kafka/3.7.0/kafka_2.12-3.7.0.tgz.sha512 (added)
+++ dev/kafka/3.7.0/kafka_2.12-3.7.0.tgz.sha512 Mon Feb 26 11:54:36 2024
@@ -0,0 +1,3 @@
+kafka_2.12-3.7.0.tgz: CA1053C4 E173539A AC816D5A 3658D29C AD446B7F 24F8DF42
+ 157E3BA5 70295A9F 909DC80C F0A2FACA 07B15FEC 4629ACF4
+ 4D601EF0 FE4B79E8 37E5E1E4 06A7624B
Added: dev/kafka/3.7.0/kafka_2.13-3.7.0-site-docs.tgz
==============================================================================
Binary file - no diff available.
Propchange: dev/kafka/3.7.0/kafka_2.13-3.7.0-site-docs.tgz
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: dev/kafka/3.7.0/kafka_2.13-3.7.0-site-docs.tgz.asc
==============================================================================
--- dev/kafka/3.7.0/kafka_2.13-3.7.0-site-docs.tgz.asc (added)
+++ dev/kafka/3.7.0/kafka_2.13-3.7.0-site-docs.tgz.asc Mon Feb 26 11:54:36 2024
@@ -0,0 +1,7 @@
+-----BEGIN PGP SIGNATURE-----
+
+iHUEABYKAB0WIQR8OML2599A5SfHyZbeDZ0S+xNg2gUCZcYp8wAKCRDeDZ0S+xNg
+2nRfAQCBgm3fdId+ovwXo19K+63nAHG/dFN+JBSEP6CDCFxXVgD/V4NFlWjZt9Bk
+QNWU+opiqRv8JVK5K+CSAfqIwdhXyA0=
+=7ogF
+-----END PGP SIGNATURE-----
Added: dev/kafka/3.7.0/kafka_2.13-3.7.0-site-docs.tgz.md5
==============================================================================
--- dev/kafka/3.7.0/kafka_2.13-3.7.0-site-docs.tgz.md5 (added)
+++ dev/kafka/3.7.0/kafka_2.13-3.7.0-site-docs.tgz.md5 Mon Feb 26 11:54:36 2024
@@ -0,0 +1 @@
+kafka_2.13-3.7.0-site-docs.tgz: 69 33 8B 6C F7 7E 15 B3 BE 95 D7 71 9B 1E 8D
5A
Added: dev/kafka/3.7.0/kafka_2.13-3.7.0-site-docs.tgz.sha1
==============================================================================
--- dev/kafka/3.7.0/kafka_2.13-3.7.0-site-docs.tgz.sha1 (added)
+++ dev/kafka/3.7.0/kafka_2.13-3.7.0-site-docs.tgz.sha1 Mon Feb 26 11:54:36 2024
@@ -0,0 +1,2 @@
+kafka_2.13-3.7.0-site-docs.tgz: 81F6 7C51 4F7A 1A41 A708 A945 822C 3C3B B21C
+ 6129
Added: dev/kafka/3.7.0/kafka_2.13-3.7.0-site-docs.tgz.sha512
==============================================================================
--- dev/kafka/3.7.0/kafka_2.13-3.7.0-site-docs.tgz.sha512 (added)
+++ dev/kafka/3.7.0/kafka_2.13-3.7.0-site-docs.tgz.sha512 Mon Feb 26 11:54:36
2024
@@ -0,0 +1,4 @@
+kafka_2.13-3.7.0-site-docs.tgz: F1B6D588 00233E53 D6548FEC 2F508A90 C4B9D388
+ B5AB92DD 4136AEA0 10A3A65B 16D149C9 2F69E7D2
+ C3E19B78 38C6B5E1 274AA28D 2D53FE7B 45C3A1F0
+ 4065114A
Added: dev/kafka/3.7.0/kafka_2.13-3.7.0.tgz
==============================================================================
Binary file - no diff available.
Propchange: dev/kafka/3.7.0/kafka_2.13-3.7.0.tgz
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: dev/kafka/3.7.0/kafka_2.13-3.7.0.tgz.asc
==============================================================================
--- dev/kafka/3.7.0/kafka_2.13-3.7.0.tgz.asc (added)
+++ dev/kafka/3.7.0/kafka_2.13-3.7.0.tgz.asc Mon Feb 26 11:54:36 2024
@@ -0,0 +1,7 @@
+-----BEGIN PGP SIGNATURE-----
+
+iHUEABYKAB0WIQR8OML2599A5SfHyZbeDZ0S+xNg2gUCZcYp9AAKCRDeDZ0S+xNg
+2t5mAQCI3ceefurST6Hluh83M4+sscF0Kku0lVkXxf9sAAhrIgD/XuIiBwi1vpS0
+I4cCj50Y9ZNpfZE/rfTkuyii6nf62wM=
+=xFdh
+-----END PGP SIGNATURE-----
Added: dev/kafka/3.7.0/kafka_2.13-3.7.0.tgz.md5
==============================================================================
--- dev/kafka/3.7.0/kafka_2.13-3.7.0.tgz.md5 (added)
+++ dev/kafka/3.7.0/kafka_2.13-3.7.0.tgz.md5 Mon Feb 26 11:54:36 2024
@@ -0,0 +1 @@
+kafka_2.13-3.7.0.tgz: B7 66 01 FD 46 A8 87 C9 CB 8B 37 8E 3F 5D 28 86
Added: dev/kafka/3.7.0/kafka_2.13-3.7.0.tgz.sha1
==============================================================================
--- dev/kafka/3.7.0/kafka_2.13-3.7.0.tgz.sha1 (added)
+++ dev/kafka/3.7.0/kafka_2.13-3.7.0.tgz.sha1 Mon Feb 26 11:54:36 2024
@@ -0,0 +1 @@
+kafka_2.13-3.7.0.tgz: DBC7 D754 3A9F E16C 3A93 D987 49DF 05AF 34EC 6E5B
Added: dev/kafka/3.7.0/kafka_2.13-3.7.0.tgz.sha512
==============================================================================
--- dev/kafka/3.7.0/kafka_2.13-3.7.0.tgz.sha512 (added)
+++ dev/kafka/3.7.0/kafka_2.13-3.7.0.tgz.sha512 Mon Feb 26 11:54:36 2024
@@ -0,0 +1,3 @@
+kafka_2.13-3.7.0.tgz: B8679283 A2D8DAB8 6E7C636B 2C688FE9 D9E64AC4 37241F65
+ EF7A1733 F4D26A2B D415EEFA 04F09F19 11373BCD 2A5DBC38
+ 38C76347 F6865642 5C09202C D290CE91
