kafka-users  

Messages by Thread

• Re: kafka internals -- and example client code Philip O'Toole
  • Re: kafka internals -- and example client code Jay Kreps
  • Re: kafka internals -- and example client code Philip O'Toole
  • Re: kafka internals -- and example client code Ming Han
• a problem with producer(it block for some minutes) zlai_2001
  • Re: a problem with producer(it block for some minutes) Jun Rao
  • Re: Re: a problem with producer(it block for some minutes) zlai_2001
  • Re: Re: a problem with producer(it block for some minutes) Jun Rao
  • Re: Re: a problem with producer(it block for some minutes) zlai_2001
  • Re: Re: Re: a problem with producer(it block for some minutes) zlai_2001
  • Re: Re: Re: a problem with producer(it block for some minutes) zlai_2001
• kafka internals Ming Han
  • Re: kafka internals Pankaj Gupta
  • Re: kafka internals Jay Kreps
• consumer terminates, zk npe Mark Grabois
  • Re: consumer terminates, zk npe Jun Rao
• A consumer keeps stopping Ke Ren
  • Re: A consumer keeps stopping Patricio Echagüe
  • Re: A consumer keeps stopping Guy Doulberg
  • Re: A consumer keeps stopping Ke Ren
  • Re: A consumer keeps stopping Guy Doulberg
  • Re: A consumer keeps stopping Jun Rao
  • Re: A consumer keeps stopping Ke Ren
  • Re: A consumer keeps stopping Patricio Echagüe
  • Re: A consumer keeps stopping Jun Rao
  • Re: A consumer keeps stopping Ke Ren
• Re: dup consume group related info and rename to a new group ? Jun Rao
  • Re: dup consume group related info and rename to a new group ? Stone
• Re: How to minimize the number of message loss when broker goes down. Jun Rao
  • Re: How to minimize the number of message loss when broker goes down. Taylor Gautier
  • Re: How to minimize the number of message loss when broker goes down. Joe Stein
  • Re: How to minimize the number of message loss when broker goes down. Jun Rao
  • Re: How to minimize the number of message loss when broker goes down. Taylor Gautier
• GumGum's usage of Kafka and Storm Vaibhav Puranik
  • Re: GumGum's usage of Kafka and Storm Jun Rao
  • Re: GumGum's usage of Kafka and Storm Vaibhav Puranik
  • Re: GumGum's usage of Kafka and Storm Something Something
  • Re: GumGum's usage of Kafka and Storm Something Something
• Re: Kafka version Jun Rao
• Re: Maven? Joe Stein
  • Re: Maven? Something Something
• RE: Kafka version 0.7.0 and 7.0.1 failed to build Ball, Ronald
  • Re: Kafka version 0.7.0 and 7.0.1 failed to build Neha Narkhede
• 0.8 idle CPU usage? Sam Meder
  • Re: 0.8 idle CPU usage? Jay Kreps
  • Re: 0.8 idle CPU usage? Sam Meder
  • Re: 0.8 idle CPU usage? Jay Kreps
  • Re: 0.8 idle CPU usage? Sam Meder
  • Re: 0.8 idle CPU usage? Jay Kreps
• 7.1 support for List<ProducerData> will martin
  • Re: 7.1 support for List<ProducerData> Neha Narkhede
  • Re: 7.1 support for List<ProducerData> will martin
  • Re: 7.1 support for List<ProducerData> Felix GV
  • Re: 7.1 support for List<ProducerData> will martin
  • Re: 7.1 support for List<ProducerData> Felix GV
  • Re: 7.1 support for List<ProducerData> wm
  • Re: 7.1 support for List<ProducerData> Felix GV
  • Re: 7.1 support for List<ProducerData> Felix GV
  • Re: 7.1 support for List<ProducerData> will martin
• S3 Consumer for Super Duper Blog Post! Russell Jurney
  • Re: S3 Consumer for Super Duper Blog Post! Matthew Rathbone
  • Re: S3 Consumer for Super Duper Blog Post! Russell Jurney
  • Re: S3 Consumer for Super Duper Blog Post! Russell Jurney
  • Re: S3 Consumer for Super Duper Blog Post! Matthew Rathbone
  • Re: S3 Consumer for Super Duper Blog Post! Niek Sanders
  • Re: S3 Consumer for Super Duper Blog Post! Parviz deyhim
