kafka-dev  

Messages by Thread

• [jira] [Created] (KAFKA-593) Empty log index file created when it shouldn't be empty Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-593) Empty log index file created when it shouldn't be empty Yang Ye (JIRA)
  • [jira] [Commented] (KAFKA-593) Empty log index file created when it shouldn't be empty Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-593) Empty log index file created when it shouldn't be empty Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-593) Empty log index file created when it shouldn't be empty Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-593) Empty log index file created when it shouldn't be empty Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-593) Empty log index file created when it shouldn't be empty Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-593) Empty log index file created when it shouldn't be empty Yang Ye (JIRA)
  • [jira] [Commented] (KAFKA-593) Empty log index file created when it shouldn't be empty Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-593) Empty log index file created when it shouldn't be empty Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-593) Empty log index file created when it shouldn't be empty Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-593) Empty log index file created when it shouldn't be empty Yang Ye (JIRA)
  • [jira] [Commented] (KAFKA-593) Empty log index file created when it shouldn't be empty Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-593) Empty log index file created when it shouldn't be empty Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-593) Empty log index file created when it shouldn't be empty Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-593) Empty log index file created when it shouldn't be empty Yang Ye (JIRA)
  • [jira] [Commented] (KAFKA-593) Empty log index file created when it shouldn't be empty Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-593) Empty log index file created when it shouldn't be empty Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-593) Empty log index file created when it shouldn't be empty Yang Ye (JIRA)
  • [jira] [Commented] (KAFKA-593) Empty log index file created when it shouldn't be empty Jay Kreps (JIRA)
  • [jira] [Resolved] (KAFKA-593) Empty log index file created when it shouldn't be empty Neha Narkhede (JIRA)
• [jira] [Created] (KAFKA-592) Register metrics beans at kafka server startup Swapnil Ghike (JIRA)
  • [jira] [Updated] (KAFKA-592) Register metrics beans at kafka server startup Swapnil Ghike (JIRA)
  • [jira] [Resolved] (KAFKA-592) Register metrics beans at kafka server startup Jun Rao (JIRA)
  • [jira] [Closed] (KAFKA-592) Register metrics beans at kafka server startup Jun Rao (JIRA)
• [jira] [Created] (KAFKA-591) Add test cases to test log size retention and more John Fung (JIRA)
  • [jira] [Updated] (KAFKA-591) Add test cases to test log size retention and more John Fung (JIRA)
  • [jira] [Updated] (KAFKA-591) Add test cases to test log size retention and more John Fung (JIRA)
  • [jira] [Updated] (KAFKA-591) Add test cases to test log size retention and more John Fung (JIRA)
  • [jira] [Commented] (KAFKA-591) Add test cases to test log size retention and more John Fung (JIRA)
  • [jira] [Updated] (KAFKA-591) Add test cases to test log size retention and more John Fung (JIRA)
  • [jira] [Updated] (KAFKA-591) Add test cases to test log size retention and more John Fung (JIRA)
  • [jira] [Updated] (KAFKA-591) Add test cases to test log size retention and more John Fung (JIRA)
  • [jira] [Updated] (KAFKA-591) Add test cases to test log size retention and more John Fung (JIRA)
  • [jira] [Updated] (KAFKA-591) Add test cases to test log size retention and more John Fung (JIRA)
  • [jira] [Updated] (KAFKA-591) Add test cases to test log size retention and more John Fung (JIRA)
  • [jira] [Updated] (KAFKA-591) Add test cases to test log size retention and more John Fung (JIRA)
  • [jira] [Updated] (KAFKA-591) Add test cases to test log size retention and more John Fung (JIRA)
  • [jira] [Updated] (KAFKA-591) Add test cases to test log size retention and more John Fung (JIRA)
  • [jira] [Updated] (KAFKA-591) Add test cases to test log size retention and more John Fung (JIRA)
  • [jira] [Commented] (KAFKA-591) Add test cases to test log size retention and more John Fung (JIRA)
  • [jira] [Updated] (KAFKA-591) Add test cases to test log size retention and more John Fung (JIRA)
  • [jira] [Updated] (KAFKA-591) Add test cases to test log size retention and more John Fung (JIRA)
  • [jira] [Updated] (KAFKA-591) Add test cases to test log size retention and more Jun Rao (JIRA)
  • [jira] [Closed] (KAFKA-591) Add test cases to test log size retention and more Jun Rao (JIRA)
