You are viewing a plain text version of this content. The canonical link for it is here.
- KafkaMetricsConfig not documented - posted by Stevo Slavić <ss...@gmail.com> on 2015/06/01 00:57:36 UTC, 2 replies.
- async - posted by ram kumar <ra...@gmail.com> on 2015/06/01 07:18:45 UTC, 3 replies.
- SCALA Consumer example program - posted by Madabhattula Rajesh Kumar <mr...@gmail.com> on 2015/06/01 07:26:55 UTC, 0 replies.
- How to correctly handle offsets? - posted by "luo.fucong" <ba...@gmail.com> on 2015/06/01 10:08:13 UTC, 1 replies.
- Kafka issue with FetchRequest buffer size - posted by Zhenzhong Xu <zx...@netflix.com.INVALID> on 2015/06/01 19:28:33 UTC, 0 replies.
- Re: Kafka broker - Ip-address instead of host naem - posted by Jason Rosenberg <jb...@squareup.com> on 2015/06/01 21:43:32 UTC, 0 replies.
- Re: Cascading failures on running out of disk space - posted by Jason Rosenberg <jb...@squareup.com> on 2015/06/01 21:56:54 UTC, 1 replies.
- Re: Broker error: "failed due to Leader not local for partition" - posted by Jason Rosenberg <jb...@squareup.com> on 2015/06/01 22:02:14 UTC, 0 replies.
- Re: leader update partitions fail with KeeperErrorCode = BadVersion,kafka version=0.8.1.1 - posted by Jason Rosenberg <jb...@squareup.com> on 2015/06/01 22:14:15 UTC, 1 replies.
- Re: aborting a repartition assignment - posted by Jason Rosenberg <jb...@squareup.com> on 2015/06/01 22:17:43 UTC, 0 replies.
- Re: KafkaException: Size of FileMessageSet has been truncated during write - posted by Jason Rosenberg <jb...@squareup.com> on 2015/06/01 22:21:22 UTC, 0 replies.
- Re: Kafka partitions unbalanced - posted by Jason Rosenberg <jb...@squareup.com> on 2015/06/01 22:30:22 UTC, 1 replies.
- Re: Offset management: client vs broker side responsibility - posted by Jason Rosenberg <jb...@squareup.com> on 2015/06/01 22:41:54 UTC, 2 replies.
- Re: Ordered Message Queue with Pool of Consumers - posted by Jason Rosenberg <jb...@squareup.com> on 2015/06/01 22:48:28 UTC, 0 replies.
- Re: consumer poll returns no records unless called more than once, why? - posted by Jason Rosenberg <jb...@squareup.com> on 2015/06/01 23:01:55 UTC, 0 replies.
- potential bug with offset request and just rolled log segment - posted by Alfred Landrum <al...@jut.io> on 2015/06/02 00:14:39 UTC, 3 replies.
- How to prevent custom Partitioner from increasing the number of producer's requests? - posted by Sebastien Falquier <se...@teads.tv> on 2015/06/02 09:35:57 UTC, 7 replies.
- Using SimpleConsumer to get messages from offset until now - posted by Kevin Sjöberg <ke...@fortnox.se> on 2015/06/02 18:25:37 UTC, 2 replies.
- HDD or SSD or EBS for kafka brokers in Amazon EC2 - posted by Henry Cai <hc...@pinterest.com.INVALID> on 2015/06/02 18:37:49 UTC, 16 replies.
- Kafka JMS metrics meaning - posted by Marina <pp...@yahoo.com.INVALID> on 2015/06/02 18:50:11 UTC, 4 replies.
- Consumer lag lies - orphaned offsets? - posted by Otis Gospodnetic <ot...@gmail.com> on 2015/06/02 22:00:30 UTC, 12 replies.
- Query on broker info - posted by Pavan Chenduluru <ch...@gmail.com> on 2015/06/03 15:29:53 UTC, 2 replies.
- Broker holding all files open - posted by Scott Thibault <sc...@multiscalehn.com> on 2015/06/03 16:47:38 UTC, 2 replies.
- Re: Issue with kafka-topics.sh tool for adding new partitions with replica assignment - posted by Jason Rosenberg <jb...@squareup.com> on 2015/06/03 22:56:22 UTC, 0 replies.
- Kafka New Producer Async vs Sync - posted by Kelvin Fann <Ke...@centro.net> on 2015/06/04 00:48:15 UTC, 0 replies.
- Kafka 0.8.1.1 - posted by Vadim Keylis <vk...@gmail.com> on 2015/06/04 02:31:45 UTC, 1 replies.
- High CPU usage for idle kafka server - posted by "Anuja Pundlik (apundlik)" <ap...@cisco.com> on 2015/06/04 06:43:23 UTC, 12 replies.
- Newbie Developer question - posted by Jayesh Thakrar <j_...@yahoo.com.INVALID> on 2015/06/04 23:04:45 UTC, 0 replies.
- [ANNOUNCE] Burrow - Consumer Lag Monitoring as a Service - posted by Todd Palino <tp...@gmail.com> on 2015/06/05 03:43:12 UTC, 9 replies.
- Multiple instances of HL Consumer - posted by "Panda, Samaresh" <Sa...@washpost.com> on 2015/06/05 16:11:56 UTC, 1 replies.
- Query on kafka topic metadata - posted by Pavan Chenduluru <ch...@gmail.com> on 2015/06/05 20:02:38 UTC, 1 replies.
- callback handler is not getting called if cluster is down - posted by ankit tyagi <an...@gmail.com> on 2015/06/08 09:27:45 UTC, 3 replies.
- simple consumer giving error always - posted by sunil kalva <sa...@gmail.com> on 2015/06/08 11:21:32 UTC, 1 replies.
- Difference between NOT_ENOUGH_REPLICAS and NOT_ENOUGH_REPLICAS_AFTER_APPEND - posted by tao xiao <xi...@gmail.com> on 2015/06/08 11:51:25 UTC, 2 replies.
- New producer very slow to call Callback on error - posted by Christofer Hedbrandh <ch...@knewton.com> on 2015/06/08 19:44:45 UTC, 1 replies.
- Anouncing PyKafka! - posted by Keith Bourgoin <ke...@gmail.com> on 2015/06/08 21:24:06 UTC, 6 replies.
- what do 'soTimeout', 'bufferSize' and 'minBytes' mean for SimpleConsumer? - posted by Marina <pp...@yahoo.com.INVALID> on 2015/06/08 22:46:26 UTC, 0 replies.
- Kafka Server JMX Log End Offset Not updating after repartioning - posted by joe smith <wa...@yahoo.com.INVALID> on 2015/06/09 00:33:48 UTC, 0 replies.
- backup(dump) and restore environment - posted by Jakub Muszynski <si...@gmail.com> on 2015/06/09 11:00:52 UTC, 2 replies.
- Query on kafka broker and topic metadata - posted by Pavan Chenduluru <ch...@gmail.com> on 2015/06/09 11:43:11 UTC, 0 replies.
- Kafka topic registration documentation. - posted by Piotr Husiatyński <ph...@optiopay.com> on 2015/06/09 13:33:58 UTC, 0 replies.
- Mirror maker doesn't rebalance after getting ZkNoNodeException - posted by tao xiao <xi...@gmail.com> on 2015/06/09 13:49:08 UTC, 2 replies.
- ConsumerFetcherManager MaxLag - posted by Tyson Norris <tn...@adobe.com> on 2015/06/09 17:46:01 UTC, 0 replies.
- offsets.storage=kafka, dual.commit.enabled=false still requires ZK - posted by noah <ia...@gmail.com> on 2015/06/09 19:26:11 UTC, 3 replies.
- Stale topic for existing producer - posted by Casey Daniell <ca...@hotmail.com> on 2015/06/09 20:14:17 UTC, 0 replies.
- producer metadata behavior when topic not created - posted by Steven Wu <st...@gmail.com> on 2015/06/09 21:04:39 UTC, 0 replies.
- Usage of Kafka Mirror Maker - posted by nitin sharma <ku...@gmail.com> on 2015/06/10 05:09:07 UTC, 0 replies.
- Kafka as an event store for Event Sourcing - posted by Daniel Schierbeck <da...@gmail.com> on 2015/06/10 11:04:17 UTC, 15 replies.
- Kafka 0.8.3 - New Consumer - user implemented partition.assignment.strategies? - posted by "Johansson, Olof" <Ol...@thingworx.com> on 2015/06/10 18:32:10 UTC, 3 replies.
- Re: ReplicaFetcherThread Error, Massive Logging, and Leader Flapping - posted by Kyle Banker <ky...@gmail.com> on 2015/06/10 18:54:58 UTC, 0 replies.
- How to manage the consumer group id? - posted by James Cheng <jc...@tivo.com> on 2015/06/10 22:20:37 UTC, 3 replies.
- Changing replication factor for an existing topic - posted by Robin Yamaguchi <ro...@tune.com> on 2015/06/11 01:05:25 UTC, 3 replies.
- Increased replication factor. Replication didn't happen! - posted by Dillian Murphey <cr...@gmail.com> on 2015/06/11 02:07:23 UTC, 6 replies.
- expose setConsumerRebalanceListener - posted by tao xiao <xi...@gmail.com> on 2015/06/11 05:12:14 UTC, 0 replies.
- offset storage as kafka - posted by Squarek Code <sq...@gmail.com> on 2015/06/11 05:44:08 UTC, 0 replies.
- offset storage as kafka with zookeeper 3.4.6 - posted by Kris K <sq...@gmail.com> on 2015/06/11 10:03:09 UTC, 2 replies.
- Kafka 0.8.1.1 arbitrarily increased replication factor - posted by Yury Ruchin <yu...@gmail.com> on 2015/06/11 10:05:02 UTC, 0 replies.
- Re: If you run Kafka in AWS or Docker, how do you persist data? - posted by Domen Pogacnik <do...@rocket-internet.de> on 2015/06/11 15:41:00 UTC, 1 replies.
- Producer RecordMetaData with Offset -1 - posted by "Gokulakannan M (Engineering - Data Platform)" <go...@flipkart.com> on 2015/06/12 15:47:38 UTC, 2 replies.
- [ANNOUNCE] kafka-python 0.9.4 - posted by Dana Powers <da...@rd.io> on 2015/06/12 19:21:14 UTC, 0 replies.
- Log compaction not working as expected - posted by Shayne S <sh...@gmail.com> on 2015/06/12 20:08:13 UTC, 7 replies.
- FetchRequestPurgatory - posted by Saladi Naidu <na...@yahoo.com.INVALID> on 2015/06/12 21:08:46 UTC, 0 replies.
- Noobie question about consumers and ordering of messages - posted by Dillian Murphey <cr...@gmail.com> on 2015/06/13 00:31:13 UTC, 1 replies.
- OutOfMemoryError in mirror maker - posted by tao xiao <xi...@gmail.com> on 2015/06/13 20:39:17 UTC, 11 replies.
- Broken auto leader rebalance after using reassign partitions tool - posted by Valentin <ka...@sblk.de> on 2015/06/15 17:41:36 UTC, 3 replies.
- At-least-once guarantees with high-level consumer - posted by Carl Heymann <ch...@gmail.com> on 2015/06/15 21:12:38 UTC, 10 replies.
- cannot make another partition reassignment due to the previous partition reassignment failure - posted by Yu Yang <yu...@gmail.com> on 2015/06/16 04:45:21 UTC, 2 replies.
- Log4j apperder - posted by Paweł Woźniak <pw...@man.poznan.pl> on 2015/06/16 17:46:27 UTC, 0 replies.
- subscribe kafka - posted by Jin Wang <wa...@gmail.com> on 2015/06/16 20:31:01 UTC, 1 replies.
- QuickStart OK locally, but getting "WARN Property topic is not valid" and LeaderNotAvailableException remotely - posted by Mike Bridge <mi...@bridgecanada.com> on 2015/06/16 23:08:33 UTC, 4 replies.
- Keeping Zookeeper and Kafka Server Up - posted by Su She <su...@gmail.com> on 2015/06/16 23:21:35 UTC, 7 replies.
- Produce request failed due to NotLeaderForPartitionException (leader epoch is old) - posted by Ivan Balashov <ib...@gmail.com> on 2015/06/17 02:54:23 UTC, 0 replies.
- duplicate messages at consumer - posted by Kris K <sq...@gmail.com> on 2015/06/17 06:06:09 UTC, 6 replies.
- How to specify kafka bootstrap jvm options? - posted by "luo.fucong" <ba...@gmail.com> on 2015/06/17 10:41:54 UTC, 1 replies.
- Recovering from broker failure with KafkaConsumer - posted by Jan Stette <ja...@gmail.com> on 2015/06/17 11:31:20 UTC, 3 replies.
- Issue with log4j Kafka Appender. - posted by Madhavi Sreerangam <ma...@gmail.com> on 2015/06/17 21:44:34 UTC, 1 replies.
- Broker ISR confusion with soft-failed broker - posted by Bob Cotton <bc...@rallydev.com> on 2015/06/17 23:38:44 UTC, 0 replies.
- NoSuchMethodError with Consumer Instantiation - posted by Srividhya Anantharamakrishnan <sr...@hedviginc.com> on 2015/06/18 04:41:20 UTC, 4 replies.
- Re: New Producer API - batched sync mode support - posted by Greg Lloyd <gl...@gmail.com> on 2015/06/18 06:07:47 UTC, 0 replies.
- unclean leader election enable default value bug? - posted by Zaiming Shi <zm...@gmail.com> on 2015/06/18 12:51:44 UTC, 2 replies.
- Could not recover kafka broker - posted by haosdent <ha...@gmail.com> on 2015/06/18 13:37:51 UTC, 1 replies.
- Add the hard drive problem - posted by 杨洪涛 <ya...@koudai.com> on 2015/06/18 14:54:38 UTC, 1 replies.
- queued.max.requests Configuration - posted by Grant Henke <gh...@cloudera.com> on 2015/06/18 18:25:52 UTC, 0 replies.
- How Netflix is using Kafka - posted by Peter Hausel <pe...@gmail.com> on 2015/06/18 19:17:55 UTC, 1 replies.
- Need recommendation - posted by "Khanda.Rajat" <Ra...@IGT.com> on 2015/06/18 19:39:11 UTC, 0 replies.
- Re: Need recommendation - posted by Gwen Shapira <gs...@cloudera.com> on 2015/06/18 20:29:07 UTC, 0 replies.
- How to decrease number of replicas - posted by Guangle Fan <fa...@gmail.com> on 2015/06/18 23:03:29 UTC, 2 replies.
- Manual Offset Commits with High Level Consumer skipping messages - posted by noah <ia...@gmail.com> on 2015/06/18 23:21:47 UTC, 8 replies.
- noticing blocking of kafka-network-thread - posted by Pete Wright <pw...@rubiconproject.com> on 2015/06/19 01:08:02 UTC, 0 replies.
- Broker Fails to restart - posted by Zakee <kz...@netzero.net> on 2015/06/19 01:52:18 UTC, 2 replies.
- Kafka client API cannot work - posted by Santiago <wx...@126.com> on 2015/06/19 04:09:02 UTC, 0 replies.
- Closing socket connection to /192.115.190.61. (kafka.network.Processor) - posted by "bit1129@163.com" <bi...@163.com> on 2015/06/19 07:39:01 UTC, 4 replies.
- Fwd: Spark Streaming + kakfa (Check that you get the data from kafka producer) - posted by Raghav Joshi <ra...@infoobjects.com> on 2015/06/19 10:24:31 UTC, 0 replies.
- Re: JavaKafkaWordCount not working under Spark Streaming - posted by rusty <ra...@infoobjects.com> on 2015/06/19 10:29:53 UTC, 0 replies.
- how to modify offsets stored in Kafka in 0.8.2.1 version? - posted by Marina <pp...@yahoo.com.INVALID> on 2015/06/19 15:23:20 UTC, 7 replies.
- Failure in Leader Election on broker shutdown - posted by Sandeep Bishnoi <sa...@gmail.com> on 2015/06/19 23:37:31 UTC, 1 replies.
- Re: Java NPE in using KafkaConsumer API - posted by Sandeep Bishnoi <sa...@gmail.com> on 2015/06/19 23:46:25 UTC, 1 replies.
- Re: How to achieve distributed processing and high availability simultaneously in Kafka? - posted by sumit jain <su...@gmail.com> on 2015/06/21 15:33:34 UTC, 0 replies.
- latest kafka consumer api maven location - posted by Shushant Arora <sh...@gmail.com> on 2015/06/21 17:01:50 UTC, 2 replies.
- Warning in producer performance test - posted by ram kumar <ra...@gmail.com> on 2015/06/22 06:59:28 UTC, 0 replies.
- data loss - replicas - posted by Nirmal ram <ni...@gmail.com> on 2015/06/22 16:26:14 UTC, 6 replies.
- kafka 0.8.2 add partitions on runtime - posted by Shushant Arora <sh...@gmail.com> on 2015/06/22 19:43:34 UTC, 0 replies.
- Consumer Best Practices - posted by Tom McKenzie <th...@gmail.com> on 2015/06/22 19:53:16 UTC, 0 replies.
- Consumer that consumes only local partition? - posted by Shef <sh...@yahoo.com> on 2015/06/22 23:43:51 UTC, 0 replies.
- kafka.common.NotLeaderForPartitionException in Consumer - posted by Srividhya Anantharamakrishnan <sr...@hedviginc.com> on 2015/06/23 00:50:46 UTC, 3 replies.
- Batch producer latencies and flush() - posted by Achanta Vamsi Subhash <ac...@flipkart.com> on 2015/06/23 09:33:30 UTC, 2 replies.
- High level consumer rebalance question - posted by tao xiao <xi...@gmail.com> on 2015/06/23 10:52:55 UTC, 0 replies.
- Is trunk safe for production? - posted by Achanta Vamsi Subhash <ac...@flipkart.com> on 2015/06/23 11:59:34 UTC, 4 replies.
- Increase partitions and replication of __consumer_offsets - posted by Daniel Coldham <da...@wix.com> on 2015/06/23 14:15:24 UTC, 1 replies.
- Does kafka write key to broker? - posted by Mohit Kathuria <mk...@sprinklr.com> on 2015/06/23 17:18:37 UTC, 4 replies.
- high level consumer memory footprint - posted by Kris K <sq...@gmail.com> on 2015/06/23 20:18:14 UTC, 1 replies.
- Best Practices for Java Consumers - posted by Tom McKenzie <th...@gmail.com> on 2015/06/23 23:03:37 UTC, 2 replies.
- Consumer rebalancing based on partition sizes? - posted by Joel Ohman <ma...@gmail.com> on 2015/06/24 04:34:43 UTC, 1 replies.
- No key specified when sending the message to Kafka - posted by "bit1129@163.com" <bi...@163.com> on 2015/06/24 05:28:52 UTC, 2 replies.
- How to run Kafka in background - posted by "bit1129@163.com" <bi...@163.com> on 2015/06/24 12:44:11 UTC, 2 replies.
- Kafka rebalancing and general questions - posted by JIEFU GONG <jg...@berkeley.edu> on 2015/06/24 20:37:29 UTC, 0 replies.
- replication factor: 1 larger than available brokers: 0 issue - posted by Rakesh Vidyadharan <rv...@gracenote.com> on 2015/06/24 23:16:55 UTC, 0 replies.
- Message loss due to zookeeper ensemble doesn't work - posted by "bit1129@163.com" <bi...@163.com> on 2015/06/25 05:57:39 UTC, 2 replies.
- How can I unsubscribe from this mailing list - posted by Monika Garg <ga...@gmail.com> on 2015/06/25 09:25:49 UTC, 1 replies.
- Uncaught exception in scheduled task 'kafka-log-retention' - posted by Emilio Parisca <ea...@enforceglobal.com> on 2015/06/25 20:46:25 UTC, 0 replies.
- Kafka consumer does not work from eclipse when kafka running inside VM - posted by shivam tiwari <sh...@gmail.com> on 2015/06/26 16:51:56 UTC, 5 replies.
- Help Us Nominate Apache Kafka for a 2015 Bossie (Best of OSS) Award - Due June 30th - posted by Neha Narkhede <ne...@confluent.io> on 2015/06/26 18:47:20 UTC, 2 replies.
- zookeeper bottleneck in kafka operations - posted by Shushant Arora <sh...@gmail.com> on 2015/06/27 16:51:58 UTC, 1 replies.
- How to fetch offset in SimpleConsumer using Java - posted by "Xiang Zhou (Samuel)" <zh...@gmail.com> on 2015/06/29 07:50:43 UTC, 3 replies.
- retention.ms is not respected after upgrade to 0.8.2 - posted by Krzysztof Zarzycki <k....@gmail.com> on 2015/06/29 08:36:48 UTC, 0 replies.
- no of threads per async producer - posted by Shushant Arora <sh...@gmail.com> on 2015/06/29 18:38:49 UTC, 7 replies.
- Sporadic Shrinking/Expanding ISR Blips - posted by Christofer Hedbrandh <ch...@knewton.com> on 2015/06/29 19:19:36 UTC, 3 replies.
- Meaning of attributes in mbean kafka.server:name=MessagesInPerSec,type=BrokerTopicMetrics: - posted by Jack Zhou <jz...@edgecast.com> on 2015/06/30 04:26:29 UTC, 4 replies.
- Subscribe kafka users mailing list - posted by Kashif Hussain <ka...@gmail.com> on 2015/06/30 10:16:01 UTC, 1 replies.
- How to monitor consuming rate and lag? - posted by Shady Xu <sh...@gmail.com> on 2015/06/30 10:41:05 UTC, 2 replies.
- Producer repeatedly locking up - posted by Shayne S <sh...@gmail.com> on 2015/06/30 19:14:28 UTC, 2 replies.
- Reimaging zookeeper host - posted by Rajasekar Elango <re...@salesforce.com> on 2015/06/30 21:06:33 UTC, 1 replies.
- querying messages based on timestamps - posted by Shushant Arora <sh...@gmail.com> on 2015/06/30 21:52:19 UTC, 2 replies.