• buffer.time Ming Han
  • Re: buffer.time Xavier Stevens
  • Re: buffer.time Neha Narkhede
  • Re: buffer.time Neha Narkhede
  • buffer.time Ming Han
• compression codec configuration Corbin Hoenes
  • Re: compression codec configuration Jun Rao
• kafka-0.7.1-incubating-src.tgz Corbin Hoenes
  • Re: kafka-0.7.1-incubating-src.tgz Joe Stein
• Removing and re-adding broker Pankaj Gupta
  • Re: Removing and re-adding broker Joel Koshy
• Kafka Avro Based Consumer Murtaza Doctor
• GZIPCompressionCodec Corbin Hoenes
  • Re: GZIPCompressionCodec jjian fan
  • Re: GZIPCompressionCodec Corbin Hoenes
  • Re: GZIPCompressionCodec Neha Narkhede
  • Re: GZIPCompressionCodec Corbin Hoenes
• Hadoop-consumer & partition question Fredrik Emilsson
  • Re: Hadoop-consumer & partition question Neha Narkhede
  • RE: Hadoop-consumer & partition question Fredrik Emilsson
  • Re: Hadoop-consumer & partition question Felix GV
• Partition problems Fredrik Emilsson
  • RE: Partition problems Fredrik Emilsson
  • Re: Partition problems Jun Rao
  • RE: Partition problems Fredrik Emilsson
• Re: broker not release segment file after deleting expired segments? Neha Narkhede
  • Re: broker not release segment file after deleting expired segments? xiaoyu wang
  • Re: broker not release segment file after deleting expired segments? Joel Koshy
  • Re: broker not release segment file after deleting expired segments? xiaoyu wang
  • Re: broker not release segment file after deleting expired segments? Neha Narkhede
  • Re: broker not release segment file after deleting expired segments? xiaoyu wang
  • Re: broker not release segment file after deleting expired segments? Jun Rao
  • Re: broker not release segment file after deleting expired segments? xiaoyu wang
  • Re: broker not release segment file after deleting expired segments? xiaoyu wang
  • Re: broker not release segment file after deleting expired segments? Jun Rao
• Kafka brokers in a VM Casey Sybrandy
  • Re: Kafka brokers in a VM Jay Kreps
  • Re: Kafka brokers in a VM Erich Nachbar
  • Re: Kafka brokers in a VM Evan Chan
  • Re: Kafka brokers in a VM Matthew Rathbone
  • Re: Kafka brokers in a VM Evan Chan
  • Re: Kafka brokers in a VM Matthew Rathbone
  • Kafka brokers in a VM Casey Sybrandy
• Re: Determining offset of last produce? Joel Koshy
  • Re: Determining offset of last produce? Brian O'Neill
  • Re: Determining offset of last produce? Joel Koshy
  • Re: Determining offset of last produce? Brian O'Neill
• removing broker files (other than using the retention policy)? James A. Robinson
  • Re: removing broker files (other than using the retention policy)? Neha Narkhede
  • Re: removing broker files (other than using the retention policy)? James A. Robinson
  • Re: removing broker files (other than using the retention policy)? Casey Sybrandy
  • Re: removing broker files (other than using the retention policy)? Joel Koshy
• Keeping zookeeper happy? James A. Robinson
  • Re: Keeping zookeeper happy? Joel Koshy
  • Re: Keeping zookeeper happy? Neha Narkhede
  • Re: Keeping zookeeper happy? James A. Robinson
• compression ratios? James A. Robinson
  • Re: compression ratios? Jun Rao
  • Re: compression ratios? James A. Robinson
• Snappy error when using Kafka producer in Jetty6 webapp Patricio Echagüe
  • Re: Snappy error when using Kafka producer in Jetty6 webapp Patricio Echagüe
  • Re: Snappy error when using Kafka producer in Jetty6 webapp Neha Narkhede
• multifetch overflow Grégoire Seux
  • Re: multifetch overflow Jun Rao
  • RE: multifetch overflow Grégoire Seux