• [jira] [Commented] (KAFKA-451) follower replica may need to backoff the fetching if leader is not ready yet Prashanth Menon (JIRA)
• [jira] [Assigned] (KAFKA-451) follower replica may need to backoff the fetching if leader is not ready yet Prashanth Menon (JIRA)
• Re: Maintainer system? Joe Stein
  • Re: Maintainer system? Jun Rao
  • Re: Maintainer system? Neha Narkhede
  • Re: Maintainer system? Prashanth Menon
  • Re: Maintainer system? Jay Kreps
  • Re: Maintainer system? Jay Kreps
  • Re: Maintainer system? Jakob Homan
  • Re: Maintainer system? Jay Kreps
• Re: move 0.8 back to trunk Joe Stein
  • Re: move 0.8 back to trunk Jun Rao
• [jira] [Created] (KAFKA-590) System Test - 4 cases failed due to insufficient no. of retry in ProducerPerformance John Fung (JIRA)
  • [jira] [Resolved] (KAFKA-590) System Test - 4 cases failed due to insufficient no. of retry in ProducerPerformance John Fung (JIRA)
  • [jira] [Closed] (KAFKA-590) System Test - 4 cases failed due to insufficient no. of retry in ProducerPerformance John Fung (JIRA)
• [jira] [Created] (KAFKA-589) Clean shutdown after startup connection failure Jason Rosenberg (JIRA)
  • [jira] [Commented] (KAFKA-589) Clean shutdown after startup connection failure Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-589) Clean shutdown after startup connection failure Jun Rao (JIRA)
  • [jira] [Assigned] (KAFKA-589) Clean shutdown after startup connection failure Swapnil Ghike (JIRA)
  • [jira] [Commented] (KAFKA-589) Clean shutdown after startup connection failure Swapnil Ghike (JIRA)
  • [jira] [Commented] (KAFKA-589) Clean shutdown after startup connection failure Jason Rosenberg (JIRA)
• [jira] [Closed] (KAFKA-340) Implement clean shutdown in 0.8 Neha Narkhede (JIRA)
• [jira] [Resolved] (KAFKA-340) Implement clean shutdown in 0.8 Neha Narkhede (JIRA)
• [jira] [Created] (KAFKA-588) Index truncation doesn't seem to remove the last entry properly Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-588) Index truncation doesn't seem to remove the last entry properly Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-588) Index truncation doesn't seem to remove the last entry properly Jun Rao (JIRA)
  • [jira] [Assigned] (KAFKA-588) Index truncation doesn't seem to remove the last entry properly Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-588) Index truncation doesn't seem to remove the last entry properly Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-588) Index truncation doesn't seem to remove the last entry properly Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-588) Index truncation doesn't seem to remove the last entry properly Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-588) Index truncation doesn't seem to remove the last entry properly Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-588) Index truncation doesn't seem to remove the last entry properly Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-588) Index truncation doesn't seem to remove the last entry properly Neha Narkhede (JIRA)
  • [jira] [Resolved] (KAFKA-588) Index truncation doesn't seem to remove the last entry properly Jay Kreps (JIRA)
• end-to-end latency in kafka 0.8 Jay Kreps
  • Re: end-to-end latency in kafka 0.8 Taylor Gautier
  • Re: end-to-end latency in kafka 0.8 Neha Narkhede
  • Re: end-to-end latency in kafka 0.8 Jay Kreps
