users@kafka.apache.org, 2017-10

You are viewing a plain text version of this content. The canonical link for it is here.

- Kafka 0.10: Two Kafka Consumers, two different topics, same group ID - commit exception occurs - posted by A Gardner <al...@gmail.com> on 2017/10/01 16:02:59 UTC, 1 replies.
- Replication does not start because of OuOfOrderSequenceException - posted by Stas Chizhov <sc...@gmail.com> on 2017/10/02 10:28:47 UTC, 3 replies.
- Using Kafka on DC/OS + Marathon - posted by Valentin Forst <va...@aseno.de> on 2017/10/02 11:39:30 UTC, 7 replies.
- The idea of "composite key" to make log compaction more flexible - question / proposal - posted by Michal Michalski <mi...@zalando.ie> on 2017/10/02 13:29:11 UTC, 2 replies.
- Fwd: Consumer Offsets partition skew on Kafka 0.10.1.1 - posted by Marcos Juarez <mj...@gmail.com> on 2017/10/03 00:57:27 UTC, 1 replies.
- Re: out of order sequence number in exactly once streams - posted by Sameer Kumar <sa...@gmail.com> on 2017/10/03 06:29:16 UTC, 3 replies.
- Re: Is anyone using MX4J loader? - posted by Dong Lin <li...@gmail.com> on 2017/10/03 08:51:57 UTC, 0 replies.
- Kafka Streams Avro SerDe version/id caching - posted by Kristopher Kane <kk...@gmail.com> on 2017/10/03 13:36:53 UTC, 4 replies.
- kafka-console-producer.sh --security-protocol - posted by Pekka Sarnila <sa...@adit.fi> on 2017/10/03 14:17:21 UTC, 5 replies.
- Re: SSL setup in Kafka 2.10.0.10.2.1 for keystore and truststore files - posted by Awadhesh Gupta <aw...@gmail.com> on 2017/10/03 17:44:18 UTC, 2 replies.
- Hostname validation in Kafka for SSL authentication - posted by Awadhesh Gupta <aw...@gmail.com> on 2017/10/03 17:54:58 UTC, 0 replies.
- Fwd: TimeoutException: Timed out waiting for a node assignment. when AdminClient attempts to create topics - posted by Elliot Metsger <em...@gmail.com> on 2017/10/04 13:13:16 UTC, 0 replies.
- Kafka - leadership - posted by Tomer Shavit <mo...@gmail.com> on 2017/10/04 13:30:14 UTC, 3 replies.
- Correct way to increase replication factor for kafka-streams internal topics - posted by Dmitriy Vsekhvalnov <dv...@gmail.com> on 2017/10/04 13:31:27 UTC, 2 replies.
- Kafka stream api to consume json values using kafka connect json deserializer - posted by "Phani Kumar Yadavilli -X (phyadavi - ALLEGIS SERVICES INDIA PRIVATE LIMITED at Cisco)" <ph...@cisco.com> on 2017/10/04 14:13:17 UTC, 1 replies.
- Configuration of Kafka Connect REST interface - posted by Jakub Scholz <ja...@scholz.cz> on 2017/10/04 14:44:08 UTC, 1 replies.
- timeout value for consumer.poll - posted by srimugunthan dhandapani <sr...@gmail.com> on 2017/10/04 18:12:52 UTC, 0 replies.
- Quotas to throttle the MBytes/sec for a kafka topic - posted by Anu P <ia...@gmail.com> on 2017/10/04 22:02:34 UTC, 1 replies.
- Kafka ACL - Access Denied while publishing the message - posted by Awadhesh Gupta <aw...@gmail.com> on 2017/10/05 03:55:15 UTC, 2 replies.
- Topics and Partitions - posted by Josh Maidana <jo...@gmail.com> on 2017/10/05 08:37:17 UTC, 5 replies.
- Store - RocksDB - aging data off - posted by Kristopher Kane <kk...@gmail.com> on 2017/10/05 16:15:38 UTC, 2 replies.
- kafka-streams configuration for high resilience (crashing when broker crashing) ? - posted by Dmitriy Vsekhvalnov <dv...@gmail.com> on 2017/10/05 16:45:49 UTC, 6 replies.
- Re: Kafka Mirror Maker Automation - posted by "Kannappan, Saravanan (Contractor)" <Sa...@comcast.com> on 2017/10/05 18:03:06 UTC, 0 replies.
- Re: Kafka Mirror Maker Automation - posted by Tom Bentley <t....@gmail.com> on 2017/10/05 19:20:16 UTC, 0 replies.
- Re: Replication throttling - posted by Ben Stopford <be...@confluent.io> on 2017/10/05 22:49:17 UTC, 0 replies.
- Scala API - posted by Josh Maidana <jo...@gmail.com> on 2017/10/06 03:45:57 UTC, 3 replies.
- AKKA KAFKA Stream - posted by Josh Meraj Maidana <jo...@gmail.com> on 2017/10/06 04:09:48 UTC, 0 replies.
- Serve interactive queries from standby replicas - posted by Stas Chizhov <sc...@gmail.com> on 2017/10/06 11:18:27 UTC, 8 replies.
- Compacted topic, entry deletion, kafka 0.11.0.0 - posted by Asko Alhoniemi <as...@lekane.com> on 2017/10/06 13:17:17 UTC, 1 replies.
- Kafka Streams with embedded RocksDB - posted by Valentin Forst <va...@aseno.de> on 2017/10/06 13:39:38 UTC, 4 replies.
- __consumers topic is overloaded - posted by Alexander Petrovsky <as...@gmail.com> on 2017/10/06 13:46:42 UTC, 1 replies.
- kafka broker loosing offsets? - posted by Dmitriy Vsekhvalnov <dv...@gmail.com> on 2017/10/06 14:52:13 UTC, 26 replies.
- Kafka Stream Deadman - posted by Trevor Huey <tr...@joltup.com> on 2017/10/06 21:16:09 UTC, 1 replies.
- NPE on ConsumerRecords$ConcatenatedIterable$1.makeNext() while iterating records - posted by Michael Keinan <mi...@capitolis.com> on 2017/10/08 13:29:31 UTC, 6 replies.
- Re: Improving Kafka State Store performance - posted by Guozhang Wang <wa...@gmail.com> on 2017/10/08 23:43:30 UTC, 0 replies.
- How to use ApiVersionRequest and ApiVersionResponse - posted by Hari Krishna <kr...@gmail.com> on 2017/10/09 06:33:35 UTC, 1 replies.
- How to reduce time for consumer to take over? - posted by Christian Schneider <ch...@die-schneider.net> on 2017/10/09 12:29:05 UTC, 1 replies.
- I meet some problem i wanna use kafka connect oracle and hdfs then use hive。 message:org.apache.hadoop.hive.serde2.avro.AvroSerdeException Invalid precision or scale for decimal type - posted by han cheryl <cr...@gmail.com> on 2017/10/09 12:43:55 UTC, 0 replies.
- subscription - posted by Emanuele Ianni <di...@gmail.com> on 2017/10/09 15:27:19 UTC, 1 replies.
- java.lang.NoSuchMethodError: scala.collection.GenTraversableOnce.$init - posted by am...@oracle.com on 2017/10/09 18:30:25 UTC, 1 replies.
- Fwd: Consumer service that supports retry with exponential backoff - posted by John Walker <jo...@gmail.com> on 2017/10/09 21:41:27 UTC, 3 replies.
- Kafka Streams Transformer: context.forward() from different thread - posted by Murad Mamedov <ma...@muradm.net> on 2017/10/10 07:16:10 UTC, 1 replies.
- Add Kafka user list - posted by "shawnding (丁晓坤)" <sh...@tencent.com> on 2017/10/10 09:07:35 UTC, 3 replies.
- Incorrect consumer offsets after broker restart 0.11.0.0 - posted by Phil Luckhurst <ph...@encycle.com> on 2017/10/10 12:20:09 UTC, 5 replies.
- kafka-streams dying if can't create internal topics - posted by Dmitriy Vsekhvalnov <dv...@gmail.com> on 2017/10/10 12:24:00 UTC, 4 replies.
- Getting started with stream processing - posted by RedShift <re...@telenet.be> on 2017/10/10 13:27:02 UTC, 4 replies.
- Custom converter with Kafka Connect ? - posted by Jehan Bruggeman <je...@gmail.com> on 2017/10/10 13:31:08 UTC, 6 replies.
- Kafka cluster Error - posted by "Kannappan, Saravanan (Contractor)" <Sa...@comcast.com> on 2017/10/10 22:35:46 UTC, 1 replies.
- Re: Kafka cluster Error - posted by Avinash Shahdadpuri <av...@gmail.com> on 2017/10/10 22:38:04 UTC, 2 replies.
- [VOTE] 1.0.0 RC0 - posted by Guozhang Wang <wa...@gmail.com> on 2017/10/11 01:34:09 UTC, 3 replies.
- Questions about Apache Kafka messages type/size and publish/subscribe - posted by Heloise Chevalier <hc...@gmail.com> on 2017/10/11 07:51:42 UTC, 0 replies.
- Retrieve unacknowledged messages from partition - posted by Tarik Courdy <ta...@gmail.com> on 2017/10/11 15:51:40 UTC, 0 replies.
- Kafka Consumer - org.apache.kafka.common.errors.TimeoutException: Failed to get offsets by times in 305000 ms - posted by SenthilKumar K <se...@gmail.com> on 2017/10/11 18:37:57 UTC, 0 replies.
- Figuring out lag within Java consumer application - posted by Manan G <ma...@gmail.com> on 2017/10/12 22:31:48 UTC, 3 replies.
- Backfill historical data - posted by Riccardo Ferrari <fe...@gmail.com> on 2017/10/12 22:52:05 UTC, 0 replies.
- Can someone explain how does __consumer_offsets work? - posted by Gytis <gy...@fmu1.net> on 2017/10/13 07:34:32 UTC, 0 replies.
- How to upsert a relational database from kafka - posted by Uwe Geercken <uw...@web.de> on 2017/10/13 19:29:18 UTC, 2 replies.
- Number of Topics and Partitions in recent Kafka? - posted by Sven Ludwig <s_...@gmx.de> on 2017/10/13 19:55:58 UTC, 1 replies.
- [VOTE] 1.0.0 RC1 - posted by Guozhang Wang <wa...@gmail.com> on 2017/10/13 20:12:31 UTC, 6 replies.
- kafka replication all crashed - posted by haiyangyu <st...@163.com> on 2017/10/16 10:43:24 UTC, 1 replies.
- replication all crashed - posted by haiyangyu <st...@163.com> on 2017/10/16 15:10:44 UTC, 0 replies.
- KIP-99 streams global ktable - slowly changing dimension type 2 supported? - posted by chris snow <ch...@gmail.com> on 2017/10/16 19:51:27 UTC, 3 replies.
- Re: [kafka-clients] Re: [VOTE] 1.0.0 RC1 - posted by Jun Rao <ju...@confluent.io> on 2017/10/16 21:19:31 UTC, 1 replies.
- Kafka Streams 0.11.0.1 Rebalancing Delay - posted by Johan Genberg <jo...@gmail.com> on 2017/10/17 04:55:05 UTC, 12 replies.
- Kafka connect rebalance problem - posted by Dhawan Gajendran <dh...@datavisor.com> on 2017/10/17 06:30:02 UTC, 2 replies.
- Kafka 0.9.0.1 Direct buffer memory OOM - posted by 杨文 <ia...@gmail.com> on 2017/10/17 09:32:09 UTC, 1 replies.
- general query. - posted by Jaswinder Singh <si...@gmail.com> on 2017/10/17 11:46:50 UTC, 2 replies.
- [VOTE] 1.0.0 RC2 - posted by Guozhang Wang <wa...@gmail.com> on 2017/10/17 16:47:40 UTC, 0 replies.
- Can you please subscribe me - posted by Nikhil Deore <de...@gmail.com> on 2017/10/17 17:36:54 UTC, 1 replies.
- Can you please subscribe me in this project - posted by Nikhil Deore <de...@gmail.com> on 2017/10/17 17:44:51 UTC, 2 replies.
- KTable Tombstone and expiry of records in Session Window - posted by Ahmad Alkilani <ah...@dreamworks.com> on 2017/10/17 18:47:30 UTC, 1 replies.
- Can I commit the same offset? Can I back up? - posted by Skip Montanaro <sk...@gmail.com> on 2017/10/17 20:02:33 UTC, 1 replies.
- Regarding kafka-manager topics parameters - posted by Pavan Patani <pa...@adcolony.com> on 2017/10/18 04:36:11 UTC, 1 replies.
- Re: Max message size and compression - posted by Krzysztof Zarzycki <k....@gmail.com> on 2017/10/18 15:20:20 UTC, 1 replies.
- Kafka Streams : Problem with Global State Restoration - posted by Tony John <to...@gmail.com> on 2017/10/18 15:51:41 UTC, 2 replies.
- Re: [kafka-clients] [VOTE] 1.0.0 RC2 - posted by Jun Rao <ju...@confluent.io> on 2017/10/18 16:41:58 UTC, 3 replies.
- Re: Kafka FileStreamSinkConnector handling of bad messages - posted by Marina Popova <pp...@protonmail.com> on 2017/10/18 17:39:37 UTC, 3 replies.
- Group Coordinator Fail Recovery on 0.11.0.1 - posted by Fabio Yamada <fa...@gmail.com> on 2017/10/18 18:19:01 UTC, 0 replies.
- Enabling SASL_PLAINTEXT for Kafka REST - posted by Manoj Murumkar <ma...@gmail.com> on 2017/10/18 20:19:32 UTC, 0 replies.
- KafkaConsumer.poll() API Behavior - posted by Manan G <ma...@gmail.com> on 2017/10/18 22:12:55 UTC, 0 replies.
- Fix the wiki entry for KIP-62? - posted by Jeff Widman <je...@jeffwidman.com> on 2017/10/19 06:58:58 UTC, 1 replies.
- Keeping two topics in-sync - posted by Skip Montanaro <sk...@gmail.com> on 2017/10/19 14:05:44 UTC, 0 replies.
- Streams equivalent of Storm's Fields Grouping - posted by Kristopher Kane <kk...@gmail.com> on 2017/10/20 01:36:11 UTC, 1 replies.
- reg kafka API versions - posted by pravin kumar <pk...@gmail.com> on 2017/10/20 09:12:49 UTC, 1 replies.
- reg Kafka Node num - posted by pravin kumar <pk...@gmail.com> on 2017/10/20 09:14:04 UTC, 4 replies.
- Kafka inter broker protocol version - posted by Zbyněk Bartoš <z....@quadient.com> on 2017/10/20 15:19:37 UTC, 0 replies.
- Micro-batching in Kafka streams - redux - posted by Shrijeet Paliwal <sh...@gmail.com> on 2017/10/20 19:36:00 UTC, 1 replies.
- Get Broker metrics timeout - posted by Json Tu <ka...@126.com> on 2017/10/22 16:01:26 UTC, 1 replies.
- left join between PageViews(KStream) & UserProfile (KTable) - posted by karan alang <ka...@gmail.com> on 2017/10/22 19:30:16 UTC, 2 replies.
- Get broker metrics timeout - posted by 涂扬 <tu...@meituan.com> on 2017/10/23 00:01:38 UTC, 1 replies.
- Process and punctuate contract - posted by Tobias Adamson <to...@stargazer.com.sg> on 2017/10/23 06:43:46 UTC, 3 replies.
- Kafka topic monitoring - posted by Amrit Jangid <ja...@gmail.com> on 2017/10/23 12:56:27 UTC, 0 replies.
- Keyed messages distribution in partitions - posted by Andrea Giordano <an...@gmail.com> on 2017/10/23 15:23:05 UTC, 6 replies.
- [VOTE] 1.0.0 RC3 - posted by Guozhang Wang <wa...@gmail.com> on 2017/10/24 01:00:50 UTC, 2 replies.
- Re: [kafka-clients] [VOTE] 1.0.0 RC3 - posted by Dana Powers <da...@gmail.com> on 2017/10/24 05:26:14 UTC, 0 replies.
- StreamTasks - posted by pravin kumar <pk...@gmail.com> on 2017/10/24 09:10:11 UTC, 1 replies.
- regarding number of Stream Tasks - posted by pravin kumar <pk...@gmail.com> on 2017/10/24 09:14:42 UTC, 4 replies.
- Apache Kafka Cluster Setup - posted by Vincenzo D'Amore <v....@gmail.com> on 2017/10/24 10:51:51 UTC, 0 replies.
- Kafka Streams 0.11.0.1 - Task Assignment Stickiness Behavior - posted by Laven Sukumaran <la...@autonomic.ai> on 2017/10/24 14:21:17 UTC, 7 replies.
- When simulating a full EBS volume for Kafka, the service doesn't explode. Why? - posted by "Tote, Caleb" <ct...@ea.com> on 2017/10/24 15:24:34 UTC, 0 replies.
- Kafka source code - Build Error - posted by Vishal Shukla <sh...@gmail.com> on 2017/10/24 19:21:16 UTC, 5 replies.
- Kafka Streams Hang While Committing - posted by Sicheng Liu <lz...@gmail.com> on 2017/10/24 20:17:04 UTC, 1 replies.
- JOB | Permanent Remote Cassandra Database Engineer - posted by James Tobin <ja...@gmail.com> on 2017/10/25 01:45:17 UTC, 0 replies.
- Log Compaction Not Picking up Topic - posted by Elmar Weber <in...@elmarweber.org> on 2017/10/25 09:42:50 UTC, 8 replies.
- Re: Log Compaction Not Picking up Topic [solved] - posted by Elmar Weber <in...@elmarweber.org> on 2017/10/25 13:48:07 UTC, 0 replies.
- "Persistence strategy" clarification - posted by Andrea Giordano <an...@gmail.com> on 2017/10/25 15:44:31 UTC, 2 replies.
- Failure to reset consumer offsets for specific topics - posted by Dan Markhasin <mi...@gmail.com> on 2017/10/25 19:11:18 UTC, 14 replies.
- [DISCUSS] KIP-213 Support non-key joining in KTable - posted by Jan Filipiak <Ja...@trivago.com> on 2017/10/25 23:14:27 UTC, 5 replies.
- Consumer poll returning 0 results - posted by Susheel Kumar <su...@gmail.com> on 2017/10/26 01:40:11 UTC, 3 replies.
- Kafka Event Acknowledgement - posted by Hemambika Hema <he...@gmail.com> on 2017/10/27 15:15:32 UTC, 2 replies.
- Help with Mirror Maker config to produce to all partitions in target cluster - posted by Chris Neal <cw...@gmail.com> on 2017/10/27 15:59:50 UTC, 0 replies.
- Kafka producer/consumer quotas (Kafka 0.10) - posted by karan alang <ka...@gmail.com> on 2017/10/27 17:05:21 UTC, 0 replies.
- [VOTE] 1.0.0 RC4 - posted by Guozhang Wang <wa...@gmail.com> on 2017/10/27 17:28:18 UTC, 1 replies.
- Call for Paper: Kafka Summit London 2018 - posted by Gwen Shapira <gw...@confluent.io> on 2017/10/27 19:43:07 UTC, 0 replies.
- Producer performance is awful when acks=all - posted by Vijay Prakash <Vi...@microsoft.com.INVALID> on 2017/10/27 21:42:13 UTC, 0 replies.
- Kafka Connect - posted by Alexander Atanasov <al...@gmail.com> on 2017/10/29 06:51:33 UTC, 1 replies.
- Offsets in Kafka producer start with -1 for new topic - posted by "Thakrar, Jayesh" <jt...@conversantmedia.com> on 2017/10/30 01:55:50 UTC, 2 replies.
- Experimenting with Kafka and OpenSSL - posted by Jaikiran Pai <ja...@gmail.com> on 2017/10/30 08:08:36 UTC, 4 replies.
- Servers Getting disconnected - posted by Yuanjia <yu...@163.com> on 2017/10/30 09:06:33 UTC, 3 replies.
- Mirror partitions from several clusters into one - posted by Alexandr Porunov <al...@gmail.com> on 2017/10/30 11:40:35 UTC, 0 replies.
- Re: Best practices - Using kafka (with http server) as source-of-truth - posted by adslqa cet <ad...@gmail.com> on 2017/10/30 12:27:42 UTC, 0 replies.
- Streams changelog topic retention is high - posted by Sameer Kumar <sa...@gmail.com> on 2017/10/30 12:49:09 UTC, 3 replies.
- How to choose which topic to replicate in MirrorMaker? - posted by Alexandr Porunov <al...@gmail.com> on 2017/10/30 15:54:07 UTC, 2 replies.
- Listing Consumer Groups Per Topic - posted by "Kronmiller, Rory" <Wi...@viasat.com> on 2017/10/30 21:45:00 UTC, 0 replies.
- is it possbile to get the last commit time for certain consumer group to target topic on v0.10.1.1 - posted by "Alex.Chen" <on...@gmail.com> on 2017/10/31 03:48:13 UTC, 0 replies.
- kafka user - posted by Karthigeyan <ka...@gmail.com> on 2017/10/31 07:36:09 UTC, 0 replies.
- Kafka performance - posted by Oussema Ben lamine <ou...@barac.io> on 2017/10/31 10:49:55 UTC, 0 replies.
- ZkUtils.getAllPartitions giving more partition counts. - posted by satyajit vegesna <sa...@gmail.com> on 2017/10/31 18:01:38 UTC, 0 replies.
- KAFKA For System z - posted by "Sultan S. Alsaleem" <Su...@sa.ibm.com> on 2017/10/31 19:38:22 UTC, 0 replies.