• Any way to know from kafka's JMX interface whether there are unread messages on a topic Joseph Boyd
  • Re: Any way to know from kafka's JMX interface whether there are unread messages on a topic Jun Rao
  • Re: Any way to know from kafka's JMX interface whether there are unread messages on a topic Joseph Boyd
  • Re: Any way to know from kafka's JMX interface whether there are unread messages on a topic Jun Rao
  • Re: Any way to know from kafka's JMX interface whether there are unread messages on a topic Joseph Boyd
  • Re: Any way to know from kafka's JMX interface whether there are unread messages on a topic Corbin Hoenes
  • Re: Any way to know from kafka's JMX interface whether there are unread messages on a topic Jun Rao
• Deployment Options for Kafka Murtaza Doctor
  • Re: Deployment Options for Kafka Jun Rao
  • Re: Deployment Options for Kafka Murtaza Doctor
  • Re: Deployment Options for Kafka Jun Rao
  • Re: Deployment Options for Kafka Joel Koshy
• InvalidMessageSizeException Rahul Biswas
  • Re: InvalidMessageSizeException Neha Narkhede
  • Re: InvalidMessageSizeException Rahul Biswas
  • InvalidMessageSizeException Rahul Biswas
• Re: Thousands of topics Taylor Gautier
  • Re: Thousands of topics Lorenzo Alberton
  • Re: Thousands of topics Johan Rydberg
• RAID software Riju Kallivalappil
  • Re: RAID software Jun Rao
  • Re: RAID software Riju Kallivalappil
• mirroring setup Grégoire Seux
• Running kafka with scala 2.10-M* Dima Gutzeit
  • Re: Running kafka with scala 2.10-M* Jun Rao
  • Re: Running kafka with scala 2.10-M* Dima Gutzeit
  • Re: Running kafka with scala 2.10-M* Jun Rao
  • Re: Running kafka with scala 2.10-M* Dima Gutzeit
  • Re: Running kafka with scala 2.10-M* Neha Narkhede
• Re: Exceptions in zookeeper based consumer Jun Rao
• Re: error in LogManager.createlog() Jun Rao
  • Re: error in LogManager.createlog() jjian fan
  • Re: error in LogManager.createlog() Jun Rao
  • Re: error in LogManager.createlog() jjian fan
  • Re: error in LogManager.createlog() Jay Kreps
  • Re: error in LogManager.createlog() jjian fan
  • Re: error in LogManager.createlog() Jun Rao
  • Re: error in LogManager.createlog() jjian fan
  • Re: error in LogManager.createlog() Jun Rao
  • Re: error in LogManager.createlog() jjian fan
  • Re: error in LogManager.createlog() Jun Rao
  • Re: error in LogManager.createlog() jjian fan
  • Re: error in LogManager.createlog() jjian fan
  • Re: error in LogManager.createlog() Jun Rao
  • Re: error in LogManager.createlog() jjian fan
  • Re: error in LogManager.createlog() Jun Rao
  • Re: error in LogManager.createlog() jjian fan
• My brokers stopped accepting events... Guy Doulberg
  • Re: My brokers stopped accepting events... Jun Rao
• compile error "illegal cyclic reference involving class Producer" with simple example Eric Deliot
  • Re: compile error "illegal cyclic reference involving class Producer" with simple example Sam William
• one broker fail to re-join the cluster after been killed 刘明敏
  • Re: one broker fail to re-join the cluster after been killed Neha Narkhede
  • Re: one broker fail to re-join the cluster after been killed 刘明敏
• Re: an exception in the logfile of consumer client Neha Narkhede
  • Re: Re: an exception in the logfile of consumer client zlai_2001
  • Re: Re: an exception in the logfile of consumer client Neha Narkhede
• Re: Maven Joe Stein
  • Re: Maven graham sanderson
  • Re: Maven Joe Stein
  • Re: Maven graham sanderson
  • Re: Maven Neha Narkhede
  • Re: Maven Ajit Koti
• Multiple Mirror Architecture Example Christian Carollo
  • Re: Multiple Mirror Architecture Example Joel Koshy
  • Re: Multiple Mirror Architecture Example Riju Kallivalappil
  • Re: Multiple Mirror Architecture Example Jun Rao
  • Re: Multiple Mirror Architecture Example Riju Kallivalappil
  • Re: Multiple Mirror Architecture Example Jun Rao

• Earlier messages
• Later messages