kafka-dev  

Messages by Thread

• • [jira] [Commented] (KAFKA-553) confusing reference to zk.connect in config/producer.properties Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-553) confusing reference to zk.connect in config/producer.properties yazgoo (JIRA)
  • [jira] [Updated] (KAFKA-553) confusing reference to zk.connect in config/producer.properties yazgoo (JIRA)
  • [jira] [Updated] (KAFKA-553) confusing reference to zk.connect in config/producer.properties yazgoo (JIRA)
  • [jira] [Updated] (KAFKA-553) confusing reference to zk.connect in config/producer.properties yazgoo (JIRA)
  • [jira] [Updated] (KAFKA-553) confusing reference to zk.connect in config/producer.properties yazgoo (JIRA)
  • [jira] [Updated] (KAFKA-553) confusing reference to zk.connect in config/producer.properties yazgoo (JIRA)
  • [jira] [Updated] (KAFKA-553) confusing reference to zk.connect in config/producer.properties Jun Rao (JIRA)
  • [jira] [Closed] (KAFKA-553) confusing reference to zk.connect in config/producer.properties Jun Rao (JIRA)
• [ANN] node.js lib for kafka Gregg Caines
  • Re: [ANN] node.js lib for kafka Taylor Gautier
  • Re: [ANN] node.js lib for kafka Joe Stein
• [jira] [Created] (KAFKA-552) No error messages logged for those failing-to-send messages from Producer John Fung (JIRA)
  • [jira] [Updated] (KAFKA-552) No error messages logged for those failing-to-send messages from Producer John Fung (JIRA)
  • [jira] [Commented] (KAFKA-552) No error messages logged for those failing-to-send messages from Producer John Fung (JIRA)
• [jira] [Created] (KAFKA-551) Log.truncateTo() may need to trucate immutable log segment Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-551) Log.truncateTo() may need to trucate immutable log segment Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-551) Log.truncateTo() may need to trucate immutable log segment Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-551) Log.truncateTo() may need to trucate immutable log segment Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-551) Log.truncateTo() may need to trucate immutable log segment Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-551) Log.truncateTo() may need to trucate immutable log segment Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-551) Log.truncateTo() may need to trucate immutable log segment Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-551) Log.truncateTo() may need to trucate immutable log segment Neha Narkhede (JIRA)
  • [jira] [Resolved] (KAFKA-551) Log.truncateTo() may need to trucate immutable log segment Jay Kreps (JIRA)
  • [jira] [Closed] (KAFKA-551) Log.truncateTo() may need to trucate immutable log segment Jun Rao (JIRA)
• [jira] [Created] (KAFKA-550) Wildcarded consumption is single-threaded Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-550) Wildcarded consumption is single-threaded Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-550) Wildcarded consumption is single-threaded Joel Koshy (JIRA)
  • [jira] [Commented] (KAFKA-550) Wildcarded consumption is single-threaded Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-550) Wildcarded consumption is single-threaded Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-550) Wildcarded consumption is single-threaded Joel Koshy (JIRA)
  • [jira] [Commented] (KAFKA-550) Wildcarded consumption is single-threaded Joel Koshy (JIRA)
  • [jira] [Commented] (KAFKA-550) Wildcarded consumption is single-threaded Neha Narkhede (JIRA)
  • [jira] [Closed] (KAFKA-550) Wildcarded consumption is single-threaded Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-550) Wildcarded consumption is single-threaded Joel Koshy (JIRA)
  • [jira] [Commented] (KAFKA-550) Wildcarded consumption is single-threaded Jun Rao (JIRA)
