Repository navigation

Commits

Commits on Jul 6, 2012
- KAFKA-373 Fix trunk broker failure test to work with mirror maker; patched by John Fung; reviewed by Joel Koshy
  Joel Jacob Koshy
  committed
  489b09c
Commits on Jun 20, 2012
- KAFKA-368 use the pig core jar from maven instead of distributing it patch by Joe Stein reviewed by Jun Rao and Neha Narkhede
  Joe Stein
  committed
  1af23bb
Commits on Jun 19, 2012
- add jmx beans in broker to track # bytes in consumer; patched by Jun Rao; reviewed by Joel Koshy; KAFKA-336
  Jun Rao
  committed
  16b600d
Commits on Jun 14, 2012
- KAFKA-365 change copyright in NOTICE to current year, reviewed by Jun Rao
  Joe Stein
  committed
  f8ce071
Commits on May 18, 2012
- Minor fix: Turning on TCP NODELAY in the Simple Consumer. This fix has a significant impact on single fetch request performance from a latency standpoint
  Neha Narkhede
  committed
  2a59ad7
Commits on Apr 25, 2012
- Mirroring should use multiple producers; add producer retries to DefaultEventHandler; patched by Joel Koshy; reviewed by Jun Rao; KAFKA-332
  Jun Rao
  committed
  d6b1de3
Commits on Apr 8, 2012
- KAFKA-320 testZKSendWithDeadBroker fails intermittently due to ZKNodeExistsException; patched by nehanarkhede; reviewed by junrao and prashanth menon
  Neha Narkhede
  committed
  d97c557
Commits on Apr 7, 2012
- Separate out Kafka mirroring into a stand-alone app; patched by Joel Koshy; reviewed by Jun Rao and Neha Narkhede; KAFKA-249
  Jun Rao
  committed
  c0e190c
Commits on Apr 6, 2012
- enable shallow iterator in ByteBufferMessageSet to allow mirroing data without decompression; patched by Jun Rao; reviewed by Joel Koshy; KAFKA-315
  Jun Rao
  committed
  d9441f0
- CallbackHandler.afterDequeuingExistingData is not called during event queue timeout; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-326
  Jun Rao
  committed
  f834623
Commits on Mar 22, 2012
- KAFKA-309 Bug in FileMessageSet's append API can corrupt on disk log; patched by nehanarkhede; reviewed by junrao
  Neha Narkhede
  committed
  ba8fd9f
- KAFKA-310 Incomplete message set validation checks in Log's append API can corrupt on disk log segment; patched by nehanarkhede; reviewed by junrao
  Neha Narkhede
  committed
  2bcc911
Commits on Mar 21, 2012
- Dead code in the Log4j appender; patched by Jose Quinteiro; reviewed by Jun Rao; KAFKA-303
  Jun Rao
  committed
  e180e68
- kafka-console-producer does not take in customized values of --batch-size or --timeout; patched by Jun Rao; reviewed by Edward Smith; KAFKA-279
  Jun Rao
  committed
  7b39d7e
Commits on Mar 15, 2012
- reverting previous commit for KAFKA-296 because patch didn't apply cleanly
  Jun Rao
  committed
  5e0e0b1
Commits on Mar 14, 2012
- Update Go Client to new version of Go; patched by AaronR; KAFKA-296
  Jun Rao
  committed
  66d8073
Commits on Mar 8, 2012
- LogManager test fails on linux; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-220
  Jun Rao
  committed
  74af0de
Commits on Mar 7, 2012
- trivial fix to include violated payload size in MessageSizeTooLargeException; patched by Jun Rao
  Jun Rao
  committed
  624a361
Commits on Mar 6, 2012
- broker deletes all file segments when cleaning up an empty log segment; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-292
  Jun Rao
  committed
  0443e2d
Commits on Mar 1, 2012
- Niek Sanders - KAFKA-284 fixed compilation issue for cpp client
  Joe Stein
  committed
  ccc464c
Commits on Feb 29, 2012
- use propertyExists to test if both broker.list and zk.connect are present; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-290
  Jun Rao
  committed
  6c34cf2
Commits on Feb 28, 2012
- Increase maximum value of log.retention.size; patched by Elben Shira; reviewed by Jun Rao; KAFKA-285
  Jun Rao
  committed
  d8286aa
Commits on Feb 27, 2012
- consumer sometimes don't release partition ownership properly in ZK during rebalance; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-286
  Jun Rao
  committed
  caf310c
Commits on Feb 25, 2012
- add jmx beans in broker to track # of failed requests; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-283
  Jun Rao
  committed
  7e91c16
Commits on Feb 23, 2012
- Add a shallow iterator to the ByteBufferMessageSet; patched by Yang Ye; reviewed by Jun Rao; KAFKA-277
  Jun Rao
  committed
  333966f
Commits on Feb 21, 2012
- A tool to UPDATE Zookeeper partition-offset with input from a file; patched by John Fung; reviewed by Jun Rao; KAFKA-255
  Jun Rao
  committed
  22d8046
- A tool to GET Zookeeper partition-offset and output to files; patched by John Fung; reviewed by Jun Rao; KAFKA-254
  Jun Rao
  committed
  7066d1c
Commits on Feb 20, 2012
- make time-based reconnect starting at a random time; patched by Yang Ye; reviewed by Jun Rao; KAFKA-268
  Jun Rao
  committed
  95ee387
Commits on Feb 17, 2012
- trivial fix for kafka-producer-perf-test.sh
  Jun Rao
  committed
  a23d396
- test access, fixed space
  Joe Stein
  committed
  ff56247
- KAFKA-274 Handle corrupted messages cleanly; patched by nehanarkhede; reviewed by junrao
  Neha Narkhede
  committed
  c28b3a6
- shutdown watch executor thread properly; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-265
  Jun Rao
  committed
  6e1b2eb
Commits on Feb 15, 2012
- trivial fix to add trace logging in FetcherRunnable
  Jun Rao
  committed
  2ead8a4
- fix condition to use await instead of wait; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-265
  Jun Rao
  committed
  3e79116
- add JMX on broker to track bytes/messages per topic; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-272
  Jun Rao
  committed
  5c4ce61

Branch selector

User selector

Datepicker

Commit history

Commits on Jul 6, 2012

Commits on Jun 20, 2012

Commits on Jun 19, 2012

Commits on Jun 14, 2012

Commits on May 18, 2012

Commits on Apr 25, 2012

Commits on Apr 8, 2012

Commits on Apr 7, 2012

Commits on Apr 6, 2012

Commits on Mar 22, 2012

Commits on Mar 21, 2012

Commits on Mar 15, 2012

Commits on Mar 14, 2012

Commits on Mar 8, 2012

Commits on Mar 7, 2012

Commits on Mar 6, 2012

Commits on Mar 1, 2012

Commits on Feb 29, 2012

Commits on Feb 28, 2012

Commits on Feb 27, 2012

Commits on Feb 25, 2012

Commits on Feb 23, 2012

Commits on Feb 21, 2012

Commits on Feb 20, 2012

Commits on Feb 17, 2012

Commits on Feb 15, 2012