kafka-dev  

Messages by Thread

• [jira] [Assigned] (KAFKA-350) Improve the high water mark maintenance to store high watermarks for all partitions in a single file on disk Neha Narkhede (JIRA)
• video recording for the 1st Kafka user group meeting Jun Rao
  • Re: video recording for the 1st Kafka user group meeting Chris Burroughs
• [VOTE] Release Kafka 0.7.1-incubating (Candidate 2) Joe Stein
  • Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 2) Jun Rao
  • Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 2) Jun Rao
  • Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 2) Jun Rao
  • Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 2) Joel Koshy
  • Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 2) Kevan Miller
  • Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 2) Joe Stein
  • remaining jars in svn (was Fwd: Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 2)) Chris Burroughs
  • Re: remaining jars in svn (was Fwd: Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 2)) Joe Stein
  • Re: remaining jars in svn (was Fwd: Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 2)) Jun Rao
  • Re: remaining jars in svn (was Fwd: Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 2)) Joe Stein
  • Re: remaining jars in svn (was Fwd: Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 2)) Neha Narkhede
  • Re: remaining jars in svn (was Fwd: Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 2)) Joe Stein
  • Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 2) Jun Rao
  • Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 2) Chris Burroughs
  • Fwd: [VOTE] Release Kafka 0.7.1-incubating (Candidate 2) Jun Rao
  • Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 2) Joe Stein
• [jira] [Created] (KAFKA-365) change copyright in NOTICE to 2012 Joe Stein (JIRA)
  • [jira] [Updated] (KAFKA-365) change copyright in NOTICE to 2012 Joe Stein (JIRA)
  • [jira] [Updated] (KAFKA-365) change copyright in NOTICE to 2012 Joe Stein (JIRA)
  • [jira] [Commented] (KAFKA-365) change copyright in NOTICE to 2012 Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-365) change copyright in NOTICE to 2012 Joe Stein (JIRA)
  • [jira] [Updated] (KAFKA-365) change copyright in NOTICE to 2012 Yang Ye (JIRA)
  • [jira] [Commented] (KAFKA-365) change copyright in NOTICE to 2012 Jun Rao (JIRA)
• [VOTE] Release Kafka 0.7.1-incubating (Candidate 1) Joe Stein
  • Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 1) sebb
  • Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 1) Joe Stein
• [jira] [Resolved] (KAFKA-198) Avoid duplicated message during consumer rebalance Joe Stein (JIRA)
• [jira] [Resolved] (KAFKA-335) Implement an embedded controller Jun Rao (JIRA)
• [jira] [Commented] (KAFKA-134) Upgrade Kafka to sbt 0.10.1 Chris Birchall (JIRA)
  • [jira] [Commented] (KAFKA-134) Upgrade Kafka to sbt 0.10.1 Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-134) Upgrade Kafka to sbt 0.10.1 Joe Stein (JIRA)
• hierarchical topics Jay Kreps
• [jira] [Commented] (KAFKA-306) broker failure system test broken on replication branch Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-306) broker failure system test broken on replication branch Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-306) broker failure system test broken on replication branch Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-306) broker failure system test broken on replication branch Joel Koshy (JIRA)
  • [jira] [Commented] (KAFKA-306) broker failure system test broken on replication branch Joel Koshy (JIRA)
  • [jira] [Commented] (KAFKA-306) broker failure system test broken on replication branch Jun Rao (JIRA)
• [jira] [Updated] (KAFKA-168) Support locality in consumer partition assignment algorithm Neha Narkhede (JIRA)
• [jira] [Updated] (KAFKA-170) Support for non-blocking polling on multiple streams Neha Narkhede (JIRA)
• [jira] [Updated] (KAFKA-183) Expose offset vector to the consumer Neha Narkhede (JIRA)
• [jira] [Updated] (KAFKA-361) Add ability to get offsets from ZK-based consumer Neha Narkhede (JIRA)
• [jira] [Updated] (KAFKA-360) Add ability to disable rebalancing in ZooKeeper consumer Neha Narkhede (JIRA)
• Consumer re-design proposal Neha Narkhede
  • Re: Consumer re-design proposal Jay Kreps
  • Re: Consumer re-design proposal Evan Chan
  • Re: Consumer re-design proposal Marcos Juarez
  • Re: Consumer re-design proposal Neha Narkhede
  • RE: Consumer re-design proposal Sybrandy, Casey
  • Re: Consumer re-design proposal Chris Burroughs
  • Re: Consumer re-design proposal Neha Narkhede
  • Re: Consumer re-design proposal Dave Barr
  • Re: Consumer re-design proposal Ross Black
  • Re: Consumer re-design proposal Jun Rao