• [jira] [Created] (KAFKA-587) Refactor end-to-end latency test to work in system test framework Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-587) Refactor end-to-end latency test to work in system test framework Jay Kreps (JIRA)
• [jira] [Created] (KAFKA-586) system test configs are broken Neha Narkhede (JIRA)
  • [jira] [Assigned] (KAFKA-586) system test configs are broken John Fung (JIRA)
  • [jira] [Commented] (KAFKA-586) system test configs are broken John Fung (JIRA)
  • [jira] [Updated] (KAFKA-586) system test configs are broken John Fung (JIRA)
  • [jira] [Comment Edited] (KAFKA-586) system test configs are broken John Fung (JIRA)
  • [jira] [Updated] (KAFKA-586) system test configs are broken John Fung (JIRA)
  • [jira] [Commented] (KAFKA-586) system test configs are broken John Fung (JIRA)
  • [jira] [Updated] (KAFKA-586) system test configs are broken Jun Rao (JIRA)
  • [jira] [Closed] (KAFKA-586) system test configs are broken Jun Rao (JIRA)
• [jira] [Created] (KAFKA-585) Remove custom metrics jar and replace with latest from metrics HEAD Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-585) Remove custom metrics jar and replace with latest from metrics HEAD Joel Koshy (JIRA)
  • [jira] [Commented] (KAFKA-585) Remove custom metrics jar and replace with latest from metrics HEAD Joel Koshy (JIRA)
  • [jira] [Commented] (KAFKA-585) Remove custom metrics jar and replace with latest from metrics HEAD Jun Rao (JIRA)
  • [jira] [Resolved] (KAFKA-585) Remove custom metrics jar and replace with latest from metrics HEAD Joel Koshy (JIRA)
  • [jira] [Closed] (KAFKA-585) Remove custom metrics jar and replace with latest from metrics HEAD Joel Koshy (JIRA)
• [jira] [Created] (KAFKA-584) produce/fetch remote time metric not set correctly when num.acks = 1 Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-584) produce/fetch remote time metric not set correctly when num.acks = 1 Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-584) produce/fetch remote time metric not set correctly when num.acks = 1 Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-584) produce/fetch remote time metric not set correctly when num.acks = 1 Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-584) produce/fetch remote time metric not set correctly when num.acks = 1 Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-584) produce/fetch remote time metric not set correctly when num.acks = 1 Jun Rao (JIRA)
  • [jira] [Closed] (KAFKA-584) produce/fetch remote time metric not set correctly when num.acks = 1 Jun Rao (JIRA)
• [jira] [Created] (KAFKA-583) SimpleConsumerShell may receive less data inconsistently John Fung (JIRA)
  • [jira] [Updated] (KAFKA-583) SimpleConsumerShell may receive less data inconsistently John Fung (JIRA)
  • [jira] [Commented] (KAFKA-583) SimpleConsumerShell may receive less data inconsistently John Fung (JIRA)
  • [jira] [Updated] (KAFKA-583) SimpleConsumerShell may receive less data inconsistently John Fung (JIRA)
  • [jira] [Updated] (KAFKA-583) SimpleConsumerShell may receive less data inconsistently John Fung (JIRA)
  • [jira] [Updated] (KAFKA-583) SimpleConsumerShell may receive less data inconsistently John Fung (JIRA)
  • [jira] [Updated] (KAFKA-583) SimpleConsumerShell may receive less data inconsistently John Fung (JIRA)
  • [jira] [Updated] (KAFKA-583) SimpleConsumerShell may receive less data inconsistently John Fung (JIRA)
  • [jira] [Updated] (KAFKA-583) SimpleConsumerShell may receive less data inconsistently John Fung (JIRA)
  • [jira] [Updated] (KAFKA-583) SimpleConsumerShell may receive less data inconsistently John Fung (JIRA)
  • [jira] [Commented] (KAFKA-583) SimpleConsumerShell may receive less data inconsistently John Fung (JIRA)
• [jira] [Created] (KAFKA-582) DumpLogSegments throws java.lang.OutOfMemoryError: Java heap space John Fung (JIRA)
  • [jira] [Resolved] (KAFKA-582) DumpLogSegments throws java.lang.OutOfMemoryError: Java heap space John Fung (JIRA)
