kafka-dev  

Messages by Thread

• • [jira] [Commented] (KAFKA-537) expose clientId and correlationId in ConsumerConfig Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-537) expose clientId and correlationId in ConsumerConfig Yang Ye (JIRA)
  • [jira] [Resolved] (KAFKA-537) expose clientId and correlationId in ConsumerConfig Neha Narkhede (JIRA)
  • [jira] [Closed] (KAFKA-537) expose clientId and correlationId in ConsumerConfig Neha Narkhede (JIRA)
• [jira] [Created] (KAFKA-536) Kafka async appender/producer looses most messages nicu marasoiu (JIRA)
• [jira] [Created] (KAFKA-535) Significant difference in time taken to produce messages between 1, -1 for request-num-acks John Fung (JIRA)
• [jira] [Updated] (KAFKA-267) Enhance ProducerPerformance to generate unique random Long value for payload Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-267) Enhance ProducerPerformance to generate unique random Long value for payload Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-267) Enhance ProducerPerformance to generate unique random Long value for payload Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-267) Enhance ProducerPerformance to generate unique random Long value for payload Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-267) Enhance ProducerPerformance to generate unique random Long value for payload Yang Ye (JIRA)
  • Re: [jira] [Updated] (KAFKA-267) Enhance ProducerPerformance to generate unique random Long value for payload wm
  • [jira] [Updated] (KAFKA-267) Enhance ProducerPerformance to generate unique random Long value for payload Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-267) Enhance ProducerPerformance to generate unique random Long value for payload Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-267) Enhance ProducerPerformance to generate unique random Long value for payload Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-267) Enhance ProducerPerformance to generate unique random Long value for payload Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-267) Enhance ProducerPerformance to generate unique random Long value for payload Yang Ye (JIRA)
• [VOTE] Release Kafka 0.7.2-incubating (Candidate 4) Joe Stein
  • Re: [VOTE] Release Kafka 0.7.2-incubating (Candidate 4) Jun Rao
  • Re: [VOTE] Release Kafka 0.7.2-incubating (Candidate 4) Jay Kreps
  • Re: [VOTE] Release Kafka 0.7.2-incubating (Candidate 4) Joel Koshy
  • Re: [VOTE] Release Kafka 0.7.2-incubating (Candidate 4) Joe Stein
  • Re: [VOTE] Release Kafka 0.7.2-incubating (Candidate 4) Joel Koshy
• Trouble producing gzip messages David Arthur
  • Re: Trouble producing gzip messages David Arthur
• [jira] [Commented] (KAFKA-42) Support rebalancing the partitions with replication Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-42) Support rebalancing the partitions with replication Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-42) Support rebalancing the partitions with replication Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-42) Support rebalancing the partitions with replication Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-42) Support rebalancing the partitions with replication Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-42) Support rebalancing the partitions with replication Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-42) Support rebalancing the partitions with replication Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-42) Support rebalancing the partitions with replication Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-42) Support rebalancing the partitions with replication Neha Narkhede (JIRA)
• [jira] [Created] (KAFKA-534) branch client dir into legacy client lib and remove client from repository Joe Stein (JIRA)
  • [jira] [Updated] (KAFKA-534) branch client dir into legacy client lib and remove client dir from repository Joe Stein (JIRA)
  • [jira] [Resolved] (KAFKA-534) branch client dir into legacy client lib and remove client dir from repository Joe Stein (JIRA)
  • [jira] [Closed] (KAFKA-534) branch client dir into legacy client lib and remove client dir from repository Joe Stein (JIRA)
• [jira] [Created] (KAFKA-533) remove nunit in both LICENSE and NOTICE Joe Stein (JIRA)
  • [jira] [Updated] (KAFKA-533) remove nunit in both LICENSE and NOTICE Joe Stein (JIRA)
  • [jira] [Updated] (KAFKA-533) remove nunit in both LICENSE and NOTICE Joe Stein (JIRA)
  • [jira] [Closed] (KAFKA-533) remove nunit in both LICENSE and NOTICE Joe Stein (JIRA)
  • [jira] [Updated] (KAFKA-533) remove nunit in both LICENSE and NOTICE Joe Stein (JIRA)
• git wip incubator-kafka.git Chris Burroughs
  • Re: git wip incubator-kafka.git Joe Stein
  • Re: git wip incubator-kafka.git Jun Rao