• [jira] [Created] (KAFKA-549) ConsumerOffsetChecker does not deal with hostnames published in zookeeper Bob Cotton (JIRA)
  • [jira] [Updated] (KAFKA-549) ConsumerOffsetChecker does not deal with hostnames published in zookeeper Bob Cotton (JIRA)
  • [jira] [Updated] (KAFKA-549) ConsumerOffsetChecker does not deal with hostnames published in zookeeper Bob Cotton (JIRA)
  • [jira] [Updated] (KAFKA-549) ConsumerOffsetChecker does not deal with hostnames published in zookeeper Bob Cotton (JIRA)
  • [jira] [Commented] (KAFKA-549) ConsumerOffsetChecker does not deal with hostnames published in zookeeper Joel Koshy (JIRA)
  • [jira] [Closed] (KAFKA-549) ConsumerOffsetChecker does not deal with hostnames published in zookeeper Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-549) ConsumerOffsetChecker does not deal with hostnames published in zookeeper Joel Koshy (JIRA)
• snappy unit test failure patch Jay Kreps
• Re: Community growth ... Jun Rao
• [jira] [Created] (KAFKA-548) remove partition from ProducerRequestPartitionData and FetchResponsePartitionData Joe Stein (JIRA)
  • [jira] [Updated] (KAFKA-548) remove partition from ProducerRequestPartitionData and FetchResponsePartitionData Yang Ye (JIRA)
  • [jira] [Commented] (KAFKA-548) remove partition from ProducerRequestPartitionData and FetchResponsePartitionData Joel Koshy (JIRA)
  • [jira] [Commented] (KAFKA-548) remove partition from ProducerRequestPartitionData and FetchResponsePartitionData Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-548) remove partition from ProducerRequestPartitionData and FetchResponsePartitionData Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-548) remove partition from ProducerRequestPartitionData and FetchResponsePartitionData Yang Ye (JIRA)
  • [jira] [Commented] (KAFKA-548) remove partition from ProducerRequestPartitionData and FetchResponsePartitionData Joel Koshy (JIRA)
  • [jira] [Commented] (KAFKA-548) remove partition from ProducerRequestPartitionData and FetchResponsePartitionData Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-548) remove partition from ProducerRequestPartitionData and FetchResponsePartitionData Yang Ye (JIRA)
  • [jira] [Resolved] (KAFKA-548) remove partition from ProducerRequestPartitionData and FetchResponsePartitionData Neha Narkhede (JIRA)
  • [jira] [Closed] (KAFKA-548) remove partition from ProducerRequestPartitionData and FetchResponsePartitionData Neha Narkhede (JIRA)
• [jira] [Created] (KAFKA-547) The ConsumerStats MBean name should include the groupid Michael Tamm (JIRA)
  • [jira] [Updated] (KAFKA-547) The ConsumerStats MBean name should include the groupid Michael Tamm (JIRA)
  • [jira] [Commented] (KAFKA-547) The ConsumerStats MBean name should include the groupid Jun Rao (JIRA)
• producer changes Jay Kreps
  • Re: producer changes Jay Kreps
• [jira] [Created] (KAFKA-546) Fix commit() in zk consumer Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-546) Fix commit() in zk consumer for compressed messages Jay Kreps (JIRA)
  • [jira] [Assigned] (KAFKA-546) Fix commit() in zk consumer for compressed messages Swapnil Ghike (JIRA)
  • [jira] [Updated] (KAFKA-546) Fix commit() in zk consumer for compressed messages Swapnil Ghike (JIRA)
  • [jira] [Comment Edited] (KAFKA-546) Fix commit() in zk consumer for compressed messages Swapnil Ghike (JIRA)
  • [jira] [Commented] (KAFKA-546) Fix commit() in zk consumer for compressed messages Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-546) Fix commit() in zk consumer for compressed messages Swapnil Ghike (JIRA)
  • [jira] [Commented] (KAFKA-546) Fix commit() in zk consumer for compressed messages Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-546) Fix commit() in zk consumer for compressed messages Swapnil Ghike (JIRA)
  • [jira] [Commented] (KAFKA-546) Fix commit() in zk consumer for compressed messages Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-546) Fix commit() in zk consumer for compressed messages Swapnil Ghike (JIRA)
  • [jira] [Updated] (KAFKA-546) Fix commit() in zk consumer for compressed messages Swapnil Ghike (JIRA)
  • [jira] [Resolved] (KAFKA-546) Fix commit() in zk consumer for compressed messages Jun Rao (JIRA)
  • [jira] [Closed] (KAFKA-546) Fix commit() in zk consumer for compressed messages Jun Rao (JIRA)
