17
I Use This!
Very High Activity

Commits : Listings

Analyzed 1 day ago. based on code collected 1 day ago.
Jan 03, 2025 — Jan 03, 2026
Commit Message Contributor Files Modified Lines Added Lines Removed Code Location Date
KAFKA-1737; Enforce ZKSerializer while creating ZkClient; reviewed by Guozhang Wang More... over 10 years ago
Revert "KAFKA-2186; Follow-up to KAFKA-1650 - add selective offset commit to" More... over 10 years ago
KAFKA-2186; Follow-up to KAFKA-1650 - add selective offset commit to consumer connector API; reviewed by Joel Koshy More... over 10 years ago
KAFKA-2190; Flush mirror maker before commiting offsets; abort the mirror-maker producer with close(0) on send error; reviewed by Joel Koshy More... over 10 years ago
KAFKA-1374; Log cleaner should be able to handle compressed messages; reviewed by Guozhang Wang More... over 10 years ago
KAFKA-2196; Remove identical topic constraint in round-robin assignor; reviewed by Guozhang Wang More... over 10 years ago
KAFKA-2160; remove watcher list if empty in purgatory; remove join-group purgatory in coordinator; reviewed by Jun Rao More... over 10 years ago
kafka-2169; Upgrade to zkclient-0.5; patched by Parth Brahmbhatt; reviewed by Jun Rao More... over 10 years ago
KAFKA-1334; Add the heartbeat logic to consumer coordinator; reviewed by Guozhang Wang More... over 10 years ago
KAFKA-1660; Add API to the producer to support close with a timeout; reviewed by Joel Koshy and Jay Kreps. More... over 10 years ago
KAFKA-2163; The offsets manager's stale-offset-cleanup and offset load should be mutually exclusive; reviewed by Jun Rao More... over 10 years ago
KAFKA-2175; Change INFO to DEBUG for socket close on no error; and partition reassignment JSON; reviewed by Gwen Shapira and Joel Koshy More... over 10 years ago
KAFKA-2150; move partitionMapCond.await into partitionMapLock; reviewed by Guozhang Wang More... over 10 years ago
KAFKA-2121; add missing file More... over 10 years ago
KAFKA-2121; Fix Closeable backward-compatibility; reviewed by Guozhang Wang More... over 10 years ago
KAFKA-1884; Add logging upon metadata response errors; reviewed by Guozhang Wang More... over 10 years ago
KAFKA-2153 kafka-patch-review tool uploads a patch even if it is empty; reviewed by Neha Narkhede, Gwen Shapira More... over 10 years ago
KAFKA-1886 SimpleConsumer swallowing ClosedByInterruptException; reviewed by Neha Narkhede More... over 10 years ago
KAFKA-2068 Phase 1; Merge in KAFKA-1841; reviewed by Jun Rao More... over 10 years ago
kafka-1940; Initial checkout and build failing; patched by Martin Lemanski; reviewed by Jun Rao More... over 10 years ago
KAFKA-2121 Follow-up: minor bug fix as pointed out by Sean Lydon More... over 10 years ago
KAFKA-1621 : Standardize --messages option. Closes #58 More... over 10 years ago
kafka-2118; Cleaner cannot clean after shutdown during replaceSegments; patched by Rajini Sivaram; reviewed by Jun Rao More... over 10 years ago
KAFKA-2114 Unable to change min.insync.replicas default; reviewed by Neha More... over 10 years ago
KAFKA-2128 kafka.Kafka should return non-zero exit code when caught exception; reviewed by Neha More... over 10 years ago
KAFKA-2140 follow up, checking in newly renamed file ConsumerRebalanceFailedException More... over 10 years ago
KAFKA-2122 Remove controller.message.queue.size Config; reviewed by Neha Narkhede, Jun Rao, Onur More... over 10 years ago
KAFKA-2140 Improve code readability; reviewed by Neha Narkhede More... over 10 years ago
KAFKA-2034 sourceCompatibility not set in Kafka build.gradle; reviewed by Neha Narkhede and Ewen Cheslack-Postava More... over 10 years ago
KAFKA-2138; Fix producer to honor retry backoff; reviewed by Joel Koshy and Guozhang Wang More... over 10 years ago