kafka-dev  

Messages by Thread

• • Re: [DISCUSS] git as the primary data source Derek Chen-Becker
  • Re: [DISCUSS] git as the primary data source Chris Burroughs
  • Re: [DISCUSS] git as the primary data source Jun Rao
  • Re: [DISCUSS] git as the primary data source Chris Burroughs
  • Re: [DISCUSS] git as the primary data source Chris Burroughs
• [jira] [Commented] (KAFKA-351) Refactor some new components introduced for replication Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-351) Refactor some new components introduced for replication Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-351) Refactor some new components introduced for replication Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-351) Refactor some new components introduced for replication Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-351) Refactor some new components introduced for replication Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-351) Refactor some new components introduced for replication Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-351) Refactor some new components introduced for replication Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-351) Refactor some new components introduced for replication Neha Narkhede (JIRA)
• [jira] [Created] (KAFKA-418) NullPointerException in ConsumerFetcherManager Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-418) NullPointerException in ConsumerFetcherManager Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-418) NullPointerException in ConsumerFetcherManager Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-418) NullPointerException in ConsumerFetcherManager Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-418) NullPointerException in ConsumerFetcherManager Jun Rao (JIRA)
  • [jira] [Closed] (KAFKA-418) NullPointerException in ConsumerFetcherManager Neha Narkhede (JIRA)
• [jira] [Created] (KAFKA-417) NullPointerException in ZookeeperConsumerConnector Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-417) NullPointerException in ZookeeperConsumerConnector Vaibhav Puranik (JIRA)
• [jira] [Created] (KAFKA-416) Controller tests throw several zookeeper errors Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-416) Controller tests throw several zookeeper errors Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-416) Controller tests throw several zookeeper errors Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-416) Controller tests throw several zookeeper errors Yang Ye (JIRA)
• [jira] [Created] (KAFKA-415) Controller throws NoSuchElementException while marking a broker failed Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-415) Controller throws NoSuchElementException while marking a broker failed Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-415) Controller throws NoSuchElementException while marking a broker failed Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-415) Controller throws NoSuchElementException while marking a broker failed Joel Koshy (JIRA)
  • [jira] [Resolved] (KAFKA-415) Controller throws NoSuchElementException while marking a broker failed Jun Rao (JIRA)
  • [jira] [Closed] (KAFKA-415) Controller throws NoSuchElementException while marking a broker failed Jun Rao (JIRA)
• [jira] [Created] (KAFKA-414) Evaluate mmap-based writes for Log implementation Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-414) Evaluate mmap-based writes for Log implementation Jay Kreps (JIRA)
• [jira] [Created] (KAFKA-413) single_host_multi_brokers system test fails on laptop Jun Rao (JIRA)
  • [jira] [Assigned] (KAFKA-413) single_host_multi_brokers system test fails on laptop John Fung (JIRA)
  • [jira] [Updated] (KAFKA-413) single_host_multi_brokers system test fails on laptop John Fung (JIRA)
  • [jira] [Updated] (KAFKA-413) single_host_multi_brokers system test fails on laptop John Fung (JIRA)
  • [jira] [Updated] (KAFKA-413) single_host_multi_brokers system test fails on laptop Jun Rao (JIRA)
• [jira] [Created] (KAFKA-412) deal with empty TopicData list in producer and fetch request Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-412) deal with empty TopicData list in producer and fetch request Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-412) deal with empty TopicData list in producer and fetch request Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-412) deal with empty TopicData list in producer and fetch request Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-412) deal with empty TopicData list in producer and fetch request Jun Rao (JIRA)
• [jira] [Assigned] (KAFKA-355) Move high watermark maintenance logic out of Log Neha Narkhede (JIRA)
• [jira] [Created] (KAFKA-411) Message Error in high cocurrent environment jian fan (JIRA)
  • [jira] [Commented] (KAFKA-411) Message Error in high cocurrent environment jian fan (JIRA)
  • [jira] [Comment Edited] (KAFKA-411) Message Error in high cocurrent environment jian fan (JIRA)
  • [jira] [Commented] (KAFKA-411) Message Error in high cocurrent environment jian fan (JIRA)
  • [jira] [Comment Edited] (KAFKA-411) Message Error in high cocurrent environment jian fan (JIRA)
  • [jira] [Updated] (KAFKA-411) Message Error in high cocurrent environment jian fan (JIRA)
  • [jira] [Commented] (KAFKA-411) Message Error in high cocurrent environment jian fan (JIRA)
  • [jira] [Updated] (KAFKA-411) Message Error in high cocurrent environment jian fan (JIRA)
  • [jira] [Commented] (KAFKA-411) Message Error in high cocurrent environment Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-411) Message Error in high cocurrent environment jian fan (JIRA)
  • [jira] [Updated] (KAFKA-411) Message Error in high cocurrent environment jian fan (JIRA)
  • [jira] [Commented] (KAFKA-411) Message Error in high cocurrent environment jian fan (JIRA)