• [jira] [Created] (KAFKA-532) Multiple controllers can co-exist during soft failures Neha Narkhede (JIRA)
  • [jira] [Work started] (KAFKA-532) Multiple controllers can co-exist during soft failures Neha Narkhede (JIRA)
  • [jira] [Assigned] (KAFKA-532) Multiple controllers can co-exist during soft failures Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-532) Multiple controllers can co-exist during soft failures Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-532) Multiple controllers can co-exist during soft failures Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-532) Multiple controllers can co-exist during soft failures Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-532) Multiple controllers can co-exist during soft failures Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-532) Multiple controllers can co-exist during soft failures Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-532) Multiple controllers can co-exist during soft failures Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-532) Multiple controllers can co-exist during soft failures Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-532) Multiple controllers can co-exist during soft failures Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-532) Multiple controllers can co-exist during soft failures Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-532) Multiple controllers can co-exist during soft failures Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-532) Multiple controllers can co-exist during soft failures Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-532) Multiple controllers can co-exist during soft failures Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-532) Multiple controllers can co-exist during soft failures Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-532) Multiple controllers can co-exist during soft failures Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-532) Multiple controllers can co-exist during soft failures Jun Rao (JIRA)
  • [jira] [Resolved] (KAFKA-532) Multiple controllers can co-exist during soft failures Neha Narkhede (JIRA)
• SyncProducer connectionTimeout and reconnect interval Jun Rao
• Re: topic names again Jay Kreps
  • Re: topic names again Joe Stein
  • Re: topic names again Swapnil Ghike
• [VOTE] Release Kafka 0.7.2-incubating (Candidate 3) Joe Stein
  • Re: [VOTE] Release Kafka 0.7.2-incubating (Candidate 3) Jun Rao
  • Re: [VOTE] Release Kafka 0.7.2-incubating (Candidate 3) Joe Stein
  • Re: [VOTE] Release Kafka 0.7.2-incubating (Candidate 3) Jun Rao
  • Re: [VOTE] Release Kafka 0.7.2-incubating (Candidate 3) Joe Stein
  • Re: [VOTE] Release Kafka 0.7.2-incubating (Candidate 3) Jun Rao
• [VOTE] Release Kafka 0.7.2-incubating (Candidate 2) Joe Stein
  • Re: [VOTE] Release Kafka 0.7.2-incubating (Candidate 2) Chris Douglas
  • Re: [VOTE] Release Kafka 0.7.2-incubating (Candidate 2) Joe Stein
• [jira] [Created] (KAFKA-531) kafka.server.ReplicaManager: java.nio.channels.NonWritableChannelException John Fung (JIRA)
  • [jira] [Updated] (KAFKA-531) kafka.server.ReplicaManager: java.nio.channels.NonWritableChannelException John Fung (JIRA)
  • [jira] [Commented] (KAFKA-531) kafka.server.ReplicaManager: java.nio.channels.NonWritableChannelException Jay Kreps (JIRA)
  • [jira] [Resolved] (KAFKA-531) kafka.server.ReplicaManager: java.nio.channels.NonWritableChannelException Jun Rao (JIRA)
  • [jira] [Closed] (KAFKA-531) kafka.server.ReplicaManager: java.nio.channels.NonWritableChannelException Jun Rao (JIRA)
• [jira] [Created] (KAFKA-530) kafka.server.KafkaApis: kafka.common.OffsetOutOfRangeException John Fung (JIRA)
  • [jira] [Updated] (KAFKA-530) kafka.server.KafkaApis: kafka.common.OffsetOutOfRangeException John Fung (JIRA)
  • [jira] [Commented] (KAFKA-530) kafka.server.KafkaApis: kafka.common.OffsetOutOfRangeException Neha Narkhede (JIRA)
• [jira] [Created] (KAFKA-529) kafka.server.ReplicaFetcherThread: java.lang.IndexOutOfBoundsException John Fung (JIRA)
  • [jira] [Updated] (KAFKA-529) kafka.server.ReplicaFetcherThread: java.lang.IndexOutOfBoundsException John Fung (JIRA)
  • [jira] [Updated] (KAFKA-529) kafka.server.ReplicaFetcherThread: java.lang.IndexOutOfBoundsException John Fung (JIRA)
  • [jira] [Resolved] (KAFKA-529) kafka.server.ReplicaFetcherThread: java.lang.IndexOutOfBoundsException John Fung (JIRA)
