17
I Use This!
Very High Activity

Commits : Listings

Analyzed 1 day ago. based on code collected 2 days ago.
Jul 30, 2024 — Jul 30, 2025
Commit Message Contributor Files Modified Lines Added Lines Removed Code Location Date
MINOR: Remove duplicated code in PgeViewDemo (#20252) More... 2 days ago
KAFKA-19530 RemoteLogManager should record lag stats when remote storage is offline (#20218) More... 2 days ago
KAFKA-19484: Fix bug with tiered storage throttle metrics (#20129) More... 2 days ago
MINOR: Delete the redundant feature upgrade instruction for running KIP-1071 EA (#20250) More... 2 days ago
KAFKA-16717 [3/N]: Add AdminClient.alterShareGroupOffsets (#19820) More... 2 days ago
KAFKA-19559: Remove ShareFetchMetricsManager sensors on consumer.close() (#20255) More... 2 days ago
KAFKA-19555: Restrict records acquisition post max in-flight limit (#20253) More... 2 days ago
KAFKA-18066: Fix mismatched StreamThread ID in log messages (#19517) More... 3 days ago
KAFKA-12281: Deprecate BrokerNotFoundException (#20192) More... 3 days ago
KAFKA-19354: KRaft observer should send fetch to best node (#19854) More... 3 days ago
KAFKA-19551: Remove the handling of FatalExitError in RemoteStorageThreadPool (#20245) More... 3 days ago
KAFKA-19425: Stop the server when fail to initialize to avoid local segment never got deleted. (#20007) More... 3 days ago
KAFKA-19471: Enable acknowledgement for a record which could not be deserialized (#20148) More... 4 days ago
MINOR: Reword warning message when internal deprecated properties are used (#20224) More... 4 days ago
MINOR: Re-add pageview demo to :streams:examples and remove dependency on :connect:json (#20239) More... 6 days ago
MINOR: Improve Kafka Streams Protocol Upgrade Doc (#20241) More... 6 days ago
MINOR: Optimize RemoteLogManager#buildFilteredLeaderEpochMap (#20205) More... 7 days ago
KAFKA-19400: Update AddRaftVoterRequest RPC to version 1 (#19982) More... 7 days ago
KAFKA-19545 Remove MetadataVersionValidator (#20233) More... 7 days ago
MINOR: Prevent error message swallow in persister. (#20238) More... 7 days ago
KAFKA-19499: Corrected the logger name in PersisterStateManagerHandler (#20175) More... 7 days ago
MINOR: typo in javadoc (#20113) More... 7 days ago
KAFKA-17645 Enable warmup in producer performance test (KIP-1052) (#17340) More... 8 days ago
KAFKA-18265: Move inflight batch and state classes from SharePartition (2/N) (#20230) More... 8 days ago
KAFKA-18265: Move acquisition lock classes from share partition (1/N) (#20227) More... 8 days ago
KAFKA-19523: Gracefully handle error while building remoteLogAuxState (#20201) More... 8 days ago
MINOR: Declare the inner RocksDBDualCFRangeIterator class as static (#20220) More... 8 days ago
KAFKA-19525: Refactor TopicBasedRLMM implementation to remove unused code (#20204) More... 9 days ago
MINOR: Fix flaky tests in Tools modules (#20225) More... 9 days ago
KAFKA-19272: Add initPid Response handling when keepPrepared is set to true (KIP-939) (#20039) More... 9 days ago