• [jira] [Created] (KAFKA-545) Add a Performance Suite for the Log subsystem Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-545) Add a Performance Suite for the Log subsystem Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-545) Add a Performance Suite for the Log subsystem Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-545) Add a Performance Suite for the Log subsystem Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-545) Add a Performance Suite for the Log subsystem Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-545) Add a Performance Suite for the Log subsystem Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-545) Add a Performance Suite for the Log subsystem Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-545) Add a Performance Suite for the Log subsystem Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-545) Add a Performance Suite for the Log subsystem Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-545) Add a Performance Suite for the Log subsystem Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-545) Add a Performance Suite for the Log subsystem Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-545) Add a Performance Suite for the Log subsystem Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-545) Add a Performance Suite for the Log subsystem Neha Narkhede (JIRA)
  • [jira] [Resolved] (KAFKA-545) Add a Performance Suite for the Log subsystem Jay Kreps (JIRA)
• [jira] [Created] (KAFKA-544) Retain key in producer Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-544) Retain key in producer Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-544) Retain key in producer Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-544) Retain key in producer Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-544) Retain key in producer and expose it in the consumer Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-544) Retain key in producer and expose it in the consumer Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-544) Retain key in producer and expose it in the consumer Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-544) Retain key in producer and expose it in the consumer Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-544) Retain key in producer and expose it in the consumer Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-544) Retain key in producer and expose it in the consumer Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-544) Retain key in producer and expose it in the consumer Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-544) Retain key in producer and expose it in the consumer Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-544) Retain key in producer and expose it in the consumer Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-544) Retain key in producer and expose it in the consumer Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-544) Retain key in producer and expose it in the consumer Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-544) Retain key in producer and expose it in the consumer Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-544) Retain key in producer and expose it in the consumer Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-544) Retain key in producer and expose it in the consumer Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-544) Retain key in producer and expose it in the consumer Eli Reisman (JIRA)
  • [jira] [Commented] (KAFKA-544) Retain key in producer and expose it in the consumer Joel Koshy (JIRA)
  • [jira] [Resolved] (KAFKA-544) Retain key in producer and expose it in the consumer Jay Kreps (JIRA)
• [jira] [Commented] (KAFKA-456) ProducerSendThread calls ListBuffer.size a whole bunch. That is a O(n) operation Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-456) ProducerSendThread calls ListBuffer.size a whole bunch. That is a O(n) operation Jay Kreps (JIRA)
• [jira] [Updated] (KAFKA-456) ProducerSendThread calls ListBuffer.size a whole bunch. That is a O(n) operation David Arthur (JIRA)
  • [jira] [Updated] (KAFKA-456) ProducerSendThread calls ListBuffer.size a whole bunch. That is a O(n) operation David Arthur (JIRA)
  • [jira] [Updated] (KAFKA-456) ProducerSendThread calls ListBuffer.size a whole bunch. That is a O(n) operation Jun Rao (JIRA)
• [jira] [Created] (KAFKA-543) Something is wrong with the metadata request in DefaultEventHandler.handle Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-543) Metadata request from DefaultEventHandler.handle repeats same topic over and over Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-543) Metadata request from DefaultEventHandler.handle repeats same topic over and over Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-543) Metadata request from DefaultEventHandler.handle repeats same topic over and over Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-543) Metadata request from DefaultEventHandler.handle repeats same topic over and over Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-543) Metadata request from DefaultEventHandler.handle repeats same topic over and over Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-543) Metadata request from DefaultEventHandler.handle repeats same topic over and over Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-543) Metadata request from DefaultEventHandler.handle repeats same topic over and over Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-543) Metadata request from DefaultEventHandler.handle repeats same topic over and over Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-543) Metadata request from DefaultEventHandler.handle repeats same topic over and over Neha Narkhede (JIRA)
  • [jira] [Resolved] (KAFKA-543) Metadata request from DefaultEventHandler.handle repeats same topic over and over Jay Kreps (JIRA)
  • [jira] [Closed] (KAFKA-543) Metadata request from DefaultEventHandler.handle repeats same topic over and over Jun Rao (JIRA)