• [jira] [Created] (KAFKA-364) Consumer re-design Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-364) Consumer re-design Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-364) Consumer re-design Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-364) Consumer re-design Ross Black (JIRA)
  • [jira] [Commented] (KAFKA-364) Consumer re-design Ross Black (JIRA)
  • [jira] [Comment Edited] (KAFKA-364) Consumer re-design Ross Black (JIRA)
• [jira] [Comment Edited] (KAFKA-341) Create a new single host system test to validate all replicas on 0.8 branch John Fung (JIRA)
• [jira] [Updated] (KAFKA-341) Create a new single host system test to validate all replicas on 0.8 branch John Fung (JIRA)
  • [jira] [Updated] (KAFKA-341) Create a new single host system test to validate all replicas on 0.8 branch John Fung (JIRA)
  • [jira] [Updated] (KAFKA-341) Create a new single host system test to validate all replicas on 0.8 branch John Fung (JIRA)
  • [jira] [Updated] (KAFKA-341) Create a new single host system test to validate all replicas on 0.8 branch John Fung (JIRA)
  • [jira] [Updated] (KAFKA-341) Create a new single host system test to validate all replicas on 0.8 branch Jun Rao (JIRA)
• [jira] [Comment Edited] (KAFKA-329) Remove the watches/broker for new topics and partitions and change create topic admin API to send start replica state change to all brokers Prashanth Menon (JIRA)
  • [jira] [Comment Edited] (KAFKA-329) Remove the watches/broker for new topics and partitions and change create topic admin API to send start replica state change to all brokers Prashanth Menon (JIRA)
• [DISCUSSION] KAFKA 0.7.1 RELEASE Joe Stein
  • Re: [DISCUSSION] KAFKA 0.7.1 RELEASE Jun Rao
  • Re: [DISCUSSION] KAFKA 0.7.1 RELEASE Joe Stein
  • Re: [DISCUSSION] KAFKA 0.7.1 RELEASE Jun Rao
• [jira] [Updated] (KAFKA-329) Remove the watches/broker for new topics and partitions and change create topic admin API to send start replica state change to all brokers Prashanth Menon (JIRA)
  • [jira] [Updated] (KAFKA-329) Remove the watches/broker for new topics and partitions and change create topic admin API to send start replica state change to all brokers Prashanth Menon (JIRA)
  • [jira] [Updated] (KAFKA-329) Remove the watches/broker for new topics and partitions and change create topic admin API to send start replica state change to all brokers Prashanth Menon (JIRA)
• [jira] [Resolved] (KAFKA-44) Various ZK listeners to support intra-cluster replication Neha Narkhede (JIRA)
• [jira] [Resolved] (KAFKA-302) Implement the become leader and become follower state change operations Neha Narkhede (JIRA)
• [jira] [Resolved] (KAFKA-45) Broker startup, leader election, becoming a leader/follower for intra-cluster replication Neha Narkhede (JIRA)
• kafka replication status Jun Rao
• Re: wiki describing code path for major components Jay Kreps
  • RE: wiki describing code path for major components Guozhang Wang
  • Re: wiki describing code path for major components Jay Kreps
• [jira] [Reopened] (KAFKA-294) "Path length must be > 0" error during startup Jay Kreps (JIRA)
• [jira] [Created] (KAFKA-363) Replace numerical compression codes in config with something human readable Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-363) Replace numerical compression codes in config with something human readable David Arthur (JIRA)
  • [jira] [Updated] (KAFKA-363) Replace numerical compression codes in config with something human readable David Arthur (JIRA)
  • [jira] [Updated] (KAFKA-363) Replace numerical compression codes in config with something human readable David Arthur (JIRA)
  • [jira] [Updated] (KAFKA-363) Replace numerical compression codes in config with something human readable David Arthur (JIRA)
  • [jira] [Commented] (KAFKA-363) Replace numerical compression codes in config with something human readable Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-363) Replace numerical compression codes in config with something human readable David Arthur (JIRA)
  • [jira] [Updated] (KAFKA-363) Replace numerical compression codes in config with something human readable David Arthur (JIRA)
  • [jira] [Commented] (KAFKA-363) Replace numerical compression codes in config with something human readable Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-363) Replace numerical compression codes in config with something human readable David Arthur (JIRA)
  • [jira] [Updated] (KAFKA-363) Replace numerical compression codes in config with something human readable David Arthur (JIRA)
  • [jira] [Commented] (KAFKA-363) Replace numerical compression codes in config with something human readable Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-363) Replace numerical compression codes in config with something human readable Joel Koshy (JIRA)
  • [jira] [Closed] (KAFKA-363) Replace numerical compression codes in config with something human readable Joel Koshy (JIRA)
