You are viewing a plain text version of this content. The canonical link for it is here.
- Re: Regarding using of apache kafka - posted by Jiangjie Qin <jq...@linkedin.com.INVALID> on 2015/08/02 05:54:50 UTC, 0 replies.
- Re: New consumer - offset storage options - posted by Jiangjie Qin <jq...@linkedin.com.INVALID> on 2015/08/02 05:59:12 UTC, 0 replies.
- Consumer limit for pub-sub mode - posted by Vaibhav Kirte <va...@sokrati.com> on 2015/08/03 07:09:01 UTC, 5 replies.
- Kafka Zookeeper Issues - posted by "Wollert, Fabian" <fa...@zalando.de> on 2015/08/03 12:20:51 UTC, 2 replies.
- Lead Broker from kafka.message.MessageAndMetadata - posted by Sreenivasulu Nallapati <sr...@gmail.com> on 2015/08/03 14:26:24 UTC, 1 replies.
- 0.8.3 ETA? - posted by Stevo Slavić <ss...@gmail.com> on 2015/08/03 14:52:38 UTC, 2 replies.
- new consumer api? - posted by Jalpesh Patadia <ja...@clickbank.com> on 2015/08/03 17:41:01 UTC, 3 replies.
- 0.9.0 release - posted by Shrikant Patel <SP...@pdxinc.com> on 2015/08/03 22:14:07 UTC, 4 replies.
- Checkpointing with custom metadata - posted by James Cheng <jc...@tivo.com> on 2015/08/03 22:52:22 UTC, 5 replies.
- kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries. - posted by David Li <da...@stargazer.com.sg> on 2015/08/04 05:21:31 UTC, 2 replies.
- Re: New Consumer API and Range Consumption with Fail-over - posted by Bhavesh Mistry <mi...@gmail.com> on 2015/08/04 09:01:58 UTC, 2 replies.
- Get last snapshot from compacted topic - posted by Aki <ja...@marmelandia.com> on 2015/08/04 12:16:02 UTC, 1 replies.
- How to read in batch using HighLevel Consumer? - posted by shahab <sh...@gmail.com> on 2015/08/04 17:37:38 UTC, 6 replies.
- Re: Decomissioning a broker - posted by Grant Henke <gh...@cloudera.com> on 2015/08/04 19:00:28 UTC, 2 replies.
- Re: Consumer that consumes only local partition? - posted by Robert Metzger <rm...@apache.org> on 2015/08/04 20:57:47 UTC, 1 replies.
- Access control in kafka - posted by Alvaro Gareppe <ag...@gmail.com> on 2015/08/04 22:57:08 UTC, 1 replies.
- message filterin or "selector" - posted by Alvaro Gareppe <ag...@gmail.com> on 2015/08/04 23:05:55 UTC, 8 replies.
- Kafka Broker server cannot be connected by telnet from other Kafka Brokers - posted by Qi Xu <sh...@gmail.com> on 2015/08/05 00:42:12 UTC, 0 replies.
- Re: Got conflicted ephemeral node exception for several hours - posted by Jaikiran Pai <ja...@gmail.com> on 2015/08/05 01:02:55 UTC, 0 replies.
- Kafka vs RabbitMQ latency - posted by Yuheng Du <yu...@gmail.com> on 2015/08/05 03:42:44 UTC, 0 replies.
- InvalidMessageException: Message is corrupt, Consumer stuck - posted by Henry Cai <hc...@pinterest.com.INVALID> on 2015/08/05 07:23:53 UTC, 2 replies.
- How to read messages from Kafka by specific time? - posted by shahab <sh...@gmail.com> on 2015/08/05 11:11:19 UTC, 2 replies.
- Specify leader when doing partition reassignment - posted by tao xiao <xi...@gmail.com> on 2015/08/05 12:18:31 UTC, 4 replies.
- Gobblin Data Ingestion Framework - posted by Bhavesh Mistry <mi...@gmail.com> on 2015/08/05 19:06:21 UTC, 0 replies.
- Kafka Simple Consumer Replicas versus ISR - posted by da...@ariens.ca on 2015/08/05 19:13:10 UTC, 1 replies.
- Changing Kafka configs for already running brokers - posted by JIEFU GONG <jg...@berkeley.edu> on 2015/08/05 19:26:42 UTC, 2 replies.
- Fwd: NotAssignedReplicationException from the ReplicaFetcher threads - version 0.8.1.1 - posted by Pradeep Jawahar <pj...@groupon.com> on 2015/08/05 19:56:33 UTC, 0 replies.
- Kafka partition reassignment causes replica number and Isr to go above configured value - posted by Ye Hong <ye...@gmail.com> on 2015/08/05 21:02:41 UTC, 0 replies.
- Question regarding Kafka EventThread - posted by Chinmay Soman <ch...@gmail.com> on 2015/08/05 21:12:15 UTC, 3 replies.
- Kafka RecordAccumulator size grows beyond configured buffer.memory size - posted by Liju John <li...@gmail.com> on 2015/08/05 21:41:41 UTC, 2 replies.
- Partition reassignment causes replica number and Isr to go above configured value - posted by Ye Hong <Ye...@audiencescience.com> on 2015/08/05 23:55:28 UTC, 0 replies.
- Kafka + Avro serialization - io.confluent.kafka.serializers.KafkaAvroSerializer - maven dependency not resolving - posted by Neville Sequeira <ne...@gmail.com> on 2015/08/06 00:28:07 UTC, 3 replies.
- Mirrormaker Re-partitioning Keyed Messages - posted by Johnny Sheeley <sh...@aigee.org> on 2015/08/06 02:23:55 UTC, 0 replies.
- Documentation typo for offsets.topic.replication.factor ? - posted by James Cheng <jc...@tivo.com> on 2015/08/06 03:28:55 UTC, 1 replies.
- New simple producer examples? - posted by Devin Smith <ds...@redcurrent.com> on 2015/08/06 04:34:43 UTC, 0 replies.
- best way to call ReassignPartitionsCommand programmatically - posted by tao xiao <xi...@gmail.com> on 2015/08/06 04:41:30 UTC, 1 replies.
- Unsubscribe me - posted by "Seshadri, Balaji" <Ba...@dish.com> on 2015/08/06 05:36:56 UTC, 0 replies.
- Kafka Simple Cosumer - posted by uvsd1 <pr...@gmail.com> on 2015/08/06 07:09:05 UTC, 1 replies.
- Inconsistency with Zookeeper - posted by Hemanth Abbina <He...@eiqnetworks.com> on 2015/08/06 10:13:18 UTC, 5 replies.
- How to recover from out of sync - posted by "sy.pan" <sh...@gmail.com> on 2015/08/06 12:47:27 UTC, 1 replies.
- Re: FATAL [Replica Manager on Broker XXX]: Error writing to highwatermark file: - posted by "tianning.zhang" <ti...@zanox.com> on 2015/08/06 12:56:27 UTC, 0 replies.
- Broker side consume-request filtering - posted by Alvaro Gareppe <ag...@gmail.com> on 2015/08/06 19:55:09 UTC, 1 replies.
- OffsetOutOfRangeError with Kafka-Spark streaming - posted by Cassa L <lc...@gmail.com> on 2015/08/06 20:17:56 UTC, 7 replies.
- java.lang.OutOfMemoryError: Java heap space - posted by Sourabh Chandak <so...@gmail.com> on 2015/08/07 03:01:22 UTC, 2 replies.
- kafka log flush questions - posted by Tao Feng <fe...@gmail.com> on 2015/08/07 06:49:20 UTC, 2 replies.
- Fwd: Spooling support for kafka publishers ! - posted by sunil kalva <ka...@gmail.com> on 2015/08/07 11:52:27 UTC, 1 replies.
- how to get single record from kafka topic+partition @ specified offset - posted by "Padgett, Ben" <bp...@illumina.com> on 2015/08/07 18:26:48 UTC, 4 replies.
- AdminUtils addPartition, subsequent producer send exception - posted by "Gelinas, Chiara" <cg...@illumina.com> on 2015/08/07 19:34:49 UTC, 4 replies.
- Suggestions when all replicas of a partition are dead? - posted by Steve Miller <st...@idrathernotsay.com> on 2015/08/07 21:58:59 UTC, 1 replies.
- Kafka metadata - posted by Qi Xu <sh...@gmail.com> on 2015/08/07 23:30:54 UTC, 4 replies.
- Disaster Recovery (was: Re: Suggestions when all replicas of a partition are dead?) - posted by Steve Miller <st...@idrathernotsay.com> on 2015/08/08 16:17:30 UTC, 0 replies.
- Why Apache is scalable? - posted by lucky Johnson <lu...@gmail.com> on 2015/08/09 17:22:54 UTC, 1 replies.
- abstracting ZooKeeper - posted by Julio Castillo <jc...@FinancialEngines.com> on 2015/08/09 17:33:15 UTC, 6 replies.
- configuring log compaction - posted by David Judd <da...@academia.edu> on 2015/08/09 19:56:24 UTC, 2 replies.
- Re: New producer in production - posted by yuto sasaki <ye...@gmail.com> on 2015/08/10 02:29:56 UTC, 0 replies.
- Is decommissioning brokers supported in 0.8.2? - posted by yuto sasaki <ye...@gmail.com> on 2015/08/10 02:42:46 UTC, 0 replies.
- Partition and consumer configuration - posted by Shashidhar Rao <ra...@gmail.com> on 2015/08/10 09:32:24 UTC, 2 replies.
- problem about the offset - posted by jinhong lu <lu...@gmail.com> on 2015/08/10 11:21:24 UTC, 1 replies.
- Recovery of Kafka cluster takes very long time - posted by Alexey Sverdelov <al...@googlemail.com> on 2015/08/10 17:57:30 UTC, 2 replies.
- Recovering from Kafka NoReplicaOnlineException with one node - posted by Mike Thomsen <mi...@gmail.com> on 2015/08/10 20:12:02 UTC, 2 replies.
- logging for Kafka new producer - posted by Tao Feng <fe...@gmail.com> on 2015/08/11 08:08:29 UTC, 1 replies.
- logging in Kafka new producer - posted by Tao Feng <fe...@gmail.com> on 2015/08/11 08:11:59 UTC, 0 replies.
- Topic auto deletion - posted by Shahar Danos <Sh...@kaltura.com> on 2015/08/11 09:28:26 UTC, 1 replies.
- How to sync back a failed broker? - posted by shahab <sh...@gmail.com> on 2015/08/11 15:18:29 UTC, 0 replies.
- broker.id does not work still showing 0,1 while it was set to 7,8 - posted by shahab <sh...@gmail.com> on 2015/08/11 15:54:44 UTC, 0 replies.
- 0.8.2.1 upgrade causes much more IO - posted by Andrew Otto <ao...@wikimedia.org> on 2015/08/11 18:26:13 UTC, 5 replies.
- Start consuming from latest message - posted by "Datta, Saurav" <sd...@paypal.com.INVALID> on 2015/08/11 22:39:38 UTC, 4 replies.
- lowlatency on kafka - posted by Alvaro Gareppe <ag...@gmail.com> on 2015/08/11 23:21:05 UTC, 0 replies.
- Help with SocketTimeoutException while reading from Kafka cluster - posted by venkatesh kavuluri <ve...@gmail.com> on 2015/08/12 01:29:10 UTC, 1 replies.
- Variation of producer latency in ProducerPerformance test - posted by Yuheng Du <yu...@gmail.com> on 2015/08/12 03:41:53 UTC, 0 replies.
- Sending multiple large HDFS files through Kafka - posted by "Datta, Saurav" <sd...@paypal.com.INVALID> on 2015/08/12 21:27:30 UTC, 5 replies.
- Re: Trying to debug a kafka failure - posted by Rajiv Kurian <ra...@signalfuse.com> on 2015/08/12 23:14:52 UTC, 0 replies.
- Undecipherable error in zookeeper on initial connection - posted by Jason Kania <ja...@ymail.com> on 2015/08/13 00:36:48 UTC, 1 replies.
- Reduce latency - posted by Yuheng Du <yu...@gmail.com> on 2015/08/13 17:51:21 UTC, 17 replies.
- Re: Create topic programmatically - posted by Sue Wilson <sw...@tivo.com> on 2015/08/13 19:47:47 UTC, 1 replies.
- Monitoring kafka metrics - posted by Rajiv Kurian <ra...@signalfuse.com> on 2015/08/13 23:27:30 UTC, 2 replies.
- use page cache as much as possiblee - posted by Yuheng Du <yu...@gmail.com> on 2015/08/13 23:54:49 UTC, 7 replies.
- removing consumer groups that use kafka offset storage - posted by Steve Boyle <sb...@connexity.com> on 2015/08/14 00:07:02 UTC, 0 replies.
- kafka-python question - posted by Sa Li <sa...@gmail.com> on 2015/08/14 00:14:31 UTC, 1 replies.
- Performance testing - posted by "Datta, Saurav" <sd...@paypal.com.INVALID> on 2015/08/14 00:36:34 UTC, 3 replies.
- [DISCUSSION] Kafka 0.8.2.2 release? - posted by Jun Rao <ju...@confluent.io> on 2015/08/14 14:15:38 UTC, 32 replies.
- Re: To Synch a failed broker? - posted by shahab <sh...@gmail.com> on 2015/08/14 16:34:53 UTC, 0 replies.
- Kafka java consumer - posted by Abhijith Prabhakar <ab...@gmail.com> on 2015/08/14 23:17:57 UTC, 3 replies.
- Re: Message corruption with new Java client + snappy + broker restart - posted by Lance Laursen <ll...@rubiconproject.com> on 2015/08/15 01:28:00 UTC, 0 replies.
- 0.8.2 producer and single message requests - posted by Neelesh <ne...@gmail.com> on 2015/08/15 02:07:54 UTC, 4 replies.
- Replica not available...when it is! - posted by Andrew Otto <ao...@wikimedia.org> on 2015/08/15 17:18:15 UTC, 5 replies.
- thread that handle client request in Kafka brokers - posted by Tao Feng <fe...@gmail.com> on 2015/08/15 18:19:42 UTC, 2 replies.
- Possible DEAD LOCK for one day at broker controller? - posted by Zhao Weinan <zh...@gmail.com> on 2015/08/16 10:52:36 UTC, 9 replies.
- Publish large number of messages for load testing - posted by "Datta, Saurav" <sd...@paypal.com.INVALID> on 2015/08/17 09:21:37 UTC, 7 replies.
- Kafka Cluster behind Proxy - posted by Ankit Jain <an...@gmail.com> on 2015/08/17 09:28:07 UTC, 2 replies.
- why does producer fail and does not try other brokers when one of brokers in the cluster fails? - posted by shahab <sh...@gmail.com> on 2015/08/17 10:36:26 UTC, 0 replies.
- Describe command does not update details about killed brokers - posted by Priya Darsini <pd...@gmail.com> on 2015/08/17 10:52:34 UTC, 2 replies.
- Topic partitions randomly failed on live system - posted by Simon Cooper <si...@featurespace.co.uk> on 2015/08/17 13:31:09 UTC, 1 replies.
- Re: New producer hangs inifitely when it looses connection to Kafka cluster - posted by Rafi Shamim <ra...@knewton.com> on 2015/08/17 16:56:28 UTC, 0 replies.
- Error handling in New AsyncProducer - posted by sunil kalva <ka...@gmail.com> on 2015/08/17 17:50:50 UTC, 8 replies.
- Question about unavailable partitions - posted by Jim Hughes <jn...@ccri.com> on 2015/08/17 19:17:33 UTC, 0 replies.
- Compaction per topic - posted by Elias K <ma...@gmail.com> on 2015/08/17 20:48:43 UTC, 1 replies.
- remote Kafka producer configuration and kafka.common.FailedToSendMessageException - posted by Job-Selina Wu <sw...@gmail.com> on 2015/08/17 23:25:24 UTC, 4 replies.
- Does Simple Consumer Shell work with Kafka committed offsets? - posted by noah <ia...@gmail.com> on 2015/08/17 23:30:00 UTC, 0 replies.
- KafkaConsumer from 0.8.3 trunk hangs indefinitely on poll - posted by "Krogh-Moe, Espen" <es...@finn.no> on 2015/08/18 11:46:59 UTC, 1 replies.
- KafkaConsumer from trunk hangs indefinitely on poll - posted by "Krogh-Moe, Espen" <es...@finn.no> on 2015/08/18 12:02:26 UTC, 1 replies.
- Zookeeper use cases with Kafka - posted by Prabhjot Bharaj <pr...@gmail.com> on 2015/08/18 15:03:32 UTC, 2 replies.
- Zookeeper jmx monitoring for kafka - posted by Prabhjot Bharaj <pr...@gmail.com> on 2015/08/18 15:11:57 UTC, 1 replies.
- Is Kafka suitable for high volume, real-time sessions ? - posted by lrnop <lr...@protonmail.com> on 2015/08/18 17:05:23 UTC, 1 replies.
- Patch for SSL setup for Kafka - posted by Cassa L <lc...@gmail.com> on 2015/08/18 19:17:10 UTC, 3 replies.
- spark broadcast variable of Kafka producer throws ConcurrentModificationException - posted by "Shenghua(Daniel) Wan" <wa...@gmail.com> on 2015/08/19 00:02:27 UTC, 1 replies.
- How to make KafkaStream iterator blocking? - posted by Siddharth Jain <si...@uber.com> on 2015/08/19 01:40:09 UTC, 0 replies.
- Using multiple consumers for same topic - posted by "Datta, Saurav" <sd...@paypal.com.INVALID> on 2015/08/19 06:19:13 UTC, 5 replies.
- How to skip malformed messages in a custom Kafka decoder? - posted by Petr Novak <os...@gmail.com> on 2015/08/19 09:40:27 UTC, 2 replies.
- Error while Consuming message - posted by Jigar Shah <ji...@sokrati.com> on 2015/08/19 15:00:30 UTC, 0 replies.
- Sys CPU and load average spikes with kafka cluster on Virtual Box - posted by "Anuja Pundlik (apundlik)" <ap...@cisco.com> on 2015/08/19 21:22:06 UTC, 0 replies.
- Safely cancel partition reassignment task - posted by tao xiao <xi...@gmail.com> on 2015/08/20 05:35:05 UTC, 0 replies.
- Exception in logs, on latest Kafka Java client - 0.8.2.1 - posted by Dima Gutzeit <gu...@maaii.com> on 2015/08/20 11:06:28 UTC, 0 replies.
- Write-time based synchronization of message consumption from multiple topics - posted by David KOCH <dk...@ezakus.com> on 2015/08/20 12:35:36 UTC, 2 replies.
- Re: Problem with node after restart no partitions? - posted by Zhao Weinan <zh...@gmail.com> on 2015/08/20 17:25:31 UTC, 0 replies.
- Leader and Replicas order out of sync. - posted by Manish <ma...@gmail.com> on 2015/08/20 21:18:47 UTC, 0 replies.
- Any drawbacks of running Kafka consumer in a web container - posted by Venkat K <ve...@gmail.com> on 2015/08/21 00:21:13 UTC, 1 replies.
- Possible Memory Leak in Record Accumulator - posted by Drew Goya <dr...@videoamp.com> on 2015/08/21 01:56:15 UTC, 3 replies.
- is SSL support feature ready to use in kafka-truck branch - posted by Qi Xu <sh...@gmail.com> on 2015/08/21 08:10:40 UTC, 1 replies.
- SocketTimeoutException with kafka-producer-perf-test.sh - posted by Prabhjot Bharaj <pr...@gmail.com> on 2015/08/21 08:52:36 UTC, 2 replies.
- kafka-producer-perf-test.sh - No visible difference between request-num-acks 1 and -1 - posted by Prabhjot Bharaj <pr...@gmail.com> on 2015/08/21 11:41:17 UTC, 1 replies.
- Painfully slow kafka recovery - posted by Jörg Wagner <jo...@1und1.de> on 2015/08/21 15:50:25 UTC, 5 replies.
- Raid vs individual disks - posted by Prabhjot Bharaj <pr...@gmail.com> on 2015/08/21 22:02:26 UTC, 2 replies.
- My emails don't seem to go through - posted by Rajiv Kurian <ra...@signalfuse.com> on 2015/08/21 22:56:20 UTC, 2 replies.
- Higher CPU going from 0.8.1 to 0.8.2.1 - posted by Rajiv Kurian <ra...@signalfuse.com> on 2015/08/22 00:50:11 UTC, 3 replies.
- bootstrap.servers for the new Producer - posted by Kishore Senji <ks...@gmail.com> on 2015/08/22 03:56:10 UTC, 4 replies.
- New Async producer hangs - posted by sunil kalva <ka...@gmail.com> on 2015/08/22 22:11:46 UTC, 0 replies.
- Query - Compression - posted by ram kumar <ra...@gmail.com> on 2015/08/24 08:49:12 UTC, 1 replies.
- Metrics to monitor in Kafka - posted by Debraj Manna <su...@gmail.com> on 2015/08/25 09:28:03 UTC, 1 replies.
- 0.8.x - posted by Damian Guy <da...@gmail.com> on 2015/08/25 11:29:25 UTC, 3 replies.
- kafka producer-perf-test.sh compression-codec not working - posted by Prabhjot Bharaj <pr...@gmail.com> on 2015/08/25 13:47:13 UTC, 6 replies.
- Storing offsets in ZooKeeper for a SimpleConsumer - posted by Buck Ryan <fr...@rjmetrics.com> on 2015/08/25 15:58:32 UTC, 1 replies.
- Kafka tools | zookeeper-shell.sh input args doesn't work - posted by João Reis <jo...@blip.pt> on 2015/08/25 16:04:45 UTC, 1 replies.
- Fwd: [kafka-clients] Re: Get kafka connection status - posted by yoel g <yo...@gmail.com> on 2015/08/25 22:10:33 UTC, 0 replies.
- Not able to find release version with patch jira-1591 - posted by Amar <am...@gmail.com> on 2015/08/26 01:18:27 UTC, 1 replies.
- Mirror a partition of a topic - posted by Binh Nguyen Van <bi...@gmail.com> on 2015/08/26 05:35:45 UTC, 4 replies.
- Issue when enabling SSL on broker - posted by "Xiang Zhou (Samuel)" <zh...@gmail.com> on 2015/08/26 05:42:02 UTC, 3 replies.
- Re: Painfully slow kafka recovery / cluster breaking - posted by Jörg Wagner <jo...@1und1.de> on 2015/08/26 14:58:19 UTC, 1 replies.
- Reg Leader re-election when leader crashes - posted by Amar <am...@gmail.com> on 2015/08/26 22:36:29 UTC, 1 replies.
- Http Kafka producer - posted by Hemanth Abbina <He...@eiqnetworks.com> on 2015/08/27 00:45:29 UTC, 9 replies.
- Lets improve our ranking - posted by Alexa Herman <al...@monetize-app.com> on 2015/08/27 16:18:27 UTC, 0 replies.
- Example of "Offset Commit" suing SimpleConsumer API? - posted by shahab <sh...@gmail.com> on 2015/08/28 10:07:10 UTC, 2 replies.
- Re: How can I unsubscribe from this mailing list - posted by Philip Potter <ph...@digital.cabinet-office.gov.uk> on 2015/08/28 12:02:18 UTC, 0 replies.
- KafkaProducer recovery/restart if broker dies - posted by Alexey Sverdelov <al...@googlemail.com> on 2015/08/28 15:36:31 UTC, 3 replies.
- SSL between Kafka and Spark Streaming API - posted by Cassa L <lc...@gmail.com> on 2015/08/28 20:00:18 UTC, 8 replies.
- Mirror maker SSL support - posted by "Xiang Zhou (Samuel)" <zh...@gmail.com> on 2015/08/28 21:01:26 UTC, 3 replies.
- Failed toString() invocation in producer.send() - posted by "Datta, Saurav" <sd...@paypal.com.INVALID> on 2015/08/28 21:18:22 UTC, 0 replies.
- Get kafka connection status - posted by yoel g <yo...@gmail.com> on 2015/08/30 09:16:31 UTC, 1 replies.
- update topic broker list when broker changes - posted by Emmanuel <el...@msn.com> on 2015/08/30 20:22:06 UTC, 1 replies.
- Performance Test Inquiries - posted by explorer <ji...@gmail.com> on 2015/08/31 12:14:20 UTC, 3 replies.
- Question regarding to reconnect.backoff.ms - posted by Steve Tian <st...@gmail.com> on 2015/08/31 19:30:17 UTC, 0 replies.
- High level consumer offset check in Java - posted by Hema Bhatia <He...@apollo.edu> on 2015/08/31 19:33:09 UTC, 0 replies.
- virtualized kafka - posted by allen chan <al...@gmail.com> on 2015/08/31 20:09:26 UTC, 1 replies.