• [jira] [Created] (KAFKA-528) IndexOutOfBoundsException thrown by kafka.consumer.ConsumerFetcherThread John Fung (JIRA)
  • [jira] [Updated] (KAFKA-528) IndexOutOfBoundsException thrown by kafka.consumer.ConsumerFetcherThread John Fung (JIRA)
  • [jira] [Updated] (KAFKA-528) IndexOutOfBoundsException thrown by kafka.consumer.ConsumerFetcherThread Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-528) IndexOutOfBoundsException thrown by kafka.consumer.ConsumerFetcherThread Jun Rao (JIRA)
  • [jira] [Assigned] (KAFKA-528) IndexOutOfBoundsException thrown by kafka.consumer.ConsumerFetcherThread Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-528) IndexOutOfBoundsException thrown by kafka.consumer.ConsumerFetcherThread Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-528) IndexOutOfBoundsException thrown by kafka.consumer.ConsumerFetcherThread Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-528) IndexOutOfBoundsException thrown by kafka.consumer.ConsumerFetcherThread John Fung (JIRA)
  • [jira] [Comment Edited] (KAFKA-528) IndexOutOfBoundsException thrown by kafka.consumer.ConsumerFetcherThread John Fung (JIRA)
  • [jira] [Updated] (KAFKA-528) IndexOutOfBoundsException thrown by kafka.consumer.ConsumerFetcherThread Jun Rao (JIRA)
  • [jira] [Comment Edited] (KAFKA-528) IndexOutOfBoundsException thrown by kafka.consumer.ConsumerFetcherThread Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-528) IndexOutOfBoundsException thrown by kafka.consumer.ConsumerFetcherThread Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-528) IndexOutOfBoundsException thrown by kafka.consumer.ConsumerFetcherThread Jun Rao (JIRA)
  • [jira] [Closed] (KAFKA-528) IndexOutOfBoundsException thrown by kafka.consumer.ConsumerFetcherThread Jun Rao (JIRA)
• byte copies in compression code Jay Kreps
• [jira] [Created] (KAFKA-527) Compression support does numerous byte copies Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-527) Compression support does numerous byte copies Jay Kreps (JIRA)
• [jira] [Created] (KAFKA-526) System Test should remove the top level data log directory John Fung (JIRA)
  • [jira] [Updated] (KAFKA-526) System Test should remove the top level data log directory John Fung (JIRA)
  • [jira] [Updated] (KAFKA-526) System Test should remove the top level data log directory John Fung (JIRA)
  • [jira] [Assigned] (KAFKA-526) System Test should remove the top level data log directory John Fung (JIRA)
  • [jira] [Commented] (KAFKA-526) System Test should remove the top level data log directory Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-526) System Test should remove the top level data log directory John Fung (JIRA)
  • [jira] [Updated] (KAFKA-526) System Test should remove the top level data log directory Jun Rao (JIRA)
  • [jira] [Closed] (KAFKA-526) System Test should remove the top level data log directory Jun Rao (JIRA)
• [jira] [Created] (KAFKA-525) newly created partitions are not added to ReplicaStateMachine Jun Rao (JIRA)
  • [jira] [Resolved] (KAFKA-525) newly created partitions are not added to ReplicaStateMachine Jun Rao (JIRA)
  • [jira] [Closed] (KAFKA-525) newly created partitions are not added to ReplicaStateMachine Jun Rao (JIRA)
• [DISCUSS] Kafka graduation resolution Jakob Homan
  • Re: [DISCUSS] Kafka graduation resolution Jay Kreps
  • Re: [DISCUSS] Kafka graduation resolution Chris Burroughs
  • Re: [DISCUSS] Kafka graduation resolution Alan D. Cabrera
  • Re: [DISCUSS] Kafka graduation resolution Jun Rao
  • Re: [DISCUSS] Kafka graduation resolution Jakob Homan
  • Re: [DISCUSS] Kafka graduation resolution Jay Kreps
  • Re: [DISCUSS] Kafka graduation resolution Jakob Homan
  • Re: [DISCUSS] Kafka graduation resolution Alan D. Cabrera
  • Re: [DISCUSS] Kafka graduation resolution Joel Koshy
  • Re: [DISCUSS] Kafka graduation resolution Jun Rao
  • Re: [DISCUSS] Kafka graduation resolution Jakob Homan
• Updates to Python client David Arthur
  • Re: Updates to Python client David Arthur
  • Re: Updates to Python client Jun Rao
• [jira] [Created] (KAFKA-524) Kafka Appender causes Log4j Deadlock nicu marasoiu (JIRA)
  • [jira] [Updated] (KAFKA-524) Kafka Appender causes Log4j Deadlock nicu marasoiu (JIRA)
• [jira] [Commented] (KAFKA-244) Improve log4j appender to use kafka.producer.Producer, and support zk.connect|broker.list options nicu marasoiu (JIRA)
  • [jira] [Commented] (KAFKA-244) Improve log4j appender to use kafka.producer.Producer, and support zk.connect|broker.list options nicu marasoiu (JIRA)
