-
Notifications
You must be signed in to change notification settings - Fork 14.5k
Insights: apache/kafka
Overview
-
0 Active issues
-
- 37 Merged pull requests
- 25 Open pull requests
- 0 Closed issues
- 0 New issues
Could not load contribution data
Please try again later
37 Pull requests merged by 23 people
-
MINOR: Optimize RemoteLogManager#buildFilteredLeaderEpochMap
#20205 merged
Jul 24, 2025 -
KAFKA-19400: Update AddRaftVoterRequest RPC to version 1
#19982 merged
Jul 24, 2025 -
KAFKA-19545: Remove MetadataVersionValidator
#20233 merged
Jul 24, 2025 -
MINOR: Prevent error message swallow in persister.
#20238 merged
Jul 24, 2025 -
KAFKA-19499: Corrected the logger name in PersisterStateManagerHandler
#20175 merged
Jul 24, 2025 -
MINOR: typo in javadoc
#20113 merged
Jul 24, 2025 -
KAFKA-17645: KIP-1052: Enable warmup in producer performance test
#17340 merged
Jul 24, 2025 -
KAFKA-18265: Move inflight batch and state classes from SharePartition (2/N)
#20230 merged
Jul 23, 2025 -
KAFKA-18265: Move acquisition lock classes from share partition (1/N)
#20227 merged
Jul 23, 2025 -
KAFKA-19523: Gracefully handle error while building remoteLogAuxState
#20201 merged
Jul 23, 2025 -
MINOR: Declare inner RocksDBDualCFRangeIterator class as static
#20220 merged
Jul 23, 2025 -
KAFKA-19525: Refactor TopicBasedRLMM implementation to remove unused code
#20204 merged
Jul 23, 2025 -
MINOR: Fix flaky tests in Tools modules
#20225 merged
Jul 23, 2025 -
KAFKA-19272: Add initPid Response handling when keepPrepared is set to true (KIP-939)
#20039 merged
Jul 22, 2025 -
KAFKA-19213 Client ignores default properties
#20134 merged
Jul 22, 2025 -
MINOR: Cleanup Connect Module (2/n)
#19871 merged
Jul 22, 2025 -
MINOR: Rename waitForTopic to waitTopicCreation
#20216 merged
Jul 22, 2025 -
KAFKA-19503: Deprecate MX4j support
#20208 merged
Jul 22, 2025 -
MINOR: Cleanup Tools Module (1/n)
#20091 merged
Jul 22, 2025 -
KAFKA-18336: Improve jmh tests on ACL in AuthorizerBenchmark and StandardAuthorizerUpdateBenchmark
#18293 merged
Jul 22, 2025 -
MINOR: Fix StreamThreadTest
#20210 merged
Jul 22, 2025 -
MINOR: Change log level for cold snapshot log.
#20209 merged
Jul 21, 2025 -
KAFKA-16505: Adding dead letter queue in Kafka Streams
#17942 merged
Jul 21, 2025 -
KAFKA-19476: Removing AtomicBoolean for findNextFetchOfffset (1/N)
#20207 merged
Jul 21, 2025 -
KAFKA-19500:
kafka-consumer-groups.sh
should fail quickly if the partition leader is unavailable#20168 merged
Jul 21, 2025 -
KAFKA-19461: Add share group admin integration tests to PlaintextAdminIntegrationTest
#20103 merged
Jul 21, 2025 -
KAFKA-19517: Include control records in LoadSummary#numRecords
#20206 merged
Jul 21, 2025 -
MINOR: Cleanup metadata module
#20115 merged
Jul 20, 2025 -
MINOR: Move ClientQuotasRequestTest to server module
#20053 merged
Jul 20, 2025 -
KAFKA-19522: avoid electing fenced lastKnownLeader
#20200 merged
Jul 20, 2025 -
MINOR: add a test for Protocol
#20169 merged
Jul 19, 2025 -
MINOR: Remove unnecessary dependencies from coordinator-common (follow up to pr#20089)
#20194 merged
Jul 19, 2025 -
KAFKA-19520 Bump Commons-Lang for CVE-2025-48924
#20196 merged
Jul 19, 2025 -
MINOR: Fix RemoteLogManager.getLeaderEpochEntries comment error
#20181 merged
Jul 18, 2025
25 Pull requests opened by 21 people
-
Feature/openj9 integration
#20197 opened
Jul 18, 2025 -
MINOR:Extract public code
#20198 opened
Jul 18, 2025 -
MINOR: Migrate EligibleLeaderReplicasIntegrationTestto use new test infra
#20199 opened
Jul 18, 2025 -
KAFKA-19486: use the latest version of kafka-topics.sh to create topics in system tests
#20202 opened
Jul 19, 2025 -
KAFKA-19426: TopicBasedRemoteLogMetadataManager's initial should happen after the broker ready.
#20203 opened
Jul 20, 2025 -
KAFKA-19527: improve the docs of LogDirDescription for remote storage
#20211 opened
Jul 21, 2025 -
KAFKA-10840: Expose authentication failures in KafkaConsumer.poll()
#20212 opened
Jul 21, 2025 -
KAFKA-16996: Fix leastLoadedNode to avoid selecting faulty nodes
#20213 opened
Jul 22, 2025 -
MINOR: Cleanup Trogdor Module
#20214 opened
Jul 22, 2025 -
[chore] Add project icon for `IntelliJ IDEA`
#20215 opened
Jul 22, 2025 -
KAFKA-19530 RemoteLogManager should record lag stats when remote storage is offline
#20218 opened
Jul 22, 2025 -
[Experimental] Add `rewrite` support for `RemoveUnusedPrivateMethods` & `RemoveUnusedImports`
#20219 opened
Jul 22, 2025 -
KAFKA-19498: Add include argument to ConsumerPerformance tool
#20221 opened
Jul 22, 2025 -
KAFKA-19524: Fix UnsupportedOperationException in connect-plugin-path
#20222 opened
Jul 22, 2025 -
MINOR: Add logging when RemoteLogManager#RLMCopyTask task is cancelled.
#20223 opened
Jul 22, 2025 -
MINOR: Reword warning message when internal deprecated properties are used
#20224 opened
Jul 22, 2025 -
Revert "MINOR: Cleanup metadata module"
#20226 opened
Jul 23, 2025 -
MINOR: Fix duplicate 'to' in ExactlyOnceMessageProcessor javadoc
#20228 opened
Jul 23, 2025 -
MINOR: Optimize map lookup efficiency with getOrDefault
#20229 opened
Jul 23, 2025 -
Refactor metrics management with AbstractMetricsManager
#20232 opened
Jul 24, 2025 -
KAFKA-19539: Kafka Streams should also purge internal topics based on user commit requests
#20234 opened
Jul 24, 2025 -
MINOR: `kafka-consumer-groups.sh` should not fail when partition offline
#20235 opened
Jul 24, 2025 -
KAFKA-19531 Add an end-to-end integration test for the DLQ feature
#20236 opened
Jul 24, 2025 -
MINOR: improve the min.insync.replicas doc
#20237 opened
Jul 24, 2025 -
MINIOR: Re-add pageview demo to :streams:examples and remove dependency on :connect:json
#20239 opened
Jul 24, 2025
46 Unresolved conversations
Sometimes conversations happen on old items that aren’t yet closed. Here is a list of all the Issues and Pull Requests with unresolved conversations.
-
KAFKA-16717 [3/N]: Add AdminClient.alterShareGroupOffsets
#19820 commented on
Jul 24, 2025 • 24 new comments -
KAFKA-19478 [3/N]: Use heaps to discover the least loaded process
#20172 commented on
Jul 21, 2025 • 20 new comments -
KAFKA-12281: Deprecate BrokerNotFoundException
#20192 commented on
Jul 24, 2025 • 9 new comments -
KAFKA-19471: Enable acknowledgement for a record which could not be deserialized
#20148 commented on
Jul 19, 2025 • 8 new comments -
MINOR: Cleanup Tools Module (2/n)
#20096 commented on
Jul 25, 2025 • 7 new comments -
KAFKA-19425: Stop the server when fail to initialize to avoid local segment never got deleted.
#20007 commented on
Jul 25, 2025 • 6 new comments -
MINOR: Cleanups in storage module
#20087 commented on
Jul 20, 2025 • 5 new comments -
MINOR: Cleanup Server Module
#20180 commented on
Jul 24, 2025 • 3 new comments -
KAFKA-19354: KRaft observer should fetch from leader after rediscovery
#19854 commented on
Jul 24, 2025 • 3 new comments -
KAFKA-19276: Trigger rebalance for streams config update
#19967 commented on
Jul 23, 2025 • 3 new comments -
KAFKA-19489: storage tool should check controller.quorum.voters is not set alongside a dynamic quorum flag when formatting
#20136 commented on
Jul 24, 2025 • 2 new comments -
KAFKA-19516: Added a request timeout of 120000ms to CreateTopics in ShareFetchAcknolwedgeRequestTest methods
#20184 commented on
Jul 24, 2025 • 2 new comments -
KAFKA-19506 : Implement dynamic compression type selection and fallback for client telemetry
#20144 commented on
Jul 20, 2025 • 2 new comments -
[WIP] KAFKA-19012: Messages ending up on the wrong topic
#20146 commented on
Jul 24, 2025 • 2 new comments -
KAFKA-19306: Migrate LogCompactionTester to tools module
#19905 commented on
Jul 24, 2025 • 2 new comments -
MINOR: Remove duplicate renewTimePeriodOpt in DelegationTokenCommand validation
#20177 commented on
Jul 23, 2025 • 1 new comment -
(WIP)KAFKA-9965/KAFKA-13303: RoundRobinPartitioner broken by KIP-480
#20170 commented on
Jul 20, 2025 • 1 new comment -
KAFKA-17853: Fix termination issue in ConsoleConsumer and ConsoleShareConsumer
#19886 commented on
Jul 21, 2025 • 1 new comment -
KAFKA-19357: AsyncConsumer#close hangs as commitAsync never completes when coordinator is missing
#19914 commented on
Jul 23, 2025 • 1 new comment -
MINOR: fix e2e docs for test that cannot be run directly
#20145 commented on
Jul 25, 2025 • 0 new comments -
[WIP] KIP-891: Multiversioning in Kafka Connect - Config and Validation Tests
#18326 commented on
Jul 25, 2025 • 0 new comments -
KAFKA-14405: Log a warning when users attempt to set a config controlled by Streams
#20149 commented on
Jul 19, 2025 • 0 new comments -
KAFKA-19493: Incorrect rate metric with larger window size
#20152 commented on
Jul 21, 2025 • 0 new comments -
KAFKA-19132 Move FetchSession and related classes to server module
#20158 commented on
Jul 19, 2025 • 0 new comments -
KAFKA-17019: Producer TimeoutException should include root cause
#20159 commented on
Jul 19, 2025 • 0 new comments -
docs: clarify log compaction with example and tombstone explanation
#20162 commented on
Jul 21, 2025 • 0 new comments -
KAFKA-17871: avoid blocking the herder thread when producer flushing hangs
#18142 commented on
Jul 25, 2025 • 0 new comments -
KAFKA-19490: Remove usages of distutils in docker scripts
#20178 commented on
Jul 21, 2025 • 0 new comments -
KAFKA-13468: Consumers may hang because IOException in Log#<init> does not trigger KafkaStorageException
#11520 commented on
Jul 25, 2025 • 0 new comments -
KAFKA-17651: Implement `describeUserScramCredentials`
#19066 commented on
Jul 23, 2025 • 0 new comments -
KAFKA-18379: Enforce resigned cannot transition to any other state in same epoch
#19236 commented on
Jul 24, 2025 • 0 new comments -
KAFKA-18960: The default type of ssh key used by vagrant is disabled …
#19264 commented on
Jul 25, 2025 • 0 new comments -
KAFKA-18185: remove internal.leave.group.on.close config
#19400 commented on
Jul 23, 2025 • 0 new comments -
KAFKA-19117: Client Throttling Log messages should be of log level - WARN (Java client)
#19456 commented on
Jul 22, 2025 • 0 new comments -
[KAFKA-15580] First attempt at UncleanRecoveryManager
#19468 commented on
Jul 23, 2025 • 0 new comments -
KAFKA-18752: Fix the warning of no-operation caused by slf4j in building kafka
#19501 commented on
Jul 23, 2025 • 0 new comments -
[Work in progress] [KAFKA-19174] Gradle version upgrade 8 -->> 9
#19513 commented on
Jul 25, 2025 • 0 new comments -
KAFKA-19078: Implement automatic controller addition to cluster metadata partition
#19589 commented on
Jul 24, 2025 • 0 new comments -
KAFKA-18561: Remove withKip853Rpc and replace it with withRaftProtocol
#18600 commented on
Jul 21, 2025 • 0 new comments -
KAFKA-19340: Move DelayedRemoteFetch to the storage module
#19876 commented on
Jul 22, 2025 • 0 new comments -
KAFKA-19395 - Updated Junit and mockito version and license information in NOTICE-binary for Jakarta RESTful Web Services Project
#19943 commented on
Jul 24, 2025 • 0 new comments -
KAFAK-14604: SASL session expiration time will be overflowed when calculation
#18526 commented on
Jul 21, 2025 • 0 new comments -
MINOR: Cleanups in Connect
#20077 commented on
Jul 19, 2025 • 0 new comments -
[WIP] KIP-891: Multiversioning in Kafka Connect - Connector Multiversion Integration Test
#18360 commented on
Jul 25, 2025 • 0 new comments -
(WIP)KAFKA-9965/KAFKA-13303: RoundRobinPartitioner broken by KIP-480
#20114 commented on
Jul 20, 2025 • 0 new comments -
[KAFKA-19484] fix bug with tiered storage throttle metrics
#20129 commented on
Jul 23, 2025 • 0 new comments