Commits

Branch selector

 0.8.2

User selector

jjkoshy

Datepicker

All time

Commit History

Commits on Feb 19, 2015

• KAFKA-1729; (followup patch)Add constructor to javaapi to allow constructing explicitly versioned offset commit requests; patched by Joel Koshy; reviewed by Jun Rao

  

  jjkoshy

  authored and

  junrao

  committed
  45b9e15

  Copy full SHA for 45b9e15

Commits on Jan 29, 2015

• KAFKA-1729; Add constructor to javaapi to allow constructing explicitly versioned offset commit requests; patched by Joel Koshy; reviewed by Jun Rao

  

  jjkoshy

  authored and

  junrao

  committed
  96ce96d

  Copy full SHA for 96ce96d

Commits on Aug 30, 2014

• KAFKA-687; Provide a roundrobin partition assignment strategy that considers partitions from all topics; reviewed by Jun Rao and Guozhang Wang.

  jjkoshy

  committed
  953e35b

  Copy full SHA for 953e35b

Commits on Jun 27, 2014

• KAFKA-1491; Always read coordinator information in consumer metadata response; reviewed by Neha Narkhede.

  jjkoshy

  committed
  c4b9564

  Copy full SHA for c4b9564

Commits on May 15, 2014

• KAFKA-1437; Consumer metadata response should include (empty) coordinator information if the coordinator is unavailable; reviewed by Neha Narkhede and Guozhang Wang.

  jjkoshy

  committed
  c179c45

  Copy full SHA for c179c45

Commits on Apr 22, 2014

• KAFKA-1327; Log cleaner metrics follow-up patch to reset dirtiest log cleanable ratio; reviewed by Jun Rao

  Show description for 3af3efe
  jjkoshy

  committed
  3af3efe

  Copy full SHA for 3af3efe

Commits on Apr 18, 2014

• KAFKA-1362; Publish sources and javadoc jars; (also removed Scala 2.8.2-specific actions). Reviewed by Jun Rao and Joe Stein

  jjkoshy

  committed
  037c054

  Copy full SHA for 037c054

Commits on Apr 16, 2014

• KAFKA-1323; Fix regression due to KAFKA-1315 (support for relative

  Show description for 97f13ec
  jjkoshy

  committed
  97f13ec

  Copy full SHA for 97f13ec

Commits on Apr 9, 2014

• KAFKA-1373; Set first dirty (uncompacted) offset to first offset of the

  Show description for 8d15de8
  jjkoshy

  committed
  8d15de8

  Copy full SHA for 8d15de8

Commits on Apr 8, 2014

• Trivial: update javadoc comment for KAFKA-1355

  jjkoshy

  committed
  69655d5

  Copy full SHA for 69655d5

Commits on Apr 7, 2014

• KAFKA-1355; Avoid sending all topic metadata on state changes. Reviewed by Neha Narkhede and Timothy Chen

  jjkoshy

  committed
  62fcaed

  Copy full SHA for 62fcaed

Commits on Mar 18, 2014

• KAFKA-1309; Fix cross-compilation issue (due to use of deprecated JavaConversions API in javaapi.OffsetCommitRequest; reviewed by Neha Narkhede

  jjkoshy

  committed
  423d9d5

  Copy full SHA for 423d9d5

Commits on Mar 14, 2014

• KAFKA-1012; Consumer offset management in Kafka; patched by Tejas Patil and Joel Koshy; feedback and reviews from Neha Narkhede, Jun Rao, Guozhang Wang, Sriram Subramanian, Joe Stein, Chris Riccomini

  jjkoshy

  committed
  a670537

  Copy full SHA for a670537

Commits on Jan 25, 2014

• KAFKA-1055 BrokerTopicStats should distinguish between messages received and messages actually appended (i.e., not dropped for various reasons).

  jjkoshy

  committed
  26a02c3

  Copy full SHA for 26a02c3

Commits on Nov 26, 2013

• Update description of num.partitions config in sample server properties - issue reported by Vaibhav Puranik

  jjkoshy

  committed
  ac239da

  Copy full SHA for ac239da

Commits on Oct 16, 2013

• KAFKA-1089; Fix run-class and log4j for migration tool system test; reviewed by Jun Rao

  jjkoshy

  committed
  d5dfa28

  Copy full SHA for d5dfa28

Commits on Aug 2, 2013

• KAFKA-915; Mirror maker system tests should wait for topics to be created. (This patch is a work-around until KAFKA-956 is resolved.); patched by John Fung; reviewed by Joel Koshy.

  jjkoshy

  committed
  81a9f6a

  Copy full SHA for 81a9f6a

• KAFKA-991; Rename config queue size to queue bytes in hadoop producer; patched by Swapnil Ghike, reviewed by Joel Koshy.

  jjkoshy

  committed
  b6479e8

  Copy full SHA for b6479e8

Commits on Aug 1, 2013

• KAFKA-991; Reduce the queue size in hadoop producer; patched by Swapnil Ghike, reviewed by Jay Kreps and Joel Koshy.

  jjkoshy

  committed
  8edd3e6

  Copy full SHA for 8edd3e6

Commits on Jul 25, 2013

• KAFKA-983; Expose MirrorMaker cleanShutdown method. Patched by Swapnil Ghike.

  jjkoshy

  committed
  bc5620c

  Copy full SHA for bc5620c

Commits on Jul 24, 2013

• KAFKA-957; MirrorMaker needs to preserve ordering for keyed messages from source cluster; patched by Guozhang Wang, reviewed by Joel Koshy

  jjkoshy

  committed
  5cf6a54

  Copy full SHA for 5cf6a54

Commits on Jun 13, 2013

• kafka-940; Scala match error in javaapi.Implicits; patched by Joel Koshy; reviewed by Jun Rao

  

  jjkoshy

  authored and

  junrao

  committed
  6400264

  Copy full SHA for 6400264

Commits on May 31, 2013

• KAFKA-921; Expose max lag and min fetch rate mbeans for consumers and replica fetchers; reviewed by Jun Rao.

  jjkoshy

  committed
  4850519

  Copy full SHA for 4850519

Commits on May 28, 2013

• KAFKA-916; Break deadlock between fetcher shutdown and error partition handling; reviewed by Jun Rao.

  jjkoshy

  committed
  517af47

  Copy full SHA for 517af47

Commits on May 22, 2013

• KAFKA-914; Break deadlock between initial rebalance and watcher-triggered rebalances; reviewed by Jun Rao and Neha Narkhede

  jjkoshy

  committed
  ffd84eb

  Copy full SHA for ffd84eb

Commits on Apr 26, 2013

• Trivial commit - warn on consumer fetch request errors.

  jjkoshy

  committed
  e37a464

  Copy full SHA for e37a464

Commits on Apr 23, 2013

• KAFKA-872; Socket server should set send/recv socket buffer sizes; reviewed by Jun Rao.

  jjkoshy

  committed
  ede8587

  Copy full SHA for ede8587

Commits on Dec 18, 2012

• KAFKA-664 RequestPurgatory should clean up satisfied requests from watchers map. Also, simplify the purge logic - purge based on an incoming request interval.

  jjkoshy

  committed
  04b5274

  Copy full SHA for 04b5274