• [jira] [Created] (KAFKA-410) after been killed, one broker fail to re-join the cluster after restarted mmliu (JIRA)
• [jira] [Commented] (KAFKA-354) Refactor getter and setter API to conform to the new convention Neha Narkhede (JIRA)
• [jira] [Comment Edited] (KAFKA-139) cross-compile multiple Scala versions Neha Narkhede (JIRA)
  • [jira] [Comment Edited] (KAFKA-139) cross-compile multiple Scala versions Neha Narkhede (JIRA)
• [jira] [Created] (KAFKA-409) Refactor DefaultEventHandler Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-409) Refactor DefaultEventHandler Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-409) Refactor DefaultEventHandler Jun Rao (JIRA)
  • [jira] [Assigned] (KAFKA-409) Refactor DefaultEventHandler Jay Kreps (JIRA)
• [jira] [Created] (KAFKA-408) ProducerPerformance does not work with all producer config options Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-408) ProducerPerformance does not work with all producer config options Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-408) ProducerPerformance does not work with all producer config options Pierre Queinnec (JIRA)
  • [jira] [Updated] (KAFKA-408) ProducerPerformance does not work with all producer config options Pierre Queinnec (JIRA)
  • [jira] [Updated] (KAFKA-408) ProducerPerformance does not work with all producer config options Jun Rao (JIRA)
• Re: Build failed in Jenkins: Kafka-0.8 #7 Jay Kreps
  • Re: Build failed in Jenkins: Kafka-0.8 #7 Neha Narkhede
  • Re: Build failed in Jenkins: Kafka-0.8 #7 Joel Koshy
• [jira] [Commented] (KAFKA-350) Enable message replication in the presence of controlled failures Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-350) Enable message replication in the presence of controlled failures Guozhang Wang (JIRA)
  • [jira] [Commented] (KAFKA-350) Enable message replication in the presence of controlled failures Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-350) Enable message replication in the presence of controlled failures Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-350) Enable message replication in the presence of controlled failures Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-350) Enable message replication in the presence of controlled failures Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-350) Enable message replication in the presence of controlled failures Neha Narkhede (JIRA)
• [jira] [Commented] (KAFKA-352) Throw exception to client if it makes a produce/consume request to a Kafka broker for a topic that hasn't been created Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-352) Throw exception to client if it makes a produce/consume request to a Kafka broker for a topic that hasn't been created Jay Kreps (JIRA)
• [jira] [Commented] (KAFKA-203) Improve Kafka internal metrics Chris Burroughs (JIRA)
  • [jira] [Commented] (KAFKA-203) Improve Kafka internal metrics Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-203) Improve Kafka internal metrics Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-203) Improve Kafka internal metrics Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-203) Improve Kafka internal metrics Joel Koshy (JIRA)
  • [jira] [Commented] (KAFKA-203) Improve Kafka internal metrics Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-203) Improve Kafka internal metrics Joel Koshy (JIRA)
• [jira] [Updated] (KAFKA-352) Throw exception to client if it makes a produce/consume request to a Kafka broker for a topic that hasn't been created Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-352) Throw exception to client if it makes a produce/consume request to a Kafka broker for a topic that hasn't been created Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-352) Throw exception to client if it makes a produce/consume request to a Kafka broker for a topic that hasn't been created Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-352) Throw exception to client if it makes a produce/consume request to a Kafka broker for a topic that hasn't been created Neha Narkhede (JIRA)
• [jira] [Comment Edited] (KAFKA-188) Support multiple data directories Jonathan Creasy (JIRA)
  • [jira] [Comment Edited] (KAFKA-188) Support multiple data directories Jonathan Creasy (JIRA)
• [jira] [Created] (KAFKA-407) Uncaught InputStream.close() exception in CompressionUtils.compress() Lorenzo Alberton (JIRA)
  • [jira] [Commented] (KAFKA-407) Uncaught InputStream.close() exception in CompressionUtils.compress() Jun Rao (JIRA)
• [jira] [Work started] (KAFKA-352) Throw exception to client if it makes a produce/consume request to a Kafka broker for a topic that hasn't been created Neha Narkhede (JIRA)
• [jira] [Assigned] (KAFKA-352) Throw exception to client if it makes a produce/consume request to a Kafka broker for a topic that hasn't been created Neha Narkhede (JIRA)
• [jira] [Updated] (KAFKA-354) Refactor getter and setter API to conform to the new convention Joe Stein (JIRA)
  • [jira] [Updated] (KAFKA-354) Refactor getter and setter API to conform to the new convention Joel Koshy (JIRA)