• [jira] [Assigned] (KAFKA-267) Enhance ProducerPerformance to generate unique random Long value for payload Yang Ye (JIRA)
• [jira] [Created] (KAFKA-542) Upgrade to metrics 3.x Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-542) Upgrade to metrics 3.x Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-542) Upgrade to metrics 3.x Joel Koshy (JIRA)
  • [jira] [Commented] (KAFKA-542) Upgrade to metrics 3.x Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-542) Upgrade to metrics 3.x Joel Koshy (JIRA)
  • [jira] [Closed] (KAFKA-542) Upgrade to metrics 3.x Joel Koshy (JIRA)
• [jira] [Created] (KAFKA-541) Use metrics CSV reporter instead of jmx tool for system tests Joel Koshy (JIRA)
  • [jira] [Commented] (KAFKA-541) Use metrics CSV reporter instead of jmx tool for system tests Joel Koshy (JIRA)
  • [jira] [Commented] (KAFKA-541) Use metrics CSV reporter instead of jmx tool for system tests Joel Koshy (JIRA)
  • [jira] [Commented] (KAFKA-541) Use metrics CSV reporter instead of jmx tool for system tests Joel Koshy (JIRA)
  • [jira] [Commented] (KAFKA-541) Use metrics CSV reporter instead of jmx tool for system tests Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-541) Use metrics CSV reporter instead of jmx tool for system tests Joel Koshy (JIRA)
  • [jira] [Assigned] (KAFKA-541) Use metrics CSV reporter instead of jmx tool for system tests Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-541) Use metrics CSV reporter instead of jmx tool for system tests Yang Ye (JIRA)
  • [jira] [Commented] (KAFKA-541) Use metrics CSV reporter instead of jmx tool for system tests Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-541) Use metrics CSV reporter instead of jmx tool for system tests Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-541) Use metrics CSV reporter instead of jmx tool for system tests Yang Ye (JIRA)
  • [jira] [Resolved] (KAFKA-541) Use metrics CSV reporter instead of jmx tool for system tests Neha Narkhede (JIRA)
  • [jira] [Closed] (KAFKA-541) Use metrics CSV reporter instead of jmx tool for system tests Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-541) Use metrics CSV reporter instead of jmx tool for system tests Joel Koshy (JIRA)
  • [jira] [Commented] (KAFKA-541) Use metrics CSV reporter instead of jmx tool for system tests Joel Koshy (JIRA)
• [jira] [Created] (KAFKA-540) log.append() should halt on IOException Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-540) log.append() should halt on IOException Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-540) log.append() should halt on IOException Jun Rao (JIRA)
  • [jira] [Assigned] (KAFKA-540) log.append() should halt on IOException Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-540) log.append() should halt on IOException Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-540) log.append() should halt on IOException Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-540) log.append() should halt on IOException Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-540) log.append() should halt on IOException Jun Rao (JIRA)
  • [jira] [Closed] (KAFKA-540) log.append() should halt on IOException Jun Rao (JIRA)
• Re: Producer code Jun Rao
• Incubator PMC/Board report for Oct 2012 ([ppmc]) Marvin
  • Re: Incubator PMC/Board report for Oct 2012 ([ppmc]) Joel Koshy
  • Incubator PMC/Board report for Oct 2012 ([ppmc]) Marvin