• [jira] [Comment Edited] (KAFKA-267) Enhance ProducerPerformance to generate unique random Long value for payload Neha Narkhede (JIRA)
• [jira] [Created] (KAFKA-581) provides windows batch script for starting Kafka/Zookeeper antoine vianey (JIRA)
  • [jira] [Updated] (KAFKA-581) provides windows batch script for starting Kafka/Zookeeper antoine vianey (JIRA)
  • [jira] [Commented] (KAFKA-581) provides windows batch script for starting Kafka/Zookeeper antoine vianey (JIRA)
  • [jira] [Comment Edited] (KAFKA-581) provides windows batch script for starting Kafka/Zookeeper antoine vianey (JIRA)
  • [jira] [Resolved] (KAFKA-581) provides windows batch script for starting Kafka/Zookeeper Jun Rao (JIRA)
  • [jira] [Closed] (KAFKA-581) provides windows batch script for starting Kafka/Zookeeper Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-581) provides windows batch script for starting Kafka/Zookeeper antoine vianey (JIRA)
  • [jira] [Commented] (KAFKA-581) provides windows batch script for starting Kafka/Zookeeper Jun Rao (JIRA)
• [jira] [Created] (KAFKA-580) system test testcase_0122 under replication fails due to large # of data loss Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-580) system test testcase_0122 under replication fails due to large # of data loss Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-580) system test testcase_0122 under replication fails due to large # of data loss Jun Rao (JIRA)
  • [jira] [Assigned] (KAFKA-580) system test testcase_0122 under replication fails due to large # of data loss Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-580) system test testcase_0122 under replication fails due to large # of data loss Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-580) system test testcase_0122 under replication fails due to large # of data loss John Fung (JIRA)
  • [jira] [Updated] (KAFKA-580) system test testcase_0122 under replication fails due to large # of data loss Jun Rao (JIRA)
  • [jira] [Closed] (KAFKA-580) system test testcase_0122 under replication fails due to large # of data loss Jun Rao (JIRA)
• [jira] [Commented] (KAFKA-77) Implement "group commit" for kafka logs Dave Revell (JIRA)
  • [jira] [Commented] (KAFKA-77) Implement "group commit" for kafka logs Jun Rao (JIRA)
• [jira] [Created] (KAFKA-579) remove connection timeout in SyncProducer Jun Rao (JIRA)
  • [jira] [Assigned] (KAFKA-579) remove connection timeout in SyncProducer Swapnil Ghike (JIRA)
  • [jira] [Updated] (KAFKA-579) remove connection timeout in SyncProducer Swapnil Ghike (JIRA)
  • [jira] [Resolved] (KAFKA-579) remove connection timeout in SyncProducer Jun Rao (JIRA)
  • [jira] [Closed] (KAFKA-579) remove connection timeout in SyncProducer Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-579) remove connection timeout in SyncProducer Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-579) remove connection timeout in SyncProducer Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-579) remove connection timeout in SyncProducer Neha Narkhede (JIRA)
• [VOTE] Graduate Kafka from Incubator to TLP status Jakob Homan
  • Re: [VOTE] Graduate Kafka from Incubator to TLP status Neha Narkhede
  • Re: [VOTE] Graduate Kafka from Incubator to TLP status Joe Stein
  • Re: [VOTE] Graduate Kafka from Incubator to TLP status Jun Rao
  • Re: [VOTE] Graduate Kafka from Incubator to TLP status Chris Burroughs
  • Re: [VOTE] Graduate Kafka from Incubator to TLP status Alan D. Cabrera
  • Re: [VOTE] Graduate Kafka from Incubator to TLP status Ajit Koti
  • Re: [VOTE] Graduate Kafka from Incubator to TLP status Jun Rao
  • Re: [VOTE] Graduate Kafka from Incubator to TLP status Jakob Homan
  • Re: [VOTE] Graduate Kafka from Incubator to TLP status Jakob Homan
• [VOTE] Resolution to graduate Kafka from Incubator to TLP status Jakob Homan
  • Re: [VOTE] Resolution to graduate Kafka from Incubator to TLP status Jakob Homan