• [jira] [Assigned] (KAFKA-354) Refactor getter and setter API to conform to the new convention Joe Stein (JIRA)
• [jira] [Commented] (KAFKA-188) Support multiple data directories Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-188) Support multiple data directories Jonathan Creasy (JIRA)
  • [jira] [Commented] (KAFKA-188) Support multiple data directories Jonathan Creasy (JIRA)
  • [jira] [Commented] (KAFKA-188) Support multiple data directories Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-188) Support multiple data directories Jonathan Creasy (JIRA)
  • [jira] [Commented] (KAFKA-188) Support multiple data directories Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-188) Support multiple data directories Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-188) Support multiple data directories Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-188) Support multiple data directories Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-188) Support multiple data directories Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-188) Support multiple data directories Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-188) Support multiple data directories Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-188) Support multiple data directories Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-188) Support multiple data directories Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-188) Support multiple data directories Jun Rao (JIRA)
• [jira] [Commented] (KAFKA-311) Allow KafkaLog4jAppender to take in a configurable producer.type Neha Narkhede (JIRA)
• [jira] [Created] (KAFKA-406) Gzipped payload is a full wrapped Message (with headers), not just payload Lorenzo Alberton (JIRA)
  • [jira] [Updated] (KAFKA-406) Gzipped payload is a fully wrapped Message (with headers), not just payload Lorenzo Alberton (JIRA)
  • [jira] [Commented] (KAFKA-406) Gzipped payload is a fully wrapped Message (with headers), not just payload Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-406) Gzipped payload is a fully wrapped Message (with headers), not just payload Lorenzo Alberton (JIRA)
  • Re: [jira] [Commented] (KAFKA-406) Gzipped payload is a fully wrapped Message (with headers), not just payload Michal Hariš
  • [jira] [Commented] (KAFKA-406) Gzipped payload is a fully wrapped Message (with headers), not just payload Lorenzo Alberton (JIRA)
  • [jira] [Commented] (KAFKA-406) Gzipped payload is a fully wrapped Message (with headers), not just payload Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-406) Gzipped payload is a fully wrapped Message (with headers), not just payload Jay Kreps (JIRA)
  • Re: [jira] [Commented] (KAFKA-406) Gzipped payload is a fully wrapped Message (with headers), not just payload Michal Hariš
  • Re: [jira] [Commented] (KAFKA-406) Gzipped payload is a fully wrapped Message (with headers), not just payload Jay Kreps
  • Re: [jira] [Commented] (KAFKA-406) Gzipped payload is a fully wrapped Message (with headers), not just payload Michal Hariš
  • [jira] [Commented] (KAFKA-406) Gzipped payload is a fully wrapped Message (with headers), not just payload Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-406) Gzipped payload is a fully wrapped Message (with headers), not just payload Lorenzo Alberton (JIRA)
• [jira] [Commented] (KAFKA-181) Log errors for unrecognized config options Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-181) Log errors for unrecognized config options Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-181) Log errors for unrecognized config options Joe Stein (JIRA)
  • [jira] [Commented] (KAFKA-181) Log errors for unrecognized config options Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-181) Log errors for unrecognized config options Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-181) Log errors for unrecognized config options Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-181) Log errors for unrecognized config options Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-181) Log errors for unrecognized config options Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-181) Log errors for unrecognized config options Jay Kreps (JIRA)
• Are we doing a 0.7.2? Jay Kreps
  • Re: Are we doing a 0.7.2? Joel Koshy
  • Re: Are we doing a 0.7.2? Joe Stein
  • Re: Are we doing a 0.7.2? Chris Burroughs
  • Re: Are we doing a 0.7.2? Neha Narkhede
  • Re: Are we doing a 0.7.2? Jay Kreps
  • Re: Are we doing a 0.7.2? Chris Burroughs
  • Re: Are we doing a 0.7.2? Chris Burroughs
• Producing to a random partition Jay Kreps
  • Re: Producing to a random partition Neha Narkhede
• KAFKA-203 - Improve Metrics (use codehale/metrics) Jonathan Creasy
  • Re: KAFKA-203 - Improve Metrics (use codehale/metrics) Joel Koshy
  • Re: KAFKA-203 - Improve Metrics (use codehale/metrics) Joe Stein
• [jira] [Updated] (KAFKA-311) Allow KafkaLog4jAppender to take in a configurable producer.type Jonathan Creasy (JIRA)
  • [jira] [Updated] (KAFKA-311) Allow KafkaLog4jAppender to take in a configurable producer.type Jonathan Creasy (JIRA)
  • [jira] [Updated] (KAFKA-311) Allow KafkaLog4jAppender to take in a configurable producer.type Jay Kreps (JIRA)
