kafka-users
Thread
Date
Earlier messages
Messages by Thread
Re: no partition leader yet for partition 0 (0.8.0)
Jun Rao
Multi-threaded consumer question
Bob Jervis
Re: tcp tuning
Jay Kreps
zkclient-20120522.jar?
Bae, Jae Hyeon
Re: zkclient-20120522.jar?
Chris Curtin
0.8.0 producer can't connect to cluster?
Chris Curtin
Re: 0.8.0 producer can't connect to cluster?
Jun Rao
Re: 0.8.0 producer can't connect to cluster?
Chris Curtin
Re: 0.8.0 producer can't connect to cluster?
Jun Rao
Re: 0.8.0 producer can't connect to cluster?
Chris Curtin
Re: 0.8.0 producer can't connect to cluster?
Jay Kreps
Re: 0.8.0 producer can't connect to cluster?
Jason Rosenberg
Re: 0.8.0 producer can't connect to cluster?
Jay Kreps
Re: 0.8.0 producer can't connect to cluster?
Chris Curtin
Re: 0.8.0 producer can't connect to cluster?
Chris Curtin
Re: 0.8.0 producer can't connect to cluster?
Chris Curtin
0.8 dependencies (and maven)
Jason Rosenberg
Re: 0.8 dependencies (and maven)
Otis Gospodnetic
Re: 0.8 dependencies (and maven)
Jason Rosenberg
Re: 0.8 dependencies (and maven)
Joel Koshy
producer queue size
Jamie Wang
Re: producer queue size
Joel Koshy
Re: producer queue size
Neha Narkhede
Re: producer queue size
Jay Kreps
Kafka 0.8 trial version
Jun Rao
Re: Kafka 0.8 trial version
Hisham Mardam-Bey
Re: Kafka 0.8 trial version
Chris Curtin
Re: Kafka 0.8 trial version
Jason Rosenberg
Re: Kafka 0.8 trial version
Neha Narkhede
Re: understanding partitions based on wiki example of profile visits
Jay Kreps
Reading "first available" offset for the partition?
Radek Gruchalski
Re: Reading "first available" offset for the partition?
Joel Koshy
Re: Reading "first available" offset for the partition?
Radek Gruchalski
0.8 producer -- many questions
ben fleis
Re: 0.8 producer -- many questions
Jun Rao
Re: 0.8 producer -- many questions
Jason Rosenberg
Re: 0.8 producer -- many questions
ben fleis
Re: 0.8 producer -- many questions
Joel Koshy
Re: What should do after ConsumerConnector.createMessageStreams throws exception
Neha Narkhede
Re: What should do after ConsumerConnector.createMessageStreams throws exception
sun liwei
Re: What should do after ConsumerConnector.createMessageStreams throws exception
Jun Rao
changing number of partitions
Paul Garner
Re: changing number of partitions
Neha Narkhede
changing config of running server
Paul Garner
Re: changing config of running server
Neha Narkhede
compression on by default?
Paul Garner
Re: compression on by default?
Neha Narkhede
Re: compression on by default?
Paul Garner
Re: compression on by default?
Jun Rao
Re: compression on by default?
Paul Garner
dumb question about offsets
Paul Garner
Re: dumb question about offsets
Neha Narkhede
Re: dumb question about offsets
Paul Garner
Re: dumb question about offsets
Neha Narkhede
Re: dumb question about offsets
Philip O'Toole
Re: dumb question about offsets
Jay Kreps
Fwd: ASF Board Meeting Summary - November 21, 2012
Jay Kreps
Re: ASF Board Meeting Summary - November 21, 2012
Prashanth Menon
Re: ASF Board Meeting Summary - November 21, 2012
David Arthur
Re: ASF Board Meeting Summary - November 21, 2012
chetan conikee
Thread Safety of KafkaStreams
David Ross
Re: Thread Safety of KafkaStreams
Neha Narkhede
Re: Thread Safety of KafkaStreams
David Arthur
Re: Thread Safety of KafkaStreams
David Ross
Re: Thread Safety of KafkaStreams
Jay Kreps
Kafka + Maven
Chris Riccomini
Re: Kafka + Maven
Evan Chan
Re: Kafka + Maven
Roman Garcia
Re: Kafka + Maven
Matthew Rathbone
Re: Kafka + Maven
David Arthur
Re: Kafka + Maven
Brian O'Neill
Re: Kafka + Maven
Otis Gospodnetic
Re: Kafka + Maven
Otis Gospodnetic
Re: Kafka + Maven
Jason Rosenberg
Re: Kafka + Maven
Pierre-Yves Ritschard
Re: Kafka + Maven
Jason Rosenberg
Re: Kafka + Maven
Jay Kreps
Re: Kafka + Maven
Evan Chan
Re: Kafka + Maven
Alan Cabrera
Re: Kafka + Maven
Jun Rao
Newbie question
Jamie Wang
Re: Newbie question
David Arthur
Newbie question
Jamie Wang
Re: Newbie question
Jun Rao
accessing stats programmatically (instead of via jmx)
Jason Rosenberg
Re: accessing stats programmatically (instead of via jmx)
Jay Kreps
Re: accessing stats programmatically (instead of via jmx)
Jason Rosenberg
Re: accessing stats programmatically (instead of via jmx)
Joel Koshy
some healthy broker disappear from zookeeper
Xiaoyu Wang
Re: some healthy broker disappear from zookeeper
Neha Narkhede
createMessageStreamsByFilter unexpected behaviour
Michal Haris
Re: createMessageStreamsByFilter unexpected behaviour
Jun Rao
Re: createMessageStreamsByFilter unexpected behaviour
Michal Haris
Re: Kafka Broker Configuration Tuning and Repartitioning topic
Jun Rao
Re: Kafka Broker Configuration Tuning and Repartitioning topic
Muthukumar
Re: Kafka Broker Configuration Tuning and Repartitioning topic
Neha Narkhede
Re: Kafka Broker Configuration Tuning and Repartitioning topic
Muthukumar
Re: Kafka Broker Configuration Tuning and Repartitioning topic
Jay Kreps
Understanding how to monitor using JMX attributes
Mike Heffner
Re: Understanding how to monitor using JMX attributes
Jun Rao
Re: Understanding how to monitor using JMX attributes
Mike Heffner
Re: Understanding how to monitor using JMX attributes
Evan Chan
Re: Understanding how to monitor using JMX attributes
Mike Heffner
Re: Understanding how to monitor using JMX attributes
Jun Rao
Re: Understanding how to monitor using JMX attributes
Mike Heffner
Re: Understanding how to monitor using JMX attributes
Jun Rao
Re: Understanding how to monitor using JMX attributes
Mike Heffner
Re: Understanding how to monitor using JMX attributes
Joel Koshy
Re: Understanding how to monitor using JMX attributes
Mike Heffner
Re: Understanding how to monitor using JMX attributes
Joel Koshy
async producer behavior if zk and/or kafka cluster goes away...
Jason Rosenberg
Re: async producer behavior if zk and/or kafka cluster goes away...
Jason Rosenberg
Re: async producer behavior if zk and/or kafka cluster goes away...
Jay Kreps
Re: async producer behavior if zk and/or kafka cluster goes away...
Jason Rosenberg
Re: async producer behavior if zk and/or kafka cluster goes away...
Jay Kreps
Re: async producer behavior if zk and/or kafka cluster goes away...
Jason Rosenberg
Re: async producer behavior if zk and/or kafka cluster goes away...
Neha Narkhede
Re: async producer behavior if zk and/or kafka cluster goes away...
Jun Rao
Re: async producer behavior if zk and/or kafka cluster goes away...
Jason Rosenberg
Re: async producer behavior if zk and/or kafka cluster goes away...
Neha Narkhede
Re: async producer behavior if zk and/or kafka cluster goes away...
Jason Rosenberg
Re: async producer behavior if zk and/or kafka cluster goes away...
Jay Kreps
Re: async producer behavior if zk and/or kafka cluster goes away...
Jason Rosenberg
Re: async producer behavior if zk and/or kafka cluster goes away...
Neha Narkhede
Re: async producer behavior if zk and/or kafka cluster goes away...
Jun Rao
Re: async producer behavior if zk and/or kafka cluster goes away...
Jason Rosenberg
Re: async producer behavior if zk and/or kafka cluster goes away...
Neha Narkhede
Keeping track of offsets
David Arthur
Re: Keeping track of offsets
Jay Kreps
Suggestion on ZkClient usage in Kafka
Bae, Jae Hyeon
RE: Suggestion on ZkClient usage in Kafka
Sybrandy, Casey
Re: Suggestion on ZkClient usage in Kafka
Jun Rao
Re: Suggestion on ZkClient usage in Kafka
Jason Rosenberg
Re: Suggestion on ZkClient usage in Kafka
Neha Narkhede
Re: Suggestion on ZkClient usage in Kafka
Jason Rosenberg
Re: Suggestion on ZkClient usage in Kafka
Jun Rao
Re: Suggestion on ZkClient usage in Kafka
David Arthur
Re: Suggestion on ZkClient usage in Kafka
Jason Rosenberg
Re: Suggestion on ZkClient usage in Kafka
Jun Rao
Re: Suggestion on ZkClient usage in Kafka
Jun Rao
Re: Suggestion on ZkClient usage in Kafka
Bae, Jae Hyeon
Re: Suggestion on ZkClient usage in Kafka
Neha Narkhede
Re: Suggestion on ZkClient usage in Kafka
David Arthur
Re: Suggestion on ZkClient usage in Kafka
Jun Rao
Why do we need reconnect with an interval?
Bae, Jae Hyeon
Re: Why do we need reconnect with an interval?
Neha Narkhede
Re: Why do we need reconnect with an interval?
Jun Rao
Re: Why do we need reconnect with an interval?
Bae, Jae Hyeon
Re: Why do we need reconnect with an interval?
Jun Rao
Re: Kafka on EC2
Joel Koshy
Re: Kafka on EC2
Bae, Jae Hyeon
Re: Kafka on EC2
Neha Narkhede
Re: Kafka on EC2
Bae, Jae Hyeon
Re: Kafka on EC2
David Arthur
Re: Kafka on EC2
Evan Chan
Re: Kafka on EC2
David Arthur
Re: Kafka on EC2
Matthew Rathbone
Re: Kafka on EC2
James A. Robinson
Re: Kafka on EC2
Matt Jones
Re: Kafka on EC2
Matthew Rathbone
Re: Kafka on EC2
Senthilvel Rangaswamy
too many duplicate messages
Mark Grabois
Re: too many duplicate messages
Mark Grabois
Re: too many duplicate messages
Joel Koshy
Re: too many duplicate messages
S Ahmed
Re: too many duplicate messages
Mark Grabois
Re: too many duplicate messages
Tom Brown
QueueFullException
Paul Mackles
Re: QueueFullException
Neha Narkhede
Re: QueueFullException
Paul Mackles
Re: QueueFullException
Joel Koshy
Re: QueueFullException
Paul Mackles
init.d scripts?
James A. Robinson
Re: init.d scripts?
Logan Hardy
Re: init.d scripts?
James A. Robinson
Would this work as a general solution for transactions in Kafka?
Tom Brown
Re: Would this work as a general solution for transactions in Kafka?
Rohit Prasad
Re: Would this work as a general solution for transactions in Kafka?
Tom Brown
Re: Would this work as a general solution for transactions in Kafka?
Jay Kreps
Re: Would this work as a general solution for transactions in Kafka?
Tom Brown
Re: Would this work as a general solution for transactions in Kafka?
Jay Kreps
Re: On SIGTERM and SIGKILL consumer ids in zookeeper do not always get cleared
Neha Narkhede
Re: On SIGTERM and SIGKILL consumer ids in zookeeper do not always get cleared
David Arthur
.NET Client
John Haigh
version of zookeeper
Jason Rosenberg
Re: version of zookeeper
David Arthur
Re: version of zookeeper
Jun Rao
Re: version of zookeeper
Neha Narkhede
Re: version of zookeeper
Jason Rosenberg
Re: version of zookeeper
Neha Narkhede
Re: version of zookeeper
Jason Rosenberg
Re: version of zookeeper
Neha Narkhede
Re: version of zookeeper
Jason Rosenberg
Invalid KafkaStreams as a result of Decoder problems
Bob Cotton
Re: Invalid KafkaStreams as a result of Decoder problems
Jason Rosenberg
Re: Invalid KafkaStreams as a result of Decoder problems
Bob Cotton
Re: Invalid KafkaStreams as a result of Decoder problems
Jun Rao
Re: Invalid KafkaStreams as a result of Decoder problems
Bob Cotton
Re: Invalid KafkaStreams as a result of Decoder problems
Neha Narkhede
Re: Invalid KafkaStreams as a result of Decoder problems
Jason Rosenberg
Earlier messages