0
I Use This!
Inactive

Commits : Listings

Analyzed 1 day ago. based on code collected 1 day ago.
May 01, 2023 — May 01, 2024
Commit Message Contributor Files Modified Lines Added Lines Removed Code Location Date
support changing host/port of a broker; patched by David Arthur; reviewed by Jun Rao; kafka-474 More... over 11 years ago
KAFKA-551 Remove the concept of immutable log segments--now all indexes and message sets are mutable. This allows truncating old segments. Review by Jun and Neha. More... over 11 years ago
The ConsumerStats MBean name should include the groupid; patched by Michael Tamm; reviewed by Jun Rao; kafka-547 More... over 11 years ago
Replica.hw should be initialized to the smaller of checkedpointed HW and log end offset; patched by Yang Ye; reviewed by Jun Rao; KAFKA-539 More... over 11 years ago
ConsumerOffsetChecker now works with hostnames (in addition to IP) in the brokers/ids zk path; KAFKA-549; patched by Bob Cotton; reviewed by Joel Koshy More... over 11 years ago
ConsumerOffsetChecker now works with hostnames (in addition to IP) in the brokers/ids zk path; KAFKA-549; patched by Bob Cotton; reviewed by Joel Koshy More... over 11 years ago
KAFKA-506 Move to logical offsets. Reviewed by Jun and Neha. More... over 11 years ago
KAFKA-508 split out partiondata from fetchresponse and producerrequest More... over 11 years ago
ProducerSendThread calls ListBuffer.size a whole bunch. That is a O(n) operation; patched by David Arthur; reviewed by Jun Rao; kafka-456 More... over 11 years ago
log.append() should halt on IOException; patched by Jun Rao; reviewed by Jay Kreps; KAFKA-540 More... over 11 years ago
Replace numerical compression codes in config with something human readable; KAFKA-363; patched by David Arthur; reviewed by Joel Koshy More... over 11 years ago
server should shut down on encountering invalid highwatermark file; patched by Yang Ye; reviewed by Jun Rao; kafka-509 More... over 11 years ago
IndexOutOfBoundsException thrown by kafka.consumer.ConsumerFetcherThread; patched by Jun Rao; reviewed by Jay Kreps and Neha Narkhede; kafka-528 More... over 11 years ago
KAFKA-538 missing apache license header in sbt and util.h More... over 11 years ago
KAFKA-538 missing apache license header in sbt and util.h More... over 11 years ago
getOffset Api should return different latest offset to non-follower and follower consumers. Also, implement a batched version of the getOffset Api. patched by Joel Koshy; reviewed by Jun Rao; KAFKA-501 More... over 11 years ago
restrict topic names (reopened); patched by Swapnil Ghike; reviewed by Jun Rao; KAFKA-495 More... over 11 years ago
Use getMetadata Api in ZookeeperConsumerConnector; patched by Yang Ye; reviewed by Jun Rao; KAFKA-473 More... over 11 years ago
KAFKA-533 changes to NOTICE and LICENSE related to KAFKA-534 removing client libraries from repo More... over 11 years ago
KAFKA-533 changes to NOTICE and LICENSE related to KAFKA-534 removing client libraries from repo More... over 11 years ago
KAFKA-534 remove client library directory More... over 11 years ago
KAFKA-534 remove client library directory More... over 11 years ago
System Test should remove the top level data log directory; patched by John Fung; reviewed by Jun Rao; KAFKA-526 More... over 11 years ago
migration tool from 0.7 to 0.8; patched by Yang Ye; reviewed by Jun Rao; kafka-327 More... over 11 years ago
javaapi support for getTopoicMetaData; patched by Swapnil Ghike; reviewed by Jun Rao; KAFKA-500 More... over 11 years ago
KAFKA-499 Refactor controller; patched by Neha Narkhede; reviewed by Jun Rao More... over 11 years ago
trivial fix to log topics in fetching metadata properly More... over 11 years ago
TopicCount.constructTopicCount isn't thread-safe; patched by Jun Rao; reviewed by Joel Koshy; KAFKA-379 More... over 11 years ago
KAFKA-391 Refactor fetch/producer requests to use maps instead of several arrays; patched by Joel Koshy; reviewed by Jun Rao. More... over 11 years ago
log.truncateTo needs to handle targetOffset smaller than the lowest offset in the log ; patched by Swapnil Ghike; reviewed by Jun Rao; KAFKA-463 More... over 11 years ago