• [jira] [Created] (KAFKA-578) Leader finder thread in ConsumerFetcherManager needs to handle exceptions Jun Rao (JIRA)
  • [jira] [Assigned] (KAFKA-578) Leader finder thread in ConsumerFetcherManager needs to handle exceptions Swapnil Ghike (JIRA)
  • [jira] [Updated] (KAFKA-578) Leader finder thread in ConsumerFetcherManager needs to handle exceptions Swapnil Ghike (JIRA)
  • [jira] [Closed] (KAFKA-578) Leader finder thread in ConsumerFetcherManager needs to handle exceptions Jun Rao (JIRA)
  • [jira] [Resolved] (KAFKA-578) Leader finder thread in ConsumerFetcherManager needs to handle exceptions Jun Rao (JIRA)
• [jira] [Created] (KAFKA-577) extend DumpLogSegments to verify consistency btw data and index Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-577) extend DumpLogSegments to verify consistency btw data and index Yang Ye (JIRA)
  • [jira] [Commented] (KAFKA-577) extend DumpLogSegments to verify consistency btw data and index Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-577) extend DumpLogSegments to verify consistency btw data and index Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-577) extend DumpLogSegments to verify consistency btw data and index Jun Rao (JIRA)
  • [jira] [Resolved] (KAFKA-577) extend DumpLogSegments to verify consistency btw data and index Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-577) extend DumpLogSegments to verify consistency btw data and index Jun Rao (JIRA)
  • [jira] [Reopened] (KAFKA-577) extend DumpLogSegments to verify consistency btw data and index Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-577) extend DumpLogSegments to verify consistency btw data and index Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-577) extend DumpLogSegments to verify consistency btw data and index Yang Ye (JIRA)
  • [jira] [Commented] (KAFKA-577) extend DumpLogSegments to verify consistency btw data and index Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-577) extend DumpLogSegments to verify consistency btw data and index Yang Ye (JIRA)
  • [jira] [Commented] (KAFKA-577) extend DumpLogSegments to verify consistency btw data and index Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-577) extend DumpLogSegments to verify consistency btw data and index Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-577) extend DumpLogSegments to verify consistency btw data and index Yang Ye (JIRA)
  • [jira] [Resolved] (KAFKA-577) extend DumpLogSegments to verify consistency btw data and index Jun Rao (JIRA)
  • [jira] [Closed] (KAFKA-577) extend DumpLogSegments to verify consistency btw data and index Jun Rao (JIRA)
• Re: Release files should have group writer permission sebb
  • Re: Release files should have group writer permission Joe Stein
• [jira] [Commented] (KAFKA-340) Implement clean shutdown in 0.8 Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-340) Implement clean shutdown in 0.8 Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-340) Implement clean shutdown in 0.8 Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-340) Implement clean shutdown in 0.8 Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-340) Implement clean shutdown in 0.8 Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-340) Implement clean shutdown in 0.8 Joel Koshy (JIRA)
  • [jira] [Commented] (KAFKA-340) Implement clean shutdown in 0.8 Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-340) Implement clean shutdown in 0.8 Joel Koshy (JIRA)
• [jira] [Updated] (KAFKA-340) Implement clean shutdown in 0.8 Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-340) Implement clean shutdown in 0.8 Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-340) Implement clean shutdown in 0.8 Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-340) Implement clean shutdown in 0.8 Joel Koshy (JIRA)
• [jira] [Created] (KAFKA-576) SimpleConsumerShell runs into an infinite loop John Fung (JIRA)
  • [jira] [Commented] (KAFKA-576) SimpleConsumerShell runs into an infinite loop John Fung (JIRA)
  • [jira] [Assigned] (KAFKA-576) SimpleConsumerShell runs into an infinite loop John Fung (JIRA)
  • [jira] [Commented] (KAFKA-576) SimpleConsumerShell runs into an infinite loop John Fung (JIRA)
  • [jira] [Comment Edited] (KAFKA-576) SimpleConsumerShell runs into an infinite loop John Fung (JIRA)

• Earlier messages
• Later messages