Repository navigation

Commits

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
Commits on Feb 14, 2012
- time-based reconnect in producer; patched by Yang Ye; reviewed by Jun Rao; KAFKA-268
  Jun Rao
  committed
  0bd3b9c
Commits on Feb 13, 2012
- Add a queue of zookeeper notifications in the zookeeper consumer to reduce the number of rebalancing attempts; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-265
  Jun Rao
  committed
  732c27f
Commits on Feb 10, 2012
- trivial change to reduce default fetcher queue size
  Jun Rao
  committed
  6a3c2f2
Commits on Feb 9, 2012
- KAFKA-262 Bug in the consumer rebalancing logic causes one consumer to release partitions that it does not own; patched by Neha Narkhede; reviewed by Jun Rao
  Neha Narkhede
  committed
  a888a9d
Commits on Feb 7, 2012
- KAFKA-263 Enhance single host broker failure test to have 2 topics with uneven distribution on the source brokers; patched by John Fung; reviewed by Neha Narkhede
  Neha Narkhede
  committed
  345bc7b
Commits on Feb 6, 2012
- KAFKA-257 Hadoop producer should use software load balancer; patched by Sam Shah; reviewed by nehanarkhede
  Neha Narkhede
  committed
  2552a24
Commits on Feb 2, 2012
- KAFKA 256 Bug in the consumer rebalancing logic leads to the consumer not pulling data from some partitions; patched by nehanarkhede; reviewed by joelkoshy
  Neha Narkhede
  committed
  afd4b0d
- Corrupted request shuts down the broker; patched by Jun Rao; reviewed by Jay Kreps and Neha Narkhede; KAFKA-261
  Jun Rao
  committed
  fcc82dc
Commits on Jan 19, 2012
- ConsumerIterator throws a IllegalStateException after a ConsumerTimeout occurs; patched by Jun Rao; reviewed by Joel Koshy; KAFKA-241
  Jun Rao
  committed
  fe2f055
Commits on Jan 17, 2012
- max.message.size and fetch.size defaults should be consistent; patched by Pierre-Yves Ritschard; reviewed by Jun Rao; KAFKA-247
  Jun Rao
  committed
  d3c58b6

Branch selector

User selector

Datepicker

Commit history

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

Commits on Feb 14, 2012

Commits on Feb 13, 2012

Commits on Feb 10, 2012

Commits on Feb 9, 2012

Commits on Feb 7, 2012

Commits on Feb 6, 2012

Commits on Feb 2, 2012

Commits on Jan 19, 2012

Commits on Jan 17, 2012