kafka-dev
Thread
Date
Later messages
Messages by Date
2012/06/21
Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 3)
Alan D. Cabrera
2012/06/21
[jira] [Assigned] (KAFKA-338) controller failover
Prashanth Menon (JIRA)
2012/06/21
[jira] [Commented] (KAFKA-342) revisit the broker startup procedure according to V3 design
Prashanth Menon (JIRA)
2012/06/21
[jira] [Commented] (KAFKA-342) revisit the broker startup procedure according to V3 design
Jun Rao (JIRA)
2012/06/21
Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 3)
Jun Rao
2012/06/21
[jira] [Commented] (KAFKA-342) revisit the broker startup procedure according to V3 design
Prashanth Menon (JIRA)
2012/06/21
Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 3)
Chris Douglas
2012/06/21
Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 3)
Alan D. Cabrera
2012/06/21
Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 3)
Joe Stein
2012/06/21
[jira] Subscription: outstanding kafka patches
jira
2012/06/21
Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 3)
Chris Douglas
2012/06/21
[jira] [Created] (KAFKA-372) Consumer doesn't receive all data if there are multiple segment files
John Fung (JIRA)
2012/06/21
[jira] [Updated] (KAFKA-306) broker failure system test broken on replication branch
John Fung (JIRA)
2012/06/20
Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 3)
Alan D. Cabrera
2012/06/20
Kafka 0.7.1-incubating - old candidates
Alan D. Cabrera
2012/06/20
[jira] [Created] (KAFKA-371) Creating topic of empty string puts broker in a bad state
Martin Kleppmann (JIRA)
2012/06/20
[jira] [Updated] (KAFKA-313) Add JSON output and looping options to ConsumerOffsetChecker
Joel Koshy (JIRA)
2012/06/20
[jira] [Updated] (KAFKA-306) broker failure system test broken on replication branch
John Fung (JIRA)
2012/06/20
Re: Build emails
Neha Narkhede
2012/06/20
[jira] [Commented] (KAFKA-339) using MultiFetch in the follower
Neha Narkhede (JIRA)
2012/06/20
[jira] [Commented] (KAFKA-339) using MultiFetch in the follower
Joel Koshy (JIRA)
2012/06/20
[jira] [Updated] (KAFKA-370) Exception "java.util.NoSuchElementException: None.get" appears inconsistently in Mirror Maker log.
John Fung (JIRA)
2012/06/20
[jira] [Created] (KAFKA-370) Exception "java.util.NoSuchElementException: None.get" appears inconsistently in Mirror Maker log.
John Fung (JIRA)
2012/06/20
[jira] [Commented] (KAFKA-306) broker failure system test broken on replication branch
Jun Rao (JIRA)
2012/06/20
[VOTE] Release Kafka 0.7.1-incubating (Candidate 3)
Joe Stein
2012/06/20
[jira] [Updated] (KAFKA-306) broker failure system test broken on replication branch
John Fung (JIRA)
2012/06/20
[jira] [Updated] (KAFKA-296) Update Go Client to new version of Go
Joe Stein (JIRA)
2012/06/20
[jira] [Updated] (KAFKA-264) Change the consumer side load balancing and distributed co-ordination to use a consumer co-ordinator
Joe Stein (JIRA)
2012/06/20
[jira] [Updated] (KAFKA-215) Improve system tests for the mirroring code
Joe Stein (JIRA)
2012/06/20
[jira] [Updated] (KAFKA-316) disallow recursively compressed message
Joe Stein (JIRA)
2012/06/20
[jira] [Updated] (KAFKA-258) Remove broker.id from the broker.list config in the Producer
Joe Stein (JIRA)
2012/06/20
[jira] [Updated] (KAFKA-368) use the pig core jar from maven instead of distributing it
Joe Stein (JIRA)
2012/06/20
Re: Consumer re-design proposal
Ross Black
2012/06/20
Re: Build emails
Prashanth Menon
2012/06/20
Re: Build emails
Joe Stein
2012/06/20
[jira] [Comment Edited] (KAFKA-364) Consumer re-design
Ross Black (JIRA)
2012/06/20
[jira] [Commented] (KAFKA-364) Consumer re-design
Ross Black (JIRA)
2012/06/20
Re: remaining jars in svn (was Fwd: Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 2))
Joe Stein
2012/06/20
[jira] [Commented] (KAFKA-364) Consumer re-design
Ross Black (JIRA)
2012/06/20
Re: Consumer re-design proposal
Dave Barr
2012/06/19
[jira] [Created] (KAFKA-369) remove ZK dependency on producer
Jun Rao (JIRA)
2012/06/19
[jira] [Updated] (KAFKA-337) upgrade ZKClient to allow conditional updates in ZK
Jun Rao (JIRA)
2012/06/19
[jira] [Updated] (KAFKA-339) using MultiFetch in the follower
Jun Rao (JIRA)
2012/06/19
Re: remaining jars in svn (was Fwd: Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 2))
Neha Narkhede
2012/06/19
[jira] [Commented] (KAFKA-368) use the pig core jar from maven instead of distributing it
Neha Narkhede (JIRA)
2012/06/19
[jira] [Commented] (KAFKA-339) using MultiFetch in the follower
Joel Koshy (JIRA)
2012/06/19
[jira] [Commented] (KAFKA-368) use the pig core jar from maven instead of distributing it
Jun Rao (JIRA)
2012/06/19
Re: remaining jars in svn (was Fwd: Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 2))
Joe Stein
2012/06/19
Re: Consumer re-design proposal
Neha Narkhede
2012/06/19
[jira] [Updated] (KAFKA-368) use the pig core jar from maven instead of distributing it
Joe Stein (JIRA)
2012/06/19
[jira] [Updated] (KAFKA-368) use the pig core jar from maven instead of distributing it
Joe Stein (JIRA)
2012/06/19
[jira] [Created] (KAFKA-368) use the pig core jar from maven instead of distributing it
Joe Stein (JIRA)
2012/06/19
Re: remaining jars in svn (was Fwd: Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 2))
Jun Rao
2012/06/19
[jira] [Commented] (KAFKA-366) add jmx beans in broker to track # bytes in consumer
Joe Stein (JIRA)
2012/06/18
Re: Build emails
Jay Kreps
2012/06/18
Re: remaining jars in svn (was Fwd: Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 2))
Joe Stein
2012/06/18
[jira] [Created] (KAFKA-367) StringEncoder/StringDecoder use platform default character set
Jay Kreps (JIRA)
2012/06/18
Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 2)
Joe Stein
2012/06/18
Fwd: [VOTE] Release Kafka 0.7.1-incubating (Candidate 2)
Jun Rao
2012/06/18
[jira] [Commented] (KAFKA-266) Kafka web console design
Evan Chan (JIRA)
2012/06/18
rm old RC tags
Chris Burroughs
2012/06/18
remaining jars in svn (was Fwd: Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 2))
Chris Burroughs
2012/06/18
Build emails
Chris Burroughs
2012/06/18
Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 2)
Chris Burroughs
2012/06/18
Re: Consumer re-design proposal
Chris Burroughs
2012/06/18
Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 2)
Jun Rao
2012/06/18
Re: video recording for the 1st Kafka user group meeting
Chris Burroughs
2012/06/18
Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 2)
Joe Stein
2012/06/18
Re: Solution for blocking fsync in 0.8
Chris Burroughs
2012/06/18
[jira] [Updated] (KAFKA-366) add jmx beans in broker to track # bytes in consumer
Jun Rao (JIRA)
2012/06/18
[jira] [Commented] (KAFKA-366) add jmx beans in broker to track # bytes in consumer
Joel Koshy (JIRA)
2012/06/18
[jira] [Assigned] (KAFKA-343) revisit the become leader and become follower state change operations using V3 design
Yang Ye (JIRA)
2012/06/18
Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 2)
Kevan Miller
2012/06/18
[jira] [Assigned] (KAFKA-366) add jmx beans in broker to track # bytes in consumer
Jun Rao (JIRA)
2012/06/18
[jira] [Updated] (KAFKA-366) add jmx beans in broker to track # bytes in consumer
Jun Rao (JIRA)
2012/06/18
[jira] [Updated] (KAFKA-366) add jmx beans in broker to track # bytes in consumer
Jun Rao (JIRA)
2012/06/18
[jira] [Created] (KAFKA-366) add jmx beans in broker to track # bytes in consumer
Jun Rao (JIRA)
2012/06/18
RE: Consumer re-design proposal
Sybrandy, Casey
2012/06/18
[jira] Subscription: outstanding kafka patches
jira
2012/06/18
Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 2)
Joel Koshy
2012/06/18
Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 2)
Jun Rao
2012/06/17
[jira] [Resolved] (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)
2012/06/17
[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)
2012/06/17
[jira] [Updated] (KAFKA-348) rebase 0.8 branch from trunk
Anonymous (JIRA)
2012/06/17
[jira] [Updated] (KAFKA-348) rebase 0.8 branch from trunk
Joe Stein (JIRA)
2012/06/16
[jira] [Reopened] (KAFKA-348) rebase 0.8 branch from trunk
Jun Rao (JIRA)
2012/06/16
[jira] [Updated] (KAFKA-348) rebase 0.8 branch from trunk
Jun Rao (JIRA)
2012/06/16
Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 2)
Jun Rao
2012/06/15
Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 2)
Jun Rao
2012/06/15
[jira] [Updated] (KAFKA-339) using MultiFetch in the follower
Jun Rao (JIRA)
2012/06/15
[jira] [Updated] (KAFKA-339) using MultiFetch in the follower
Jun Rao (JIRA)
2012/06/15
Re: Replication status
Neha Narkhede
2012/06/15
Re: Replication status
Joe Stein
2012/06/15
Replication status
Neha Narkhede
2012/06/15
[jira] [Work started] (KAFKA-350) Improve the high water mark maintenance to store high watermarks for all partitions in a single file on disk
Neha Narkhede (JIRA)
2012/06/15
[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)
2012/06/15
video recording for the 1st Kafka user group meeting
Jun Rao
2012/06/14
Re: Consumer re-design proposal
Neha Narkhede
2012/06/14
[jira] [Commented] (KAFKA-364) Consumer re-design
Neha Narkhede (JIRA)
2012/06/14
[jira] [Commented] (KAFKA-364) Consumer re-design
Neha Narkhede (JIRA)
2012/06/14
Re: Consumer re-design proposal
Marcos Juarez
2012/06/14
Re: Consumer re-design proposal
Evan Chan
2012/06/14
[jira] Subscription: outstanding kafka patches
jira
2012/06/14
[VOTE] Release Kafka 0.7.1-incubating (Candidate 2)
Joe Stein
2012/06/14
[jira] [Commented] (KAFKA-134) Upgrade Kafka to sbt 0.10.1
Jay Kreps (JIRA)
2012/06/14
[jira] [Updated] (KAFKA-365) change copyright in NOTICE to 2012
Joe Stein (JIRA)
2012/06/14
[jira] [Commented] (KAFKA-365) change copyright in NOTICE to 2012
Jun Rao (JIRA)
2012/06/14
[jira] [Updated] (KAFKA-365) change copyright in NOTICE to 2012
Joe Stein (JIRA)
2012/06/14
[jira] [Updated] (KAFKA-365) change copyright in NOTICE to 2012
Joe Stein (JIRA)
2012/06/14
Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 1)
Joe Stein
2012/06/14
[jira] [Created] (KAFKA-365) change copyright in NOTICE to 2012
Joe Stein (JIRA)
2012/06/14
Re: [VOTE] Release Kafka 0.7.1-incubating (Candidate 1)
sebb
2012/06/14
[VOTE] Release Kafka 0.7.1-incubating (Candidate 1)
Joe Stein
2012/06/14
[jira] [Updated] (KAFKA-341) Create a new single host system test to validate all replicas on 0.8 branch
Jun Rao (JIRA)
2012/06/14
Re: Consumer re-design proposal
Jun Rao
2012/06/14
[jira] [Resolved] (KAFKA-198) Avoid duplicated message during consumer rebalance
Joe Stein (JIRA)
2012/06/14
Re: [jira] Subscription: outstanding kafka patches
Joe Stein
2012/06/14
[jira] [Resolved] (KAFKA-335) Implement an embedded controller
Jun Rao (JIRA)
2012/06/14
[jira] [Commented] (KAFKA-134) Upgrade Kafka to sbt 0.10.1
Chris Birchall (JIRA)
2012/06/13
Re: [DISCUSSION] KAFKA 0.7.1 RELEASE
Jun Rao
2012/06/13
Re: [DISCUSSION] KAFKA 0.7.1 RELEASE
Joe Stein
2012/06/13
[jira] [Updated] (KAFKA-335) Implement an embedded controller
Yang Ye (JIRA)
2012/06/13
[jira] [Commented] (KAFKA-335) Implement an embedded controller
Jun Rao (JIRA)
2012/06/13
[jira] [Updated] (KAFKA-341) Create a new single host system test to validate all replicas on 0.8 branch
John Fung (JIRA)
2012/06/13
[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)
2012/06/13
[jira] [Updated] (KAFKA-335) Implement an embedded controller
Yang Ye (JIRA)
2012/06/13
[jira] [Updated] (KAFKA-335) Implement an embedded controller
Yang Ye (JIRA)
2012/06/13
[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)
2012/06/13
[jira] [Commented] (KAFKA-335) Implement an embedded controller
Jun Rao (JIRA)
2012/06/12
[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)
2012/06/12
hierarchical topics
Jay Kreps
2012/06/12
[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)
2012/06/12
[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)
2012/06/12
[jira] [Updated] (KAFKA-335) Implement an embedded controller
Yang Ye (JIRA)
2012/06/12
[jira] [Commented] (KAFKA-341) Create a new single host system test to validate all replicas on 0.8 branch
Jun Rao (JIRA)
2012/06/12
[jira] [Commented] (KAFKA-341) Create a new single host system test to validate all replicas on 0.8 branch
John Fung (JIRA)
2012/06/12
[jira] [Updated] (KAFKA-341) Create a new single host system test to validate all replicas on 0.8 branch
John Fung (JIRA)
2012/06/12
[jira] [Updated] (KAFKA-341) Create a new single host system test to validate all replicas on 0.8 branch
John Fung (JIRA)
2012/06/12
Re: Consumer re-design proposal
Jay Kreps
2012/06/12
[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)
2012/06/12
[jira] [Commented] (KAFKA-306) broker failure system test broken on replication branch
Jun Rao (JIRA)
2012/06/12
[jira] [Commented] (KAFKA-341) Create a new single host system test to validate all replicas on 0.8 branch
Jun Rao (JIRA)
2012/06/12
[jira] [Commented] (KAFKA-335) Implement an embedded controller
Jun Rao (JIRA)
2012/06/12
[jira] [Commented] (KAFKA-335) Implement an embedded controller
Jun Rao (JIRA)
2012/06/11
[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)
2012/06/11
[jira] [Updated] (KAFKA-168) Support locality in consumer partition assignment algorithm
Neha Narkhede (JIRA)
2012/06/11
[jira] [Updated] (KAFKA-170) Support for non-blocking polling on multiple streams
Neha Narkhede (JIRA)
2012/06/11
[jira] [Updated] (KAFKA-183) Expose offset vector to the consumer
Neha Narkhede (JIRA)
2012/06/11
[jira] [Updated] (KAFKA-361) Add ability to get offsets from ZK-based consumer
Neha Narkhede (JIRA)
2012/06/11
[jira] [Updated] (KAFKA-360) Add ability to disable rebalancing in ZooKeeper consumer
Neha Narkhede (JIRA)
2012/06/11
Consumer re-design proposal
Neha Narkhede
2012/06/11
[jira] [Created] (KAFKA-364) Consumer re-design
Neha Narkhede (JIRA)
2012/06/11
[jira] [Updated] (KAFKA-335) Implement an embedded controller
Yang Ye (JIRA)
2012/06/11
[jira] [Comment Edited] (KAFKA-341) Create a new single host system test to validate all replicas on 0.8 branch
John Fung (JIRA)
2012/06/11
[jira] [Updated] (KAFKA-341) Create a new single host system test to validate all replicas on 0.8 branch
John Fung (JIRA)
2012/06/11
[jira] Subscription: outstanding kafka patches
jira
2012/06/11
[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)
2012/06/11
Re: [DISCUSSION] KAFKA 0.7.1 RELEASE
Jun Rao
2012/06/11
[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)
2012/06/11
[DISCUSSION] KAFKA 0.7.1 RELEASE
Joe Stein
2012/06/11
Re: Emeritus Committer status
Alan D. Cabrera
2012/06/10
[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)
2012/06/10
[jira] [Resolved] (KAFKA-44) Various ZK listeners to support intra-cluster replication
Neha Narkhede (JIRA)
2012/06/10
[jira] [Resolved] (KAFKA-302) Implement the become leader and become follower state change operations
Neha Narkhede (JIRA)
2012/06/10
[jira] [Resolved] (KAFKA-45) Broker startup, leader election, becoming a leader/follower for intra-cluster replication
Neha Narkhede (JIRA)
2012/06/09
Re: wiki describing code path for major components
Jay Kreps
2012/06/09
RE: wiki describing code path for major components
Guozhang Wang
2012/06/08
kafka replication status
Jun Rao
2012/06/08
Re: wiki describing code path for major components
Jay Kreps
2012/06/08
Re: Kafka user group meeting
Jun Rao
2012/06/08
[jira] [Reopened] (KAFKA-294) "Path length must be > 0" error during startup
Jay Kreps (JIRA)
2012/06/08
[jira] [Created] (KAFKA-363) Replace numerical compression codes in config with something human readable
Jay Kreps (JIRA)
2012/06/08
Re: Emeritus Committer status
Jay Kreps
2012/06/08
Re: [DISCUSS] Graduate from incubator?
Jay Kreps
2012/06/08
Re: [DISCUSS] Graduate from incubator?
Joe Stein
2012/06/08
[jira] [Commented] (KAFKA-335) Implement an embedded controller
Jun Rao (JIRA)
2012/06/08
Re: [DISCUSS] Graduate from incubator?
Jun Rao
2012/06/08
Re: Kafka user group meeting
chetan conikee
2012/06/08
Re: Kafka user group meeting
Sam William
2012/06/08
Re: Kafka user group meeting
Jun Rao
2012/06/08
[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)
2012/06/07
[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)
2012/06/07
[jira] [Updated] (KAFKA-335) Implement an embedded controller
Yang Ye (JIRA)
2012/06/07
[jira] Subscription: outstanding kafka patches
jira
2012/06/07
Re: [DISCUSS] Graduate from incubator?
Alan D. Cabrera
2012/06/06
Re: [DISCUSS] Graduate from incubator?
Chris Douglas
2012/06/06
Re: [DISCUSS] Graduate from incubator?
Neha Narkhede
2012/06/06
Re: [DISCUSS] Graduate from incubator?
Joel Koshy
2012/06/06
Re: [DISCUSS] Graduate from incubator?
Jay Kreps
2012/06/06
Re: Kafka user group meeting
Jun Rao
2012/06/06
[jira] [Commented] (KAFKA-341) Create a new single host system test to validate all replicas on 0.8 branch
Joel Koshy (JIRA)
2012/06/06
[jira] [Commented] (KAFKA-341) Create a new single host system test to validate all replicas on 0.8 branch
Jun Rao (JIRA)
2012/06/05
Emeritus Committer status
Chris Burroughs
2012/06/05
Re: [DISCUSS] Graduate from incubator?
Chris Burroughs
2012/06/05
[jira] [Updated] (KAFKA-336) add an admin RPC to communicate state changes between the controller and the broker
Jun Rao (JIRA)
2012/06/05
[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)
2012/06/05
[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)
2012/06/05
Re: Kafka user group meeting
Evan Chan
2012/06/05
[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)
2012/06/05
Re: Kafka user group meeting
Taylor Gautier
Later messages