{"payload":{"feedbackUrl":"https://github.com/orgs/community/discussions/53140","repo":{"id":2211243,"defaultBranch":"trunk","name":"kafka","ownerLogin":"apache","currentUserCanPush":false,"isFork":false,"isEmpty":false,"createdAt":"2011-08-15T18:06:16.000Z","ownerAvatar":"https://avatars.githubusercontent.com/u/47359?v=4","public":true,"private":false,"isOrgOwned":true},"refInfo":{"name":"","listCacheKey":"v0:1716245978.0","currentOid":""},"activityList":{"items":[{"before":"a8d166c00e6023b478a30092b1b92ded395cfc6e","after":"d9ee9c96dd5081f3b494f5fc820fb3f51328993f","ref":"refs/heads/trunk","pushedAt":"2024-05-25T19:22:56.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"mjsax","name":"Matthias J. Sax","path":"/mjsax","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/8959638?s=80&v=4"},"commit":{"message":"KAFKA-15541: Use LongAdder instead of AtomicInteger (#16076)\n\n`LongAdder` performs better than `AtomicInteger` when under contention\r\nfrom many threads. Since it's possible that many Interactive Query\r\nthreads could create a large number of `KeyValueIterator`s, we don't\r\nwant contention on a metric to be a performance bottleneck.\r\n\r\nThe trade-off is memory, as `LongAdder` uses more memory to space out\r\nindependent counters across different cache lines. In practice, I don't\r\nexpect this to cause too many problems, as we're only constructing 1\r\nper-store.\r\n\r\nReviewers: Matthias J. Sax ","shortMessageHtmlLink":"KAFKA-15541: Use LongAdder instead of AtomicInteger (#16076)"}},{"before":"d585a494a4871eaecdddf98f8655b8f30c5bd834","after":"a8d166c00e6023b478a30092b1b92ded395cfc6e","ref":"refs/heads/trunk","pushedAt":"2024-05-25T16:06:15.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"dajac","name":"David Jacot","path":"/dajac","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/157182?s=80&v=4"},"commit":{"message":"KAFKA-16625; Reverse lookup map from topic partitions to members (#15974)\n\nThis patch speeds up the computation of the unassigned partitions by exposing the inverted target assignment. It allows the assignor to check whether a partition is assigned or not.\r\n\r\nReviewers: Jeff Kim , David Jacot ","shortMessageHtmlLink":"KAFKA-16625; Reverse lookup map from topic partitions to members (#15974"}},{"before":"8eea6b82638d69de536c8797bb318ed278f01695","after":"d585a494a4871eaecdddf98f8655b8f30c5bd834","ref":"refs/heads/trunk","pushedAt":"2024-05-24T20:33:57.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"dajac","name":"David Jacot","path":"/dajac","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/157182?s=80&v=4"},"commit":{"message":"KAFKA-16831: CoordinatorRuntime should initialize MemoryRecordsBuilder with max batch size write limit (#16059)\n\nCoordinatorRuntime should initialize MemoryRecordsBuilder with max batch size write limit. Otherwise, we default the write limit to the min buffer size of 16384 for the write limit. This causes the coordinator to threw RecordTooLargeException even when it's under the 1MB max batch size limit.\r\n\r\nReviewers: David Jacot ","shortMessageHtmlLink":"KAFKA-16831: CoordinatorRuntime should initialize MemoryRecordsBuilde…"}},{"before":"30aaed388b12002db28060adc52f6d0db62e54d0","after":"39ddeb08e906fcaf3002c77d57a5101b53ebf4a1","ref":"refs/heads/3.7","pushedAt":"2024-05-24T20:28:36.000Z","pushType":"push","commitsCount":2,"pusher":{"login":"edoardocomar","name":"Edoardo Comar","path":"/edoardocomar","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/6661532?s=80&v=4"},"commit":{"message":"MINOR: mention KAFKA-15905 in docs \"Notable changes in 3.7.1\"\n\nCo-Authored-By: Adrian Preston ","shortMessageHtmlLink":"MINOR: mention KAFKA-15905 in docs \"Notable changes in 3.7.1\""}},{"before":"4f55786a8a86fe228a0b10a2f28529f5128e5d6f","after":"8eea6b82638d69de536c8797bb318ed278f01695","ref":"refs/heads/trunk","pushedAt":"2024-05-24T19:33:00.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"edoardocomar","name":"Edoardo Comar","path":"/edoardocomar","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/6661532?s=80&v=4"},"commit":{"message":"MINOR: mention KAFKA-15905 in docs \"Notable changes in 3.7.1\" (#16070)\n\n* MINOR: mention KAFKA-15905 in docs \"Notable changes in 3.7.1/3.8.0\"\r\n\r\nCo-Authored-By: Adrian Preston ","shortMessageHtmlLink":"MINOR: mention KAFKA-15905 in docs \"Notable changes in 3.7.1\" (#16070)"}},{"before":"90892ae99fb09f62197c50fedc320ecebe09baad","after":"4f55786a8a86fe228a0b10a2f28529f5128e5d6f","ref":"refs/heads/trunk","pushedAt":"2024-05-24T17:17:04.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"cmccabe","name":"Colin Patrick McCabe","path":"/cmccabe","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/1095624?s=80&v=4"},"commit":{"message":"KAFKA-16515: Fix the ZK Metadata cache confusion between brokers and controllers\n\nZkMetadataCache could theoretically return KRaft controller information from a call to\nZkMetadataCache.getAliveBrokerNode, which doesn't make sense. KRaft controllers are not part of the\nset of brokers. The only use-case for this functionality was in MetadataCacheControllerNodeProvider\nduring ZK migration, where it allowed ZK brokers in migration mode to forward requests to\nkcontrollers when appropriate. This PR changes MetadataCacheControllerNodeProvider to simply\ndelegate to quorumControllerNodeProvider in this case.\n\nReviewers: José Armando García Sancio ","shortMessageHtmlLink":"KAFKA-16515: Fix the ZK Metadata cache confusion between brokers and …"}},{"before":"2432a1866e7bd270f1073cea7c9594e111aed78b","after":"90892ae99fb09f62197c50fedc320ecebe09baad","ref":"refs/heads/trunk","pushedAt":"2024-05-24T16:54:00.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"cmccabe","name":"Colin Patrick McCabe","path":"/cmccabe","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/1095624?s=80&v=4"},"commit":{"message":"KAFKA-16516: Fix the controller node provider for broker to control channel\n\nFix the code in the RaftControllerNodeProvider to query RaftManager to find Node information,\nrather than consulting a static map. Add a RaftManager.voterNode function to supply this\ninformation. In KRaftClusterTest, add testControllerFailover to get more coverage of controller\nfailovers.\n\nReviewers: José Armando García Sancio ","shortMessageHtmlLink":"KAFKA-16516: Fix the controller node provider for broker to control c…"}},{"before":"0143c72e501afd76f89c2da9e4537be5ea11d4a0","after":"2432a1866e7bd270f1073cea7c9594e111aed78b","ref":"refs/heads/trunk","pushedAt":"2024-05-24T16:51:02.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"omkreddy","name":"Manikumar Reddy","path":"/omkreddy","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/8134545?s=80&v=4"},"commit":{"message":"KAFKA-16373: KIP-1028: Adding code to support Apache Kafka Docker Official Images (#16027)\n\nThis PR aims to add JVM based Docker Official Image for Apache Kafka as per the following KIP - https://cwiki.apache.org/confluence/display/KAFKA/KIP-1028%3A+Docker+Official+Image+for+Apache+Kafka\r\n\r\nThis PR adds the following functionalities:\r\nIntroduces support for Apache Kafka Docker Official Images via:\r\n\r\nGitHub Workflows:\r\n\r\n- Workflow to prepare static source files for Docker images\r\n- Workflow to build and test Docker official images\r\n- Scripts to prepare source files and perform Docker image builds and tests\r\n\r\nA new directory for Docker official images, named docker/docker_official_images. This is the new directory to house all Docker Official Image assets.\r\n\r\nCo-authored-by: Vedarth Sharma \r\n\r\nReviewers: Manikumar Reddy , Vedarth Sharma ","shortMessageHtmlLink":"KAFKA-16373: KIP-1028: Adding code to support Apache Kafka Docker Off…"}},{"before":"c5cd19081891c058681b3088c30769641bf4ae6b","after":"0143c72e501afd76f89c2da9e4537be5ea11d4a0","ref":"refs/heads/trunk","pushedAt":"2024-05-24T12:19:43.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"dajac","name":"David Jacot","path":"/dajac","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/157182?s=80&v=4"},"commit":{"message":"KAFKA-16815: Handle FencedInstanceId in HB response (#16047)\n\nHandle FencedInstanceIdException that a consumer may receive in the heartbeat response. This will be the case when a static consumer is removed from the group by and admin client, and another member joins with the same group.instance.id (allowed in). The first member will receive a FencedInstanceId on its next heartbeat. The expectation is that this should be handled as a fatal error.\r\n\r\nThere are no actual changes in logic with this PR, given that without being handled, the FencedInstanceId was being treated as an \"unexpected error\", which are all treated as fatal errors, so the outcome remains the same. But we're introducing this small change just for accuracy in the logic and the logs: FencedInstanceId is expected during heartbeat, a log line is shown describing the situation and why it happened (and it's treated as a fatal error, just like it was before this PR).\r\n\r\nThis PR also improves the test to ensure that the error propagated to the app thread matches the one received in the HB.\r\n\r\nReviewers: Andrew Schofield , David Jacot ","shortMessageHtmlLink":"KAFKA-16815: Handle FencedInstanceId in HB response (#16047)"}},{"before":"520aa8665c8bad19c55d74e6b8ac14a4e17de789","after":"c5cd19081891c058681b3088c30769641bf4ae6b","ref":"refs/heads/trunk","pushedAt":"2024-05-24T10:50:47.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"mimaison","name":"Mickael Maison","path":"/mimaison","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/903615?s=80&v=4"},"commit":{"message":"MINOR: Refactor SSL/SASL admin integration tests to not use a custom authorizer (#15377)\n\n\r\nReviewers: Mickael Maison ","shortMessageHtmlLink":"MINOR: Refactor SSL/SASL admin integration tests to not use a custom …"}},{"before":"6941598f710e094fbb272c6f8c243d891ad5c877","after":"520aa8665c8bad19c55d74e6b8ac14a4e17de789","ref":"refs/heads/trunk","pushedAt":"2024-05-24T07:51:50.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"dajac","name":"David Jacot","path":"/dajac","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/157182?s=80&v=4"},"commit":{"message":"KAFKA-16626; Lazily convert subscribed topic names to topic ids (#15970)\n\nThis patch aims to remove the data structure that stores the conversion from topic names to topic ids which was taking time similar to the actual assignment computation. Instead, we reuse the already existing ConsumerGroupMember.subscribedTopicNames() and do the conversion to topic ids when the iterator is requested.\r\n\r\nReviewers: David Jacot ","shortMessageHtmlLink":"KAFKA-16626; Lazily convert subscribed topic names to topic ids (#15970)"}},{"before":"de3202832dcabdb30fbcaa29329552c410db8500","after":"6941598f710e094fbb272c6f8c243d891ad5c877","ref":"refs/heads/trunk","pushedAt":"2024-05-24T06:46:01.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"omkreddy","name":"Manikumar Reddy","path":"/omkreddy","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/8134545?s=80&v=4"},"commit":{"message":"KAFKA-16826: Integrate Native Docker Image with github actions (#16045)\n\nThis PR integrates the Native docker image with the existing github action jobs for the jvm docker image of AK.\r\n\r\nThe integration is done to the following actions:\r\n\r\ndocker_build_and_test.yml: Builds the docker image and runs sanity tests and CVE scan\r\ndocker_rc_release.yml: Builds the RC docker image for both amd and arm platform and pushes it to the dockerhub.\r\ndocker_promote.yml: Promotes the RC docker image to the released image tag\r\n\r\nReviewers: Manikumar Reddy , Vedarth Sharma <142404391+VedarthConfluent@users.noreply.github.com>","shortMessageHtmlLink":"KAFKA-16826: Integrate Native Docker Image with github actions (#16045)"}},{"before":"11ad5e8bca2444d8c51cd6b81ee84dcb41a047c2","after":"de3202832dcabdb30fbcaa29329552c410db8500","ref":"refs/heads/trunk","pushedAt":"2024-05-23T21:25:53.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"chia7712","name":"Chia-Ping Tsai","path":"/chia7712","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/6234750?s=80&v=4"},"commit":{"message":"KAFKA-16828 RackAwareTaskAssignorTest failed (#16044)\n\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-16828 RackAwareTaskAssignorTest failed (#16044)"}},{"before":"93238ae312ef7bea79160e59bb7a06623cc94a1b","after":"11ad5e8bca2444d8c51cd6b81ee84dcb41a047c2","ref":"refs/heads/trunk","pushedAt":"2024-05-23T20:23:18.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"gharris1727","name":"Greg Harris","path":"/gharris1727","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/5856969?s=80&v=4"},"commit":{"message":"MINOR: Refactor Values class to fix checkstyle, add benchmark, optimize exceptions (#15469)\n\nSigned-off-by: Greg Harris \r\nReviewers: Mickael Maison ","shortMessageHtmlLink":"MINOR: Refactor Values class to fix checkstyle, add benchmark, optimi…"}},{"before":"4020307ac2842a35cac8c974ec3ab90153893194","after":"93238ae312ef7bea79160e59bb7a06623cc94a1b","ref":"refs/heads/trunk","pushedAt":"2024-05-23T19:45:29.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"ableegoldman","name":"A. Sophie Blee-Goldman","path":"/ableegoldman","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4843099?s=80&v=4"},"commit":{"message":"KAFKA-15045: (KIP-924 pt. 10) Topic partition rack annotation simplified (#16034)\n\nThis PR uses the new TaskTopicPartition structure to simplify the build\r\nprocess for the ApplicationState, which is the input to the new\r\nTaskAssignor#assign call.\r\n\r\nReviewers: Anna Sophie Blee-Goldman ","shortMessageHtmlLink":"KAFKA-15045: (KIP-924 pt. 10) Topic partition rack annotation simplif…"}},{"before":"c3018ef55ec97f6b2bb08baaf141ff840559e10e","after":"4020307ac2842a35cac8c974ec3ab90153893194","ref":"refs/heads/trunk","pushedAt":"2024-05-23T18:51:26.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"chia7712","name":"Chia-Ping Tsai","path":"/chia7712","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/6234750?s=80&v=4"},"commit":{"message":"KAFKA-16795 Fix broken compatibility in kafka.tools.NoOpMessageFormatter, kafka.tools.DefaultMessageFormatter, and kafka.tools.LoggingMessageFormatter (#16020)\n\nThis commit allows users to apply the scala version Formatters, but users will receive the warning messages about deprecation. \r\n\r\nThis compatibility support will be removed from 4.0.0\r\n \r\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-16795 Fix broken compatibility in kafka.tools.NoOpMessageFormat…"}},{"before":"0ba15ad4d1bd7318d626430035a1666eb16f844d","after":"c3018ef55ec97f6b2bb08baaf141ff840559e10e","ref":"refs/heads/trunk","pushedAt":"2024-05-23T17:15:56.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"gharris1727","name":"Greg Harris","path":"/gharris1727","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/5856969?s=80&v=4"},"commit":{"message":"KAFKA-16804: Replace archivesBaseName with archivesName (#16016)\n\nReviewers: Chia-Ping Tsai , Greg Harris ","shortMessageHtmlLink":"KAFKA-16804: Replace archivesBaseName with archivesName (#16016)"}},{"before":"5a4898450d0125f819f8b5ca5cce53e26ea053af","after":"0ba15ad4d1bd7318d626430035a1666eb16f844d","ref":"refs/heads/trunk","pushedAt":"2024-05-23T16:17:56.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"edoardocomar","name":"Edoardo Comar","path":"/edoardocomar","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/6661532?s=80&v=4"},"commit":{"message":"KAFKA-15905 Restarts of MirrorCheckpointTask should not permanently i… (#15910)\n\n* KAFKA-15905 Restarts of MirrorCheckpointTask should not permanently interrupt offset translation\r\n\r\nMirrorCheckpointTask reloads the last checkpoint at start,\r\nOffsetSyncStore stores OffsetSyncs before reading till end.\r\n\r\nIf CheckpointTask cannot read checkpoints at startup,\r\nuse previous OffsetSyncStore load logic, with\r\nwarning log message about degraded offset translation.\r\n\r\nAlso addresses KAFKA-16622 Mirromaker2 first Checkpoint not emitted until\r\nconsumer group fully catches up once because the OffsetSyncStore store\r\nis populated before reading to log end.\r\n\r\nCo-Authored-By: Adrian Preston \r\nReviewers: Greg Harris ","shortMessageHtmlLink":"KAFKA-15905 Restarts of MirrorCheckpointTask should not permanently i… ("}},{"before":"8d117a188df7a135ad5595d0302ad903f9241027","after":"5a4898450d0125f819f8b5ca5cce53e26ea053af","ref":"refs/heads/trunk","pushedAt":"2024-05-23T15:36:40.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"soarez","name":"Igor Soarez","path":"/soarez","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/1357510?s=80&v=4"},"commit":{"message":"KAFKA-15649: Handle directory failure timeout (#15697)\n\nA broker that is unable to communicate with the controller will shut down\r\nafter the configurable log.dir.failure.timeout.ms.\r\n\r\nThe implementation adds a new event to the Kafka EventQueue. This event\r\nis deferred by the configured timeout and will execute the shutdown\r\nif the heartbeat communication containing the failed log dir is still\r\npending with the controller.\r\n\r\nReviewers: Igor Soarez ","shortMessageHtmlLink":"KAFKA-15649: Handle directory failure timeout (#15697)"}},{"before":"4f73a8d1f06a35a055c68d07e92c785c9383f172","after":"30aaed388b12002db28060adc52f6d0db62e54d0","ref":"refs/heads/3.7","pushedAt":"2024-05-23T15:22:46.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"mimaison","name":"Mickael Maison","path":"/mimaison","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/903615?s=80&v=4"},"commit":{"message":"KAFKA-16825: Update netty/jetty/jackson/zstd dependencies (#16038)\n\nReviewers: Luke Chen ","shortMessageHtmlLink":"KAFKA-16825: Update netty/jetty/jackson/zstd dependencies (#16038)"}},{"before":"ab0cc72499eedd5b5da7232d4a799103d17802fd","after":"8d117a188df7a135ad5595d0302ad903f9241027","ref":"refs/heads/trunk","pushedAt":"2024-05-23T15:03:25.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"mimaison","name":"Mickael Maison","path":"/mimaison","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/903615?s=80&v=4"},"commit":{"message":"KAFKA-16825: Update netty/jetty/jackson/zstd dependencies (#16038)\n\n\r\nReviewers: Luke Chen ","shortMessageHtmlLink":"KAFKA-16825: Update netty/jetty/jackson/zstd dependencies (#16038)"}},{"before":"14b5c4d1e8589ff61faf855e6b64766001e06ecf","after":"ab0cc72499eedd5b5da7232d4a799103d17802fd","ref":"refs/heads/trunk","pushedAt":"2024-05-23T14:01:45.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"mimaison","name":"Mickael Maison","path":"/mimaison","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/903615?s=80&v=4"},"commit":{"message":"MINOR: Move parseCsvList to server-common (#16029)\n\n\r\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"MINOR: Move parseCsvList to server-common (#16029)"}},{"before":"e692feed34c59c71fe0277d08141e023c0d28d73","after":"14b5c4d1e8589ff61faf855e6b64766001e06ecf","ref":"refs/heads/trunk","pushedAt":"2024-05-23T06:27:00.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"dajac","name":"David Jacot","path":"/dajac","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/157182?s=80&v=4"},"commit":{"message":"KAFKA-16793; Heartbeat API for upgrading ConsumerGroup (#15988)\n\nThis patch implements the heartbeat api to the members that use the classic protocol in a ConsumerGroup.\r\n\r\nReviewers: Jeff Kim , David Jacot ","shortMessageHtmlLink":"KAFKA-16793; Heartbeat API for upgrading ConsumerGroup (#15988)"}},{"before":"bef83ce89bb6a869cf884b37d5b5f86d8f243488","after":"e692feed34c59c71fe0277d08141e023c0d28d73","ref":"refs/heads/trunk","pushedAt":"2024-05-23T06:24:23.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"dajac","name":"David Jacot","path":"/dajac","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/157182?s=80&v=4"},"commit":{"message":"MINOR: fix flaky testRecordThreadIdleRatio (#15987)\n\nDelayEventAccumulator should return immediately if there are no events in the queue. Also removed some unused fields inside EventProcessorThread.\r\n\r\nReviewers: Gaurav Narula , Chia-Ping Tsai , David Jacot ","shortMessageHtmlLink":"MINOR: fix flaky testRecordThreadIdleRatio (#15987)"}},{"before":"06739d5aa026e7db62ff0bd7da57e079cca35f07","after":"bef83ce89bb6a869cf884b37d5b5f86d8f243488","ref":"refs/heads/trunk","pushedAt":"2024-05-23T04:34:31.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"mjsax","name":"Matthias J. Sax","path":"/mjsax","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/8959638?s=80&v=4"},"commit":{"message":"KAFKA-15541: Add iterator-duration metrics (#16028)\n\nPart of [KIP-989](https://cwiki.apache.org/confluence/x/9KCzDw).\r\n\r\nThis new `StateStore` metric tracks the average and maximum amount of\r\ntime between creating and closing Iterators.\r\n\r\nIterators with very high durations can indicate to users performance\r\nproblems that should be addressed.\r\n\r\nIf a store reports no data for these metrics, despite the user opening\r\nIterators on the store, it suggests those iterators are not being\r\nclosed, and have therefore leaked.\r\n\r\nReviewers: Matthias J. Sax ","shortMessageHtmlLink":"KAFKA-15541: Add iterator-duration metrics (#16028)"}},{"before":"27a6c156c49e375edea0e6f33a35c64c615db1b5","after":"06739d5aa026e7db62ff0bd7da57e079cca35f07","ref":"refs/heads/trunk","pushedAt":"2024-05-22T22:52:53.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"ableegoldman","name":"A. Sophie Blee-Goldman","path":"/ableegoldman","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4843099?s=80&v=4"},"commit":{"message":"KAFKA-15045: (KIP-924 pt. 8) Added TopicPartitionAssignmentInfo (#16024)\n\nFor task assignment purposes, the user needs to have a set of information available for each topic partition affecting the desired tasks.\r\n\r\nThis PR introduces a new interface for a read-only container class that allows all the important and relevant information to be found in one place.\r\n\r\nReviewers: Anna Sophie Blee-Goldman ","shortMessageHtmlLink":"KAFKA-15045: (KIP-924 pt. 8) Added TopicPartitionAssignmentInfo (#16024)"}},{"before":"ef2c5e41a5418d83cb56b71b897e8ff8ced03c68","after":"27a6c156c49e375edea0e6f33a35c64c615db1b5","ref":"refs/heads/trunk","pushedAt":"2024-05-22T20:25:18.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"ableegoldman","name":"A. Sophie Blee-Goldman","path":"/ableegoldman","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4843099?s=80&v=4"},"commit":{"message":"KAFKA-15045: (KIP-924 pt. 7) Simplify requirements for rack aware graphs (#16004)\n\nRack aware graphs don't actually need any topology information about the system, but rather require a simple ordered (not sorted) grouping of tasks.\r\n\r\nThis PR changes the internal constructors and some interface signatures of RackAwareGraphConstructor and its implementations to allow reuse by future components that may not have access to the actual subtopology information.\r\n\r\nReviewers: Anna Sophie Blee-Goldman ","shortMessageHtmlLink":"KAFKA-15045: (KIP-924 pt. 7) Simplify requirements for rack aware gra…"}},{"before":"a753172ad3e0927f412fb56e468c95a9a81ba3ad","after":"ef2c5e41a5418d83cb56b71b897e8ff8ced03c68","ref":"refs/heads/trunk","pushedAt":"2024-05-22T20:24:26.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"ableegoldman","name":"A. Sophie Blee-Goldman","path":"/ableegoldman","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4843099?s=80&v=4"},"commit":{"message":"KAFKA-15045: (KIP-924 pt. 5) Add rack information to ApplicationState (#15972)\n\nThis rack information is required to compute rack-aware assignments, which many of the current assigners do.\r\n\r\nThe internal ClientMetadata class was also edited to pass around this rack information.\r\n\r\nReviewers: Anna Sophie Blee-Goldman ","shortMessageHtmlLink":"KAFKA-15045: (KIP-924 pt. 5) Add rack information to ApplicationState (…"}},{"before":"e4e1116156d44d5e7a52ad8fb51a57d5e5755710","after":"a753172ad3e0927f412fb56e468c95a9a81ba3ad","ref":"refs/heads/trunk","pushedAt":"2024-05-22T16:52:41.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"mimaison","name":"Mickael Maison","path":"/mimaison","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/903615?s=80&v=4"},"commit":{"message":"KAFKA-12399: Deprecate KafkaLog4jAppender (#15985)\n\n\r\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-12399: Deprecate KafkaLog4jAppender (#15985)"}},{"before":"a98c9be6b00806c870c542c2a6ecbd247e2bf712","after":"e4e1116156d44d5e7a52ad8fb51a57d5e5755710","ref":"refs/heads/trunk","pushedAt":"2024-05-22T16:47:31.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"mimaison","name":"Mickael Maison","path":"/mimaison","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/903615?s=80&v=4"},"commit":{"message":"MINOR: Move Throttler to storage module (#16023)\n\n\r\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"MINOR: Move Throttler to storage module (#16023)"}}],"hasNextPage":true,"hasPreviousPage":false,"activityType":"all","actor":null,"timePeriod":"all","sort":"DESC","perPage":30,"cursor":"djE6ks8AAAAEU9hUkAA","startCursor":null,"endCursor":null}},"title":"Activity · apache/kafka"}