• [jira] [Updated] (KAFKA-184) Log retention size and file size should be a long Jonathan Creasy (JIRA)
  • [jira] [Updated] (KAFKA-184) Log retention size and file size should be a long Jonathan Creasy (JIRA)
• [jira] [Commented] (KAFKA-184) Log retention size and file size should be a long Jonathan Creasy (JIRA)
  • [jira] [Commented] (KAFKA-184) Log retention size and file size should be a long Jonathan Creasy (JIRA)
  • [jira] [Commented] (KAFKA-184) Log retention size and file size should be a long Jay Kreps (JIRA)
• [jira] [Comment Edited] (KAFKA-343) revisit the become leader and become follower state change operations using V3 design Neha Narkhede (JIRA)
• [jira] [Updated] (KAFKA-350) Enable message replication in the presence of controlled failures Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-350) Enable message replication in the presence of controlled failures Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-350) Enable message replication in the presence of controlled failures Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-350) Enable message replication in the presence of controlled failures Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-350) Enable message replication in the presence of controlled failures Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-350) Enable message replication in the presence of controlled failures Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-350) Enable message replication in the presence of controlled failures Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-350) Enable message replication in the presence of controlled failures Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-350) Enable message replication in the presence of controlled failures Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-350) Enable message replication in the presence of controlled failures Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-350) Enable message replication in the presence of controlled failures Neha Narkhede (JIRA)
• [jira] [Created] (KAFKA-405) Improve the high water mark maintenance to store high watermarks for all partitions in a single file on disk Neha Narkhede (JIRA)
  • [jira] [Assigned] (KAFKA-405) Improve the high water mark maintenance to store high watermarks for all partitions in a single file on disk Neha Narkhede (JIRA)
  • [jira] [Work started] (KAFKA-405) Improve the high water mark maintenance to store high watermarks for all partitions in a single file on disk Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-405) Improve the high water mark maintenance to store high watermarks for all partitions in a single file on disk Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-405) Improve the high water mark maintenance to store high watermarks for all partitions in a single file on disk Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-405) Improve the high water mark maintenance to store high watermarks for all partitions in a single file on disk Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-405) Improve the high water mark maintenance to store high watermarks for all partitions in a single file on disk Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-405) Improve the high water mark maintenance to store high watermarks for all partitions in a single file on disk Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-405) Improve the high water mark maintenance to store high watermarks for all partitions in a single file on disk Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-405) Improve the high water mark maintenance to store high watermarks for all partitions in a single file on disk Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-405) Improve the high water mark maintenance to store high watermarks for all partitions in a single file on disk Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-405) Improve the high water mark maintenance to store high watermarks for all partitions in a single file on disk Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-405) Improve the high water mark maintenance to store high watermarks for all partitions in a single file on disk Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-405) Improve the high water mark maintenance to store high watermarks for all partitions in a single file on disk Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-405) Improve the high water mark maintenance to store high watermarks for all partitions in a single file on disk Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-405) Improve the high water mark maintenance to store high watermarks for all partitions in a single file on disk Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-405) Improve the high water mark maintenance to store high watermarks for all partitions in a single file on disk Jun Rao (JIRA)
• [jira] [Created] (KAFKA-404) When using chroot path, create chroot on startup if it doesn't exist Jonathan Creasy (JIRA)
  • [jira] [Commented] (KAFKA-404) When using chroot path, create chroot on startup if it doesn't exist Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-404) When using chroot path, create chroot on startup if it doesn't exist Jonathan Creasy (JIRA)
  • [jira] [Updated] (KAFKA-404) When using chroot path, create chroot on startup if it doesn't exist Jonathan Creasy (JIRA)
  • [jira] [Updated] (KAFKA-404) When using chroot path, create chroot on startup if it doesn't exist Jonathan Creasy (JIRA)
  • [jira] [Updated] (KAFKA-404) When using chroot path, create chroot on startup if it doesn't exist Jonathan Creasy (JIRA)
  • [jira] [Updated] (KAFKA-404) When using chroot path, create chroot on startup if it doesn't exist Jonathan Creasy (JIRA)
  • [jira] [Updated] (KAFKA-404) When using chroot path, create chroot on startup if it doesn't exist Jonathan Creasy (JIRA)
  • [jira] [Updated] (KAFKA-404) When using chroot path, create chroot on startup if it doesn't exist Jonathan Creasy (JIRA)
  • [jira] [Updated] (KAFKA-404) When using chroot path, create chroot on startup if it doesn't exist Jonathan Creasy (JIRA)
  • [jira] [Commented] (KAFKA-404) When using chroot path, create chroot on startup if it doesn't exist Joel Koshy (JIRA)

• Earlier messages
• Later messages