• [jira] [Commented] (KAFKA-185) The files in the kafka\clients\csharp\src\Kafka\Kafka.Client\cfg folder of the csharp client are out of date. T Dholakia (JIRA)
• [jira] [Created] (KAFKA-523) OffsetRequest handler does not handle errors David Arthur (JIRA)
  • [jira] [Updated] (KAFKA-523) OffsetRequest handler does not handle errors David Arthur (JIRA)
  • [jira] [Updated] (KAFKA-523) OffsetRequest handler does not handle errors David Arthur (JIRA)
  • [jira] [Updated] (KAFKA-523) OffsetRequest handler does not handle errors David Arthur (JIRA)
  • [jira] [Comment Edited] (KAFKA-523) OffsetRequest handler does not handle errors David Arthur (JIRA)
  • [jira] [Comment Edited] (KAFKA-523) OffsetRequest handler does not handle errors David Arthur (JIRA)
  • [jira] [Commented] (KAFKA-523) OffsetRequest handler does not handle errors Joel Koshy (JIRA)
• Scripts/config not being rolled into package-dist artifact Matt Blair
  • Re: Scripts/config not being rolled into package-dist artifact Neha Narkhede
• [jira] [Created] (KAFKA-522) OutOfMemoryError in System Test John Fung (JIRA)
  • [jira] [Resolved] (KAFKA-522) OutOfMemoryError in System Test John Fung (JIRA)
• [VOTE] Release Kafka 0.7.2-incubating (Candidate 1) Joe Stein
  • Re: [VOTE] Release Kafka 0.7.2-incubating (Candidate 1) Lorenzo Alberton
  • Re: [VOTE] Release Kafka 0.7.2-incubating (Candidate 1) David Arthur
  • Re: [VOTE] Release Kafka 0.7.2-incubating (Candidate 1) Jun Rao
  • Re: [VOTE] Release Kafka 0.7.2-incubating (Candidate 1) Jay Kreps
  • Re: [VOTE] Release Kafka 0.7.2-incubating (Candidate 1) Joe Stein
  • Re: [VOTE] Release Kafka 0.7.2-incubating (Candidate 1) Jay Kreps
• Kafka 0.8 Vito Sabella
  • Re: Kafka 0.8 Neha Narkhede
  • Re: Kafka 0.8 Joel Koshy
  • RE: Kafka 0.8 Vito Sabella
  • Re: Kafka 0.8 Jun Rao
  • Re: Kafka 0.8 Jay Kreps
• release management features gone from JIRA Joe Stein
• Re: Integration with AMQP wm
  • Re: Integration with AMQP William Henry
  • Re: Integration with AMQP Jun Rao
  • Re: Integration with AMQP Jay Kreps
  • Re: Integration with AMQP Taylor Gautier
  • Re: Integration with AMQP William Henry
  • Re: Integration with AMQP William Henry
  • Re: Integration with AMQP William Henry
  • Re: Integration with AMQP Milind Parikh
  • Re: Integration with AMQP William Henry
  • Re: Integration with AMQP Jay Kreps
  • Re: Integration with AMQP William Henry
• whitespace Jay Kreps
  • Re: whitespace Neha Narkhede
  • Re: whitespace Prashanth Menon
  • Re: whitespace Joel Koshy
  • Re: whitespace Swapnil Ghike
  • Re: whitespace Jun Rao
  • Re: whitespace Jun Rao
  • Re: whitespace Jay Kreps
  • Re: whitespace Joe Stein
• [jira] [Created] (KAFKA-521) Cleanup public API for Log.scala Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-521) Refactor Log subsystem Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-521) Refactor Log subsystem Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-521) Refactor Log subsystem Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-521) Refactor Log subsystem Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-521) Refactor Log subsystem Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-521) Refactor Log subsystem Swapnil Ghike (JIRA)
  • [jira] [Commented] (KAFKA-521) Refactor Log subsystem Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-521) Refactor Log subsystem Swapnil Ghike (JIRA)
  • [jira] [Updated] (KAFKA-521) Refactor Log subsystem Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-521) Refactor Log subsystem Swapnil Ghike (JIRA)
  • [jira] [Commented] (KAFKA-521) Refactor Log subsystem Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-521) Refactor Log subsystem Jay Kreps (JIRA)
• Log.getOffsetsBefore() Jay Kreps
  • Re: Log.getOffsetsBefore() Jun Rao
  • Re: Log.getOffsetsBefore() Neha Narkhede

• Earlier messages
• Later messages