• [jira] [Created] (KAFKA-539) Replica.hw should be initialized to the smaller of checkedpointed HW and log end offset Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-539) Replica.hw should be initialized to the smaller of checkedpointed HW and log end offset Yang Ye (JIRA)
  • [jira] [Resolved] (KAFKA-539) Replica.hw should be initialized to the smaller of checkedpointed HW and log end offset Jun Rao (JIRA)
  • [jira] [Closed] (KAFKA-539) Replica.hw should be initialized to the smaller of checkedpointed HW and log end offset Jun Rao (JIRA)
• Fwd: Preparing for the October reports Alan D. Cabrera
  • Re: Preparing for the October reports Jun Rao
• [VOTE] Release Kafka 0.7.2-incubating (Candidate 5) Joe Stein
  • Re: [VOTE] Release Kafka 0.7.2-incubating (Candidate 5) Jun Rao
  • Re: [VOTE] Release Kafka 0.7.2-incubating (Candidate 5) Joel Koshy
  • Re: [VOTE] Release Kafka 0.7.2-incubating (Candidate 5) Jun Rao
  • Re: [VOTE] Release Kafka 0.7.2-incubating (Candidate 5) Neha Narkhede
  • Re: [VOTE] Release Kafka 0.7.2-incubating (Candidate 5) Chris Douglas
  • Re: [VOTE] Release Kafka 0.7.2-incubating (Candidate 5) Joe Stein
  • Re: [VOTE] Release Kafka 0.7.2-incubating (Candidate 5) Jun Rao
  • Re: [VOTE] Release Kafka 0.7.2-incubating (Candidate 5) Joe Stein
  • Re: [VOTE] Release Kafka 0.7.2-incubating (Candidate 5) Jun Rao
  • Re: [VOTE] Release Kafka 0.7.2-incubating (Candidate 5) Joe Stein
• [jira] [Created] (KAFKA-538) missing apache header in sbt and util.h Joe Stein (JIRA)
  • [jira] [Updated] (KAFKA-538) missing apache header in sbt and util.h Joe Stein (JIRA)
  • [jira] [Updated] (KAFKA-538) missing apache header in sbt and util.h Joe Stein (JIRA)
  • [jira] [Updated] (KAFKA-538) missing apache license header in sbt and util.h Joe Stein (JIRA)
  • [jira] [Updated] (KAFKA-538) missing apache license header in sbt and util.h Joe Stein (JIRA)
  • [jira] [Closed] (KAFKA-538) missing apache license header in sbt and util.h Joe Stein (JIRA)
• MULTI FETCH RESPONSE Wire Format for Kafka 0.7.1 Milind Parikh
  • Re: MULTI FETCH RESPONSE Wire Format for Kafka 0.7.1 Milind Parikh
  • Re: MULTI FETCH RESPONSE Wire Format for Kafka 0.7.1 Jun Rao
• [jira] [Created] (KAFKA-537) expose clientId and correlationId in ConsumerConfig Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-537) expose clientId and correlationId in ConsumerConfig Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-537) expose clientId and correlationId in ConsumerConfig Yang Ye (JIRA)
  • [jira] [Commented] (KAFKA-537) expose clientId and correlationId in ConsumerConfig Jay Kreps (JIRA)
  • [jira] [Assigned] (KAFKA-537) expose clientId and correlationId in ConsumerConfig Yang Ye (JIRA)
  • [jira] [Commented] (KAFKA-537) expose clientId and correlationId in ConsumerConfig Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-537) expose clientId and correlationId in ConsumerConfig Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-537) expose clientId and correlationId in ConsumerConfig Yang Ye (JIRA)
  • [jira] [Commented] (KAFKA-537) expose clientId and correlationId in ConsumerConfig Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-537) expose clientId and correlationId in ConsumerConfig Yang Ye (JIRA)
  • [jira] [Commented] (KAFKA-537) expose clientId and correlationId in ConsumerConfig Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-537) expose clientId and correlationId in ConsumerConfig Neha Narkhede (JIRA)

• Earlier messages
• Later messages