Messages by Thread
-
(kafka-site) branch markdown updated: MINOR: Add CVE-2026-33557 and CVE-2026-33558 (#848)
mimaison
-
(kafka-site) branch dependabot/npm_and_yarn/npm-check-updates-21.0.0 deleted (was 3a739055c8)
github-bot
-
(kafka-site) branch dependabot/npm_and_yarn/npm-check-updates-21.0.2 created (now 3b5b2764d2)
github-bot
-
(kafka) branch trunk updated: MINOR: formatting fix on UpdateRaftVoterRequest class declaration (#22010)
chia7712
-
(kafka) branch test-catalog updated: Update test catalog data for GHA workflow run 24500771809
github-bot
-
(kafka) branch trunk updated: KAFKA-20297 move Crc32C Checksums and Sanitizer from utils to utils.internals (#22072)
chia7712
-
(kafka) branch trunk updated: MINOR: Use maybeSetDslStoreFormatHeaders helper in more streams test classes (#22057)
chia7712
-
(kafka) branch test-catalog updated: Update test catalog data for GHA workflow run 24472241884
github-bot
-
(kafka) branch trunk updated: MINOR: increase test visibility to public in client integration tests. (#22069)
lianetm
-
(kafka) branch trunk updated (2299a06e319 -> 3852c50c5f9)
chia7712
-
(kafka) branch 4.2 updated: MINOR: add comma before "and" in README (#22064)
chia7712
-
(kafka) branch 4.1 updated: MINOR: add comma before "and" in README (#22064)
chia7712
-
(kafka) branch 4.2 updated: KAFKA-20085 Replace verbose version instructions with updateVersion task (#22065)
chia7712
-
(kafka) branch test-catalog updated: Update test catalog data for GHA workflow run 24455590028
github-bot
-
(kafka) branch 4.2 updated: MINOR: Remove -SNAPSHOT in version.py (#22066)
payang
-
(kafka) branch trunk updated: KAFKA-20297: Move AbstractIterator, CircularIterator, CloseableIterator... into internal (#22052)
payang
-
(kafka) branch trunk updated: KAFKA-20442: Update streams group assignment epoch when last member leaves (#22047)
dajac
-
(kafka) branch trunk updated: KAFKA-20442: Update share group assignment epoch when last member leaves (#22046)
dajac
-
(kafka) branch trunk updated: KAFKA-20442: Update consumer group assignment epoch when last member leaves (#22045)
dajac
-
(kafka) branch test-catalog updated: Update test catalog data for GHA workflow run 24422993545
github-bot
-
(kafka) branch 4.2 updated: MINOR: Delegate version updates to Gradle in release script (#22031)
payang
-
(kafka) branch 4.3 updated: MINOR: Delegate version updates to Gradle in release script (#22031)
payang
-
(kafka) branch trunk updated: MINOR: Clarify docs for consumer leave options & rebalances (#22058)
lianetm
-
(kafka) branch test-catalog updated: Update test catalog data for GHA workflow run 24413277748
github-bot
-
(kafka-site) branch dependabot/npm_and_yarn/npm-check-updates-21.0.0 created (now 3a739055c8)
github-bot
-
(kafka-site) branch dependabot/npm_and_yarn/npm-check-updates-20.0.2 deleted (was d8a3e00e6c)
github-bot
-
(kafka) branch 4.3 updated: KAFKA-19649: Document ListOffsets API v11 and follower fetch from tiered of… (#22038)
mimaison
-
(kafka) branch trunk updated: KAFKA-19649: Document ListOffsets API v11 and follower fetch from tiered of… (#22038)
mimaison
-
(kafka) branch trunk updated: KAFKA-20449: Downgrade "not updating high watermark" log from WARN to DEBUG (#22055)
lianetm
-
(kafka) branch 4.3 updated: MINOR: fix incorrect JavaDocs for headers-stores (#22043)
mjsax
-
(kafka) branch trunk updated: KAFKA-20297 move KafkaThread, ThreadUtils, ExponentialBackoff and ExponentialBackoffManager to internal (#22049)
chia7712
-
(kafka) branch trunk updated: KAFKA-19768 Update ci-complete to support branch 4.0 buildscan upload (#20805)
chia7712
-
(kafka) branch trunk updated: KAFKA-20165 [2]: Integration tests to validate different OffsetFetch response behaviour on topic deleted (#21509)
lianetm
-
(kafka) branch trunk updated: MINOR: Delegate version updates to Gradle in release script (#22031)
chia7712
-
(kafka) branch trunk updated: Revert "KAFKA-13499: Avoid restoring outdated records (#21901)"
mjsax
-
(kafka) branch trunk updated: MINOR: fix incorrect JavaDocs for headers-stores (#22043)
mjsax
-
(kafka) branch trunk updated: MINOR: Clarify group.consumer.assignors doc about default assignor change (#22039)
dajac
-
(kafka) branch 4.3 updated: KAFKA-20446 KAFKA-20447: Fix CVE-2026-28390 and CVE-2026-22184 (#22053)
chia7712
-
(kafka) branch 4.2 updated: KAFKA-20446 KAFKA-20447: Fix CVE-2026-28390 and CVE-2026-22184 (#22053)
chia7712
-
(kafka) branch trunk updated: KAFKA-20446 KAFKA-20447: Fix CVE-2026-28390 and CVE-2026-22184 (#22053)
chia7712
-
(kafka) branch test-catalog updated: Update test catalog data for GHA workflow run 24393549601
github-bot
-
(kafka) branch trunk updated: KAFKA-20329: Test headers dsl.store.format further (3/N) (#21820)
frankvicky
-
(kafka) branch trunk updated: KAFKA-20252: Migrate clearYammerMetrics to TestUtils (#21679)
mimaison
-
(kafka) branch trunk updated: MINOR: Clarify components not considered for security issues (#22048)
mimaison
-
(kafka) branch trunk updated: MINOR: Move KafkaMetricsGroupTest from Scala to Java (#22028)
mimaison
-
(kafka) branch dependabot/pip/tests/pytest-9.0.3 deleted (was 1f76b1fe99a)
mimaison
-
(kafka) branch trunk updated: MINOR: Bump pytest from 8.3.3 to 9.0.3 in /tests (#22042)
mimaison
-
(kafka) branch test-catalog updated: Update test catalog data for GHA workflow run 24383013070
github-bot
-
(kafka) branch trunk updated: KAFKA-20182 Remove removeUnusedImports and upgrade spotless to 8.4.0 (#22025)
chia7712
-
(kafka) branch trunk updated: MINOR: Flaky test fixes (#21986)
chia7712
-
(kafka) branch dependabot/pip/tests/pytest-9.0.3 created (now 1f76b1fe99a)
github-bot
-
(kafka-site) branch dependabot/npm_and_yarn/npm-check-updates-20.0.1 deleted (was 1378625c74)
github-bot
-
(kafka-site) branch dependabot/npm_and_yarn/npm-check-updates-20.0.2 created (now d8a3e00e6c)
github-bot
-
(kafka) branch trunk updated: KAFKA-20434: Consumer group does not recompute assignment when static members rejoin with different assignor (#22036)
dajac
-
(kafka) branch trunk updated: MINOR: Code cleanup in server module (#22026)
mimaison
-
(kafka) branch 4.2 updated (8adfdeca85a -> 6c7e6fb2c64)
payang
-
(kafka) branch 4.3 updated (67ae18eaae3 -> 9c302a16cf3)
payang
-
(kafka) branch trunk updated: MINOR: Fix arguments in trivy scan (#22032)
chia7712
-
(kafka) branch trunk updated: MINOR: Change trivy action (#22024)
payang
-
(kafka) branch test-catalog updated: Update test catalog data for GHA workflow run 24283715766
github-bot
-
(kafka) branch 4.3 updated: KAFKA-20428: Fix unsubscribe failure with assignment updates (#22011)
lianetm
-
(kafka) branch trunk updated: KAFKA-20428: Fix unsubscribe failure with assignment updates (#22011)
lianetm
-
(kafka) branch trunk updated: MINOR: Various code cleanups in server (#22021)
mimaison
-
(kafka) branch trunk updated: MINOR: Fix tool package in kafka-dump-log.bat (#22014)
mimaison
-
(kafka) annotated tag 4.2.1-rc0 updated (8adfdeca85a -> 1e75ec1b11c)
payang
-
(kafka) branch 4.2 updated (c40116e620f -> 8adfdeca85a)
payang
-
(kafka) branch 4.3 updated: MINOR: fix the Custom Exception Handler Implementation example. (#22022)
mjsax
-
(kafka) branch trunk updated: MINOR: fix the Custom Exception Handler Implementation example. (#22022)
mjsax
-
svn commit: r83744 - in dev/kafka/4.2.1-rc0: . javadoc javadoc/legal javadoc/org javadoc/org/apache javadoc/org/apache/kafka javadoc/org/apache/kafka/clients javadoc/org/apache/kafka/clients/admin javadoc/org/apache/kafka/clients/consumer javadoc/org/a...
payang
-
(kafka) branch 4.2 updated: Revert "MINOR: Bump version to 4.2.1"
payang
-
(kafka) branch test-catalog updated: Update test catalog data for GHA workflow run 24263688679
github-bot
-
(kafka) branch 4.2 updated: MINOR: Bump version to 4.2.1
payang
-
(kafka) branch 4.3 updated: Revert "KAFKA-18652: Add `task.offset.interval.ms` config (#21737)" (#22020)
mjsax
-
(kafka) branch test-catalog updated: Update test catalog data for GHA workflow run 24259324198
github-bot
-
(kafka) branch trunk updated: KAFKA-20245: DLQ share group client REJECT ack records. [2/N] (#21793)
schofielaj
-
(kafka-site) branch dependabot/npm_and_yarn/npm-check-updates-20.0.1 created (now 1378625c74)
github-bot
-
(kafka-site) branch dependabot/npm_and_yarn/npm-check-updates-20.0.0 deleted (was 087f24aac8)
github-bot
-
(kafka) branch test-catalog updated: Update test catalog data for GHA workflow run 24251497539
github-bot
-
(kafka) branch 4.3 updated: KAFKA-20431: ConsumerGroupDescribe API does not return partitions being revoked (#22015)
dajac
-
(kafka) branch trunk updated: KAFKA-20417: Add KIP-1035 self-managed offset recovery integration tests (#21998)
bbejeck
-
(kafka) branch trunk updated: KAFKA-20431: ConsumerGroupDescribe API does not return partitions being revoked (#22015)
dajac
-
(kafka) branch trunk updated: KAFKA-20378 Make container memory limit configurable (#21924)
chia7712
-
(kafka) branch test-catalog updated: Update test catalog data for GHA workflow run 24239039145
github-bot
-
(kafka) branch trunk updated: KAFKA-20323: Refactor deleteRecords stub to use partition-based matching for Mockito upgrade (#21857)
schofielaj
-
(kafka) branch trunk updated: KAFKA-19914: Move AlterPartitionManager to server module (#21432)
mimaison
-
(kafka) branch trunk updated: KAFKA-20363 Fix flaky testIdleTimeCallback in KafkaEventQueueTest (#21920)
chia7712
-
(kafka) branch trunk updated: KAFKA-20354: Add missing Control Batch types in documentation (#21866)
mimaison
-
(kafka) branch trunk updated (123ee9e45d7 -> 7aaf4de8207)
chia7712
-
(kafka) branch test-catalog updated: Update test catalog data for GHA workflow run 24213774190
github-bot
-
(kafka) branch test-catalog updated: Update test catalog data for GHA workflow run 24202729980
github-bot
-
(kafka) branch 4.2 updated: KAFKA-20393: Fix stickyNode using stale IP when broker address changes (#21983)
mittal
-
(kafka) branch trunk updated: KAFKA-20393: Fix stickyNode using stale IP when broker address changes (#21983)
mittal
-
(kafka) branch trunk updated: KAFKA-20337 Make all GroupConfig fields Optional and clean up validation (#22003)
chia7712
-
(kafka) branch 4.2 updated: MINOR: Bump Jackson to 2.21.2 (#22008)
mimaison
-
(kafka) branch 4.3 updated: MINOR: Bump Jackson to 2.21.2 (#22008)
mimaison
-
(kafka) branch trunk updated: MINOR: Bump Jackson to 2.21.2 (#22008)
mimaison
-
(kafka) branch test-catalog updated: Update test catalog data for GHA workflow run 24182164166
github-bot
-
(kafka) branch 4.3 updated: KAFKA-20306: StreamsGroupCommand should display committed offsets for repartition topics (#21817)
lucasbru
-
(kafka) branch trunk updated: KAFKA-20089 clients - update javadocs -- while topic being created in background (#21959)
chia7712
-
(kafka) branch trunk updated: KAFKA-20425: Optimize purgatory triggers when no data is available for share fetch (#22005)
mittal
-
(kafka) branch test-catalog updated: Update test catalog data for GHA workflow run 24174174737
github-bot
-
(kafka) branch trunk updated: KAFKA-20194: Ensure backward compatibility for Windowed Store (#22004)
mjsax
-
(kafka) branch 4.3 updated: Revert "KAFKA-13499: Avoid restoring outdated records (#21901)"
mjsax
-
(kafka) branch 4.3 updated: KAFKA-20194: Ensure backward compatibility for Windowed Store (#22004)
mjsax
-
(kafka) branch trunk updated: KAFKA-20332 [2]: Handle wakeup on poll reconciliation check (#21997)
lianetm
-
(kafka) branch 4.3 updated: KAFKA-20307: expose header-stores natively in IQv1 (#21992)
mjsax
-
(kafka) branch 4.3 updated: KAFKA-19863: Add documentation on how to implement a custom exception(with ref to DLQ) (#21606)
bbejeck
-
(kafka) branch trunk updated: KAFKA-19863: Add documentation on how to implement a custom exception(with ref to DLQ) (#21606)
bbejeck
-
(kafka) branch 4.3 updated: KAFKA-20332 [2]: Handle wakeup on poll reconciliation check (#21997)
lianetm
-
(kafka) branch trunk updated: KAFKA-20194: Add sesssion-header-store support to TDD (#21956)
mjsax
-
(kafka) branch 4.3 updated: KAFKA-20264: fix overwrite in recursive parent-node matching (#21540)
bbejeck
-
(kafka) branch trunk updated: KAFKA-20307: expose header-stores natively in IQv1 (#21992)
mjsax
-
(kafka-site) branch dependabot/npm_and_yarn/hugo-extended-0.160.1 created (now 37a0e32e53)
github-bot
-
(kafka) branch trunk updated: KAFKA-20264: fix overwrite in recursive parent-node matching (#21540)
bbejeck
-
(kafka) branch trunk updated: KAFKA-20329: Test `headers` dsl.store.format further (1/N) (#21806)
frankvicky
-
(kafka) branch 4.3 updated (384db3be186 -> f8d5f730e2d)
lianetm
-
(kafka) branch test-catalog updated: Update test catalog data for GHA workflow run 24146608076
github-bot
-
(kafka) branch 4.2 updated: KAFKA-20332 [2]: Handle wakeup on poll reconciliation check (#21997)
lianetm
-
(kafka-site) branch dependabot/npm_and_yarn/hugo-extended-0.160.0 deleted (was e82c4d1ed3)
github-bot
-
(kafka) branch trunk updated: KAFKA-20415: Add share.version=2 for gated DLQ support. (#21994)
schofielaj
-
(kafka) branch 4.3 updated: KAFKA-20194: Add sesssion-header-store support to TDD (#21956)
mjsax
-
(kafka) branch trunk updated: MINOR: Fix double negative typos in Javadoc and exception messages (#21977)
chia7712
-
(kafka) branch 4.2 updated: KAFKA-20332: Fix to ensure app thread not collecting records for partitions being revoked (#21897)
lianetm
-
(kafka) branch 4.3 updated: KAFKA-20332: Fix to ensure app thread not collecting records for partitions being revoked (#21897)
lianetm
-
(kafka) branch 4.2 updated: MINOR: Cleanup in SharePartition acknowledgement functionality (#21236)
mittal
-
(kafka) branch 4.2 updated: KAFKA-20398: Fix memory leak by removing StreamsThreadMetricsDelegatingReporter from metrics registry on thread (#21989)
lucasbru
-
(kafka) branch test-catalog updated: Update test catalog data for GHA workflow run 24119254306
github-bot
-
(kafka) branch 4.3 updated: KAFKA-20219: Headers store with caching enabled should reject queries (#21941)
mjsax
-
(kafka) branch trunk updated: KAFKA-20219: Headers store with caching enabled should reject queries (#21941)
mjsax
-
(kafka) branch trunk updated: MINOR: Fix log statement formatting in KafkaAdminClient (#21990)
chia7712
-
(kafka) branch trunk updated: MINOR: fix typo in KafkaAdminClient to align the meaning (#21988)
chia7712
-
(kafka) branch test-catalog updated: Update test catalog data for GHA workflow run 24112611496
github-bot
-
(kafka) branch trunk updated: KAFKA-20119 Clarify that `Consumer#unsubscribe` does not trigger auto-commit (#21424)
chia7712
-
(kafka) branch test-catalog updated: Update test catalog data for GHA workflow run 24103889692
github-bot
-
(kafka) branch trunk updated: KAFKA-20332: Fix to ensure app thread not collecting records for partitions being revoked (#21897)
lianetm
-
(kafka) branch 4.3 updated: KAFKA-20173: Ensure Metered session-stores pass headers correctly (#21957)
mjsax
-
(kafka) branch trunk updated: KAFKA-20173: Ensure Metered session-stores pass headers correctly (#21957)
mjsax
-
(kafka) branch 4.3 updated: KAFKA-20194: Fix StoreBuilderWrapper for header-stores (#21950)
mjsax
-
(kafka) branch trunk updated: KAFKA-20194: Fix StoreBuilderWrapper for header-stores (#21950)
mjsax
-
(kafka) branch 4.3 updated: KAFKA-20376: Update consumer rebalance docs (#21930)
lianetm
-
(kafka) branch 4.3 updated: KAFKA-20398: Fix memory leak by removing StreamsThreadMetricsDelegatingReporter from metrics registry on thread shutdown (#21973)
bbejeck
-
(kafka) branch 4.3 updated: KAFKA-20396: Fix RocksDBStore initialization error handling (#21946)
bbejeck
-
(kafka) branch trunk updated: KAFKA-20396: Fix RocksDBStore initialization error handling (#21946)
bbejeck
-
(kafka) branch test-catalog updated: Update test catalog data for GHA workflow run 24094598924
github-bot
-
(kafka) branch trunk updated: KAFKA-20376: Update consumer rebalance docs (#21930)
lianetm
-
(kafka) branch trunk updated: KAFKA-20398: Fix memory leak by removing StreamsThreadMetricsDelegatingReporter from metrics registry on thread shutdown (#21973)
bbejeck
-
(kafka) branch trunk updated: MINOR: Replace Map conversions with MetricsUtils.getTags for metric tags (#21948)
chia7712
-
(kafka) branch trunk updated: KAFKA-20408 Remove ConsumerMetrics wrapper (#21974)
chia7712
-
(kafka) branch trunk updated: KAFKA-20297 move testIncrement and testIncrementUpperBoundary to ByteUtilsTest (#21913)
chia7712
-
(kafka) branch trunk updated: MINOR: Suppress the deprecation warning for `LOG_CLEANER_ENABLE_PROP` in `LogCleanerIntegrationTest` (#21982)
chia7712
-
(kafka) branch 4.3 updated: KAFKA-20339: Remove assignment offloading configs for 4.3 (#21926)
dajac
-
(kafka) branch trunk updated (c9cfaafac4f -> 8ddda49ff64)
chia7712
-
(kafka-site) branch asf-staging updated: Updated asf-staging from GHA workflow run 24081265913
github-bot
-
(kafka-site) branch markdown updated: minor cleanups (#842)
manikumar
-
(kafka-site) branch markdown updated: Add CVE-2026-35554 to the list
manikumar
-
(kafka) branch 4.3 updated: KAFKA-20331, KAFKA-20240: Update upgrade.md for new KIP-1263 configs in 4.3 (#21822)
dajac
-
(kafka) branch trunk updated: KAFKA-20331, KAFKA-20240: Update upgrade.md for new KIP-1263 configs in 4.3 (#21822)
dajac
-
(kafka) branch trunk updated: KAFKA-20405: Remove redundant `numClassicGroupsTimelineCounter` (#21978)
dajac
-
(kafka) branch test-catalog updated: Update test catalog data for GHA workflow run 24053561987
github-bot
-
(kafka-site) branch dependabot/npm_and_yarn/hugo-extended-0.160.0 created (now e82c4d1ed3)
github-bot
-
(kafka) branch 4.3 updated: KAFKA-20194: Ensure backward compatibility for Sliding Windows (#21949)
mjsax
-
(kafka) branch trunk updated: KAFKA-20194: Ensure backward compatibility for Sliding Windows (#21949)
mjsax
-
(kafka) branch trunk updated: KAFKA-13819: Add application.server to Streams assignor logs when set (#21605)
mjsax
-
(kafka-site) branch dependabot/npm_and_yarn/hugo-extended-0.159.2 deleted (was 3ac7a732d0)
github-bot
-
(kafka) branch test-catalog updated: Update test catalog data for GHA workflow run 24027501501
github-bot
-
(kafka) branch trunk updated: KAFKA-20346 LogCleaner#cleaners should be thread-safe (#21847)
chia7712
-
(kafka) branch trunk updated: KAFKA-19566 Deprecate ClientQuotaCallback#updateClusterMetadata (#21958)
chia7712
-
(kafka) branch test-catalog updated: Update test catalog data for GHA workflow run 23992935467
github-bot
-
(kafka) branch 4.3 updated: KAFKA-20173: Propagate headers into serde 8/N (#21967)
mjsax
-
(kafka) branch trunk updated: KAFKA-20173: Propagate headers into serde 8/N (#21967)
mjsax
-
(kafka) branch 4.3 updated: KAFKA-20173: Propagate headers into serde 9/N (#21969)
mjsax
-
(kafka) branch trunk updated: KAFKA-20173: Propagate headers into serde 9/N (#21969)
mjsax
-
(kafka) branch 4.3 updated: MINOR: Simplify inheritance for MeteredTimestampedWindowStoreWithHeaders (#21966)
mjsax
-
(kafka) branch trunk updated: MINOR: Simplify inheritance for MeteredTimestampedWindowStoreWithHeaders (#21966)
mjsax
-
(kafka) branch trunk updated: KAFKA-20357 Unify method signature for retrieving config names across config classes (#21951)
chia7712
-
(kafka) branch test-catalog updated: Update test catalog data for GHA workflow run 23972529762
github-bot
-
(kafka) branch trunk updated: KAFKA-15529 Fix race condition between isConsumed and position updates in AsyncKafkaConsumer fetch path (#21476)
chia7712
-
(kafka) branch trunk updated: KAFKA-20362 Auto-fill PR reviewers in PR description (#21928)
chia7712
-
(kafka) branch 4.1 updated: KAFKA-20344: Upgrade Jetty to 12.0.34 (4.1) (#21940)
payang
-
(kafka) branch test-catalog updated: Update test catalog data for GHA workflow run 23959556273
github-bot
-
(kafka) branch 4.3 updated: KAFKA-20194: Ensure backward compatibility for Session Stores (#21934)
mjsax
-
(kafka-site) branch dependabot/npm_and_yarn/hugo-extended-0.159.2 created (now 3ac7a732d0)
github-bot
-
(kafka-site) branch dependabot/npm_and_yarn/hugo-extended-0.158.0 deleted (was 6238031d0f)
github-bot
-
(kafka) branch test-catalog updated: Update test catalog data for GHA workflow run 23936352527
github-bot
-
(kafka) branch trunk updated: KAFKA-20194: Ensure backward compatibility for Session Stores (#21934)
mjsax
-
(kafka) branch trunk updated: KAFKA-20368 Use LinkedHashMap for deterministic metric tags order in RLMExpirationTask (#21931)
chia7712
-
(kafka) branch 4.1 updated: MINOR: Update all github actions to latest version (#20649)
chia7712
-
(kafka) branch trunk updated: KAFKA-20344: Upgrade Jetty to 12.0.34 (trunk, 4.3, 4.2) (#21939)
payang
-
(kafka) branch 4.2 updated: KAFKA-20344: Upgrade Jetty to 12.0.34 (trunk, 4.3, 4.2) (#21939)
payang
-
(kafka) branch 4.3 updated: KAFKA-20344: Upgrade Jetty to 12.0.34 (trunk, 4.3, 4.2) (#21939)
payang
-
(kafka) branch trunk updated (d840776ed7d -> c7d574e75f4)
payang
-
(kafka) branch trunk updated: MINOR: Fix typo 'reqeust' to 'request' in NetworkPartitionMetadataClientTest (#21945)
schofielaj
-
(kafka) branch test-catalog updated: Update test catalog data for GHA workflow run 23933828532
github-bot
-
(kafka) branch 4.3 updated: MINOR: Fix headers in KTableMapValues and KTableTransformValues (#21835)
mjsax