kafka-users
Thread
Date
Earlier messages
Later messages
Messages by Thread
Re: Questions on consumerConnector.createMessageStreams()
Jun Rao
Re: Questions on consumerConnector.createMessageStreams()
Evan Chan
Re: Questions on consumerConnector.createMessageStreams()
Patricio Echagüe
Re: Questions on consumerConnector.createMessageStreams()
Evan Chan
Re: Questions on consumerConnector.createMessageStreams()
Jun Rao
Re: Questions on consumerConnector.createMessageStreams()
Neha Narkhede
Re: Questions on consumerConnector.createMessageStreams()
Evan Chan
Consumer iterator error
Patricio Echagüe
Re: Consumer iterator error
Neha Narkhede
Re: Consumer iterator error
Jun Rao
Re: Consumer iterator error
Patricio Echagüe
Re: Consumer iterator error
Patricio Echagüe
Re: Consumer iterator error
Neha Narkhede
Re: Consumer iterator error
Patricio Echagüe
Kafka managed by zookeeper
Tobias Schulze-Heinrichs
Re: Kafka managed by zookeeper
Neha Narkhede
Re: Kafka managed by zookeeper
Tobias Schulze-Heinrichs
Re: Kafka managed by zookeeper
Pierre-Yves Ritschard
Re: Kafka managed by zookeeper
Tobias Schulze-Heinrichs
Re: Kafka managed by zookeeper
Pierre-Yves Ritschard
Re: Kafka managed by zookeeper
Neha Narkhede
hardware configuration and specs
Irfan Mohammed
Re: hardware configuration and specs
Jun Rao
How to dequeue the last message again during failures
Patricio Echagüe
Re: How to dequeue the last message again during failures
Jun Rao
Re: How to dequeue the last message again during failures
Patricio Echagüe
Re: How to dequeue the last message again during failures
Jun Rao
Re: How to dequeue the last message again during failures
Patricio Echagüe
Re: How to dequeue the last message again during failures
Jun Rao
Re: How to dequeue the last message again during failures
Patricio Echagüe
Producer thread-safety and performance
Patricio Echagüe
Re: Producer thread-safety and performance
Jay Kreps
Re: Producer thread-safety and performance
Patricio Echagüe
Re: Producer thread-safety and performance
Neha Narkhede
skype meeting on replication roadmap
Jun Rao
Re: skype meeting on replication roadmap
Joe Stein
Re: skype meeting on replication roadmap
Jun Rao
Re: skype meeting on replication roadmap
Jun Rao
Re: skype meeting on replication roadmap
Joe Stein
Re: skype meeting on replication roadmap
Jun Rao
Re: skype meeting on replication roadmap
Chris Burroughs
Re: skype meeting on replication roadmap
Joe Stein
Re: skype meeting on replication roadmap
Joe Stein
Re: skype meeting on replication roadmap
Jeffrey Damick
Re: skype meeting on replication roadmap
Jun Rao
Re: skype meeting on replication roadmap
David Ormsbee
Re: skype meeting on replication roadmap
Joe Stein
RE: skype meeting on replication roadmap
Andrew Psaltis
Re: skype meeting on replication roadmap
Jun Rao
Re: skype meeting on replication roadmap
Prashanth Menon
Kafak-rb gem
Mark
Re: Kafak-rb gem
Tim Lossen
Re: Kafak-rb gem
Mark
Re: Kafak-rb gem
Dave Fayram
Re: Kafak-rb gem
Evan Chan
Re: Kafak-rb gem
Tim Lossen
[ANNOUNCE] Apache Kafka 0.7.0-incubating released
Neha Narkhede
Re: [ANNOUNCE] Apache Kafka 0.7.0-incubating released
Jay Kreps
SimpleConsumer woes
Joe Stein
Re: SimpleConsumer woes
Jun Rao
Re: SimpleConsumer woes
Joe Stein
Re: SimpleConsumer woes
Neha Narkhede
Re: SimpleConsumer woes
Jun Rao
Re: SimpleConsumer woes
Joe Stein
Introducing the newbie tag
Neha Narkhede
How to know how many messages not yet processed ?
Stone
Re: How to know how many messages not yet processed ?
Mark
Re: How to know how many messages not yet processed ?
Jun Rao
Replication Follow-up
Joe Stein
Re: Replication Follow-up
Matt Abrams
Re: Replication Follow-up
Joe Stein
Re: Replication Follow-up
Matt Abrams
Re: Replication Follow-up
Jun Rao
RE: Replication Follow-up
Andrew Psaltis
Re: Replication Follow-up
Jay Kreps
[RESULT] [VOTE] Release Kafka 0.7.0-incubating
Neha Narkhede
Race when broker reconnects to zk?
Dan Brown
Re: Race when broker reconnects to zk?
Jun Rao
[0.6] Consumer API Question - What if a ConsumerIterator has an error?
David Ross
Re: [0.6] Consumer API Question - What if a ConsumerIterator has an error?
Neha Narkhede
Re: [0.6] Consumer API Question - What if a ConsumerIterator has an error?
David Ross
Re: [0.6] Consumer API Question - What if a ConsumerIterator has an error?
Neha Narkhede
random questions
S Ahmed
Re: random questions
Jun Rao
any message size restrictions? suggest range?
S Ahmed
Re: any message size restrictions? suggest range?
Neha Narkhede
Re: any message size restrictions? suggest range?
S Ahmed
Re: any message size restrictions? suggest range?
Neha Narkhede
FetctherRunnable stopping after some ZK disconnect expirations
Joe Stein
Re: FetctherRunnable stopping after some ZK disconnect expirations
Neha Narkhede
Re: FetctherRunnable stopping after some ZK disconnect expirations
Joe Stein
Re: FetctherRunnable stopping after some ZK disconnect expirations
Neha Narkhede
Passing through a firewall
kafka
[VOTE] Release Kafka 0.7.0-incubating (candidate 9)
Neha Narkhede
Re: [VOTE] Release Kafka 0.7.0-incubating (candidate 9)
Jakob Homan
Re: [VOTE] Release Kafka 0.7.0-incubating (candidate 9)
Jay Kreps
Re: [VOTE] Release Kafka 0.7.0-incubating (candidate 9)
Jun Rao
Re: [VOTE] Release Kafka 0.7.0-incubating (candidate 9)
Alan D. Cabrera
Re: [VOTE] Release Kafka 0.7.0-incubating (candidate 9)
Neha Narkhede
Re: [VOTE] Release Kafka 0.7.0-incubating (candidate 9)
Alan D. Cabrera
.6 License
Bateman, Matt
Re: .6 License
Jun Rao
RE: .6 License
Bateman, Matt
Re: .6 License
Jun Rao
RE: .6 License
Bateman, Matt
Ruby or Python App -> Kafka -> S3
Russell Jurney
Re: Ruby or Python App -> Kafka -> S3
Jun Rao
Re: Ruby or Python App -> Kafka -> S3
Russell Jurney
Re: Ruby or Python App -> Kafka -> S3
Neha Narkhede
[VOTE] Release Kafka 0.7.0 incubating candidate 8
Neha Narkhede
Re: [VOTE] Release Kafka 0.7.0 incubating candidate 8
Jun Rao
Re: [VOTE] Release Kafka 0.7.0 incubating candidate 8
Chris Douglas
Re: [VOTE] Release Kafka 0.7.0 incubating candidate 8
Jakob Homan
Re: [VOTE] Release Kafka 0.7.0 incubating candidate 8
Neha Narkhede
Retrieving unprocessed messages and exiting
Sybrandy, Casey
Re: Retrieving unprocessed messages and exiting
Jun Rao
RE: Retrieving unprocessed messages and exiting
Sybrandy, Casey
Quickstart Problem re: Zookeeper
Russell Jurney
Re: Quickstart Problem re: Zookeeper
Russell Jurney
Re: Quickstart Problem re: Zookeeper
Jun Rao
maven references
Peter Thygesen
Re: maven references
Jun Rao
Re: maven references
Peter Thygesen
Re: maven references
Jun Rao
Producer Performance Test Mesage Count Mismatch
Andrew Psaltis
Re: Producer Performance Test Mesage Count Mismatch
Jay Kreps
Kafak Mirroring Questions
Carey, Lynda
Re: Kafak Mirroring Questions
Jun Rao
Re: Kafak Mirroring Questions
Olivier Pomel
Re: Kafak Mirroring Questions
Jay Kreps
RE: Kafak Mirroring Questions
Carey, Lynda
Re: Kafak Mirroring Questions
Neha Narkhede
Re: Kafak Mirroring Questions
Tim Lossen
Errors in load tests
Florian Leibert
Re: Errors in load tests
Florian Leibert
Re: Errors in load tests
Florian Leibert
Re: Errors in load tests
Neha Narkhede
Re: Errors in load tests
Florian Leibert
Re: Errors in load tests
Neha Narkhede
Re: Errors in load tests
Jun Rao
Re: Errors in load tests
David Ormsbee
Re: Errors in load tests
Jay Kreps
Re: Errors in load tests
Florian Leibert
Re: Errors in load tests
Florian Leibert
Re: Errors in load tests
David Ormsbee
Re: Errors in load tests
David Ormsbee
Multiple brokers on the same host
Florian Leibert
Re: Multiple brokers on the same host
David Ormsbee
Re: Multiple brokers on the same host
Florian Leibert
Re: Multiple brokers on the same host
Florian Leibert
Re: Multiple brokers on the same host
Florian Leibert
Broker ID
Florian Leibert
Re: Broker ID
Jun Rao
Re: Broker ID
Florian Leibert
Re: Broker ID
Jay Kreps
Re: Broker ID
Chris Burroughs
Re: Broker ID
Jay Kreps
Re: Broker ID
Neha Narkhede
Re: Broker ID
Jay Kreps
Re: Broker ID
Neha Narkhede
Clients
Mark
Re: Clients
Jun Rao
Re: Clients
Mark
Re: Clients
Jun Rao
Re: Clients
David Ormsbee
Re: Clients
Mark
Re: Clients
David Ormsbee
Exactly once semantics
Mark
Re: Exactly once semantics
Jun Rao
Re: Exactly once semantics
Mark
Re: Exactly once semantics
Jun Rao
Re: Exactly once semantics
Neha Narkhede
Re: Exactly once semantics
Jun Rao
Re: Exactly once semantics
Evan Chan
Re: Exactly once semantics
Neha Narkhede
Re: Exactly once semantics
Hisham Mardam-Bey
Re: Exactly once semantics
Neha Narkhede
Re: Exactly once semantics
Hisham Mardam-Bey
How to use compression & more docs needed
Stone
Re: How to use compression & more docs needed
Neha Narkhede
Re: How to use compression & more docs needed
Stone
Compression
Inder Pall
Re: Compression
Neha Narkhede
Re: Compression
Inder Pall
Re: Compression
Neha Narkhede
Re: Compression
Inder Pall
Timestamps
Mark
Re: Timestamps
Neha Narkhede
Re: Timestamps
Evan Chan
Re: Timestamps
Neha Narkhede
Re: Timestamps
David Ormsbee
General Messaging Systems
Mark
Re: General Messaging Systems
Jun Rao
Kafka is live in prod @ 100%
Taylor Gautier
Re: Kafka is live in prod @ 100%
Hisham Mardam-Bey
broker is already registered - fatal on startup
Hisham Mardam-Bey
Re: broker is already registered - fatal on startup
Hisham Mardam-Bey
Re: broker is already registered - fatal on startup
Jun Rao
Re: broker is already registered - fatal on startup
Hisham Mardam-Bey
0mq
Mark
Earlier messages
Later messages