• [jira] [Commented] (KAFKA-335) Implement an embedded controller Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-335) Implement an embedded controller Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-335) Implement an embedded controller Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-335) Implement an embedded controller Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-335) Implement an embedded controller Jun Rao (JIRA)
• [jira] [Commented] (KAFKA-329) Remove the watches/broker for new topics and partitions and change create topic admin API to send start replica state change to all brokers Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-329) Remove the watches/broker for new topics and partitions and change create topic admin API to send start replica state change to all brokers Prashanth Menon (JIRA)
  • [jira] [Commented] (KAFKA-329) Remove the watches/broker for new topics and partitions and change create topic admin API to send start replica state change to all brokers Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-329) Remove the watches/broker for new topics and partitions and change create topic admin API to send start replica state change to all brokers Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-329) Remove the watches/broker for new topics and partitions and change create topic admin API to send start replica state change to all brokers Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-329) Remove the watches/broker for new topics and partitions and change create topic admin API to send start replica state change to all brokers Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-329) Remove the watches/broker for new topics and partitions and change create topic admin API to send start replica state change to all brokers Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-329) Remove the watches/broker for new topics and partitions and change create topic admin API to send start replica state change to all brokers Prashanth Menon (JIRA)
• [jira] [Updated] (KAFKA-335) Implement an embedded controller Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-335) Implement an embedded controller Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-335) Implement an embedded controller Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-335) Implement an embedded controller Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-335) Implement an embedded controller Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-335) Implement an embedded controller Yang Ye (JIRA)
• [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • Re: [jira] Subscription: outstanding kafka patches Joe Stein
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
  • [jira] Subscription: outstanding kafka patches jira
• [jira] [Commented] (KAFKA-341) Create a new single host system test to validate all replicas on 0.8 branch Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-341) Create a new single host system test to validate all replicas on 0.8 branch Joel Koshy (JIRA)
  • [jira] [Commented] (KAFKA-341) Create a new single host system test to validate all replicas on 0.8 branch Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-341) Create a new single host system test to validate all replicas on 0.8 branch John Fung (JIRA)
  • [jira] [Commented] (KAFKA-341) Create a new single host system test to validate all replicas on 0.8 branch Jun Rao (JIRA)
• Emeritus Committer status Chris Burroughs
  • Re: Emeritus Committer status Jay Kreps
  • Re: Emeritus Committer status Alan D. Cabrera
• Re: [DISCUSS] Graduate from incubator? Chris Burroughs
  • Re: [DISCUSS] Graduate from incubator? Jay Kreps
  • Re: [DISCUSS] Graduate from incubator? Joel Koshy
  • Re: [DISCUSS] Graduate from incubator? Neha Narkhede
  • Re: [DISCUSS] Graduate from incubator? Jun Rao
  • Re: [DISCUSS] Graduate from incubator? Joe Stein
  • Re: [DISCUSS] Graduate from incubator? Jay Kreps
  • Re: [DISCUSS] Graduate from incubator? Chris Douglas
  • Re: [DISCUSS] Graduate from incubator? Alan D. Cabrera
• [jira] [Updated] (KAFKA-336) add an admin RPC to communicate state changes between the controller and the broker Jun Rao (JIRA)
• [jira] [Resolved] (KAFKA-349) Create individual "Response" types for each kind of request and wrap them with "BoundedByteBufferSend", remove "xxResponseSend" types for all requests except "FetchRequest" Jun Rao (JIRA)
• [jira] [Updated] (KAFKA-349) Create individual "Response" types for each kind of request and wrap them with "BoundedByteBufferSend", remove "xxResponseSend" types for all requests except "FetchRequest" Yang Ye (JIRA)
• [jira] [Commented] (KAFKA-349) Create individual "Response" types for each kind of request and wrap them with "BoundedByteBufferSend", remove "xxResponseSend" types for all requests except "FetchRequest" Jun Rao (JIRA)
• Re: Kafka user group meeting Taylor Gautier
  • Re: Kafka user group meeting Evan Chan
  • Re: Kafka user group meeting Jun Rao
  • Re: Kafka user group meeting Jun Rao
  • Re: Kafka user group meeting Sam William
  • Re: Kafka user group meeting chetan conikee
  • Re: Kafka user group meeting Jun Rao

• Later messages