users@kafka.apache.org, 2018-05

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

- ApacheCon North America 2018 schedule is now live. - posted by Rich Bowen <rb...@apache.org> on 2018/05/01 12:36:05 UTC, 0 replies.
- Kafka-Connect : Invalid value java.sql.SQLException: No suitable driver found for jdbc:mysql://127.0.0.1:3306/connect_test - posted by Jagannath Bilgi <js...@yahoo.com.INVALID> on 2018/05/01 12:52:05 UTC, 3 replies.
- Re: Workaround for KTable/KTable join followed by groupBy and aggregate/count can result in duplicated results KAFKA-4609? - posted by Artur Mrozowski <ar...@gmail.com> on 2018/05/01 17:40:25 UTC, 2 replies.
- Re: Using Kafka CLI without specifying the URLs every single time? - posted by Horváth Péter Gergely <ho...@gmail.com> on 2018/05/02 14:10:16 UTC, 0 replies.
- ClassCastException in KStreams job for SessionWindow aggregation - posted by Conrad Crampton <co...@gmail.com> on 2018/05/02 15:12:09 UTC, 3 replies.
- Spread log segment deletion over a couple hours - posted by Vincent Rischmann <vi...@rischmann.fr> on 2018/05/02 18:52:50 UTC, 2 replies.
- Re: kafka error after upgrading to 1.1.0: “the state store…may have migrated to another instance” - posted by Guozhang Wang <wa...@gmail.com> on 2018/05/02 20:12:13 UTC, 0 replies.
- Re: KStreams API Usage - posted by Guozhang Wang <wa...@gmail.com> on 2018/05/02 20:17:01 UTC, 0 replies.
- Re: Kafka streams state directory - help - posted by "Matthias J. Sax" <ma...@confluent.io> on 2018/05/03 11:38:13 UTC, 0 replies.
- Building schema-registry module fails - kafka-connect-hdfs FAQ - posted by Kanagha <er...@gmail.com> on 2018/05/03 17:40:04 UTC, 1 replies.
- Kafka-connect - posted by Jagannath Bilgi <js...@yahoo.com.INVALID> on 2018/05/03 18:22:26 UTC, 9 replies.
- What is the performance impact of setting max.poll.records=1 - posted by Mads Tandrup <Ma...@schneider-electric.com> on 2018/05/04 11:19:06 UTC, 3 replies.
- [DISCUSS] KIP-295: Add Streams Configuration Allowing for Optional Topology Optimization - posted by Bill Bejeck <bb...@gmail.com> on 2018/05/07 17:26:25 UTC, 0 replies.
- CFP: Kafka Summit San Francisco, 2018 - posted by Jun Rao <ju...@confluent.io> on 2018/05/08 22:08:09 UTC, 0 replies.
- Help needed for Upgrade from 0.10.2 to 1.1 - posted by Darshan <pu...@gmail.com> on 2018/05/09 07:29:17 UTC, 0 replies.
- Graceful Shutdown always fails on multi-broker setup (Windows) - posted by "M. Manna" <ma...@gmail.com> on 2018/05/09 10:02:38 UTC, 3 replies.
- Kafka offset problem when using Spark Streaming... - posted by Pena Quijada Alexander <a....@reply.it> on 2018/05/09 10:42:17 UTC, 3 replies.
- Log Compaction configuration over all topics in cluster - posted by David Espinosa <es...@gmail.com> on 2018/05/09 12:21:56 UTC, 0 replies.
- Log Cleanup Support for Windows [KAFKA-1194] - posted by "M. Manna" <ma...@gmail.com> on 2018/05/09 13:51:27 UTC, 2 replies.
- Merging clusters or changing zk root - posted by Luke Steensen <lu...@braintreepayments.com> on 2018/05/09 13:58:29 UTC, 0 replies.
- Kafka as K/V store - posted by Sudhir Babu Pothineni <sb...@gmail.com> on 2018/05/09 14:46:11 UTC, 3 replies.
- How to do failover in case of single replica topics on 3 node kafka cluster - posted by Gangadhar Mylapuram <ga...@gmail.com> on 2018/05/09 15:18:28 UTC, 1 replies.
- Kafka Consumer Group cmd line Tool - Group is missing even though it's present - posted by "M. Manna" <ma...@gmail.com> on 2018/05/09 15:59:52 UTC, 0 replies.
- multi-disk brokers data replication - posted by Andrian Jardan <an...@gmail.com> on 2018/05/10 08:49:45 UTC, 4 replies.
- No records on consumer poll when upgraded to 2.11-1.1.0 - posted by "M. Manna" <ma...@gmail.com> on 2018/05/10 17:47:00 UTC, 1 replies.
- Consulting ReadOnlyKeyValueStore from Processor can lead to deadlock - posted by Steven Schlansker <ss...@opentable.com> on 2018/05/10 17:48:04 UTC, 3 replies.
- Producer#commitTransaction() Not Being Called if New Records Aren't Processed by StreamTask - posted by David Chu <da...@appdynamics.com> on 2018/05/10 20:33:06 UTC, 3 replies.
- Re: Removing the Kafka DEBUG logs in catalina.out using log4j.properties - posted by Karthick Kumar <kk...@apptivo.co.in> on 2018/05/11 07:28:33 UTC, 5 replies.
- How many are supported by kafka cluster - posted by Sathish Anandapu <sa...@nuovosolutions.com> on 2018/05/11 09:01:43 UTC, 1 replies.
- Re: Kafka consumer slowly consume the data - posted by Karthick Kumar <kk...@apptivo.co.in> on 2018/05/11 13:41:23 UTC, 2 replies.
- Kafka TotalTimeMs time interval - posted by Shyam P R <sh...@gmail.com> on 2018/05/11 14:01:10 UTC, 0 replies.
- LogCleaner thread failing after upgrading to 2.11-1.1.0 - posted by "M. Manna" <ma...@gmail.com> on 2018/05/11 17:24:25 UTC, 0 replies.
- Consumer/Producer different kerberos.service.name same jvm - posted by "Zieger, Antoine" <An...@morganstanley.com> on 2018/05/11 17:55:41 UTC, 0 replies.
- Help Needed: Leadership Issue upon Kafka Upgrade (ZooKeeper 3.4.9) - posted by Raghav <ra...@gmail.com> on 2018/05/11 22:16:57 UTC, 2 replies.
- Re: SSL metrics for simple Producer/Consumer implementation - posted by Jaikiran Pai <ja...@gmail.com> on 2018/05/12 06:38:49 UTC, 0 replies.
- Kafka 2.11-1.1.0 crashes brokers and brings cluster down on Windows - posted by "M. Manna" <ma...@gmail.com> on 2018/05/12 20:42:50 UTC, 7 replies.
- Does anyone publish or subscribe kafka topic in TestNG? - posted by James Yu <cy...@gmail.com> on 2018/05/13 08:16:51 UTC, 1 replies.
- Kafka streaming partition assignment - posted by Liam Clarke <li...@adscale.co.nz> on 2018/05/14 02:52:01 UTC, 2 replies.
- Unable to recover from offline partition - posted by Di Shang <sh...@au1.ibm.com> on 2018/05/14 04:13:08 UTC, 0 replies.
- WG: Exactly Once, Producer configuration - posted by Th...@t-systems.com on 2018/05/14 16:13:53 UTC, 1 replies.
- How to reset the GroupCoordinator's saved session timeout for a group? - posted by Jeff Widman <je...@jeffwidman.com> on 2018/05/14 16:58:35 UTC, 0 replies.
- Exception stopps data processing (Kafka Streams) - posted by Claudia Wegmann <c....@kasasi.de> on 2018/05/15 13:30:44 UTC, 3 replies.
- [VOTE] KIP-295: Add Streams Configuration Allowing for Optional Topology Optimization - posted by Bill Bejeck <bb...@gmail.com> on 2018/05/15 20:45:12 UTC, 0 replies.
- Kafka Consumer - WARN INVALID_FETCH_SESSION_EPOCH - posted by SenthilKumar K <se...@gmail.com> on 2018/05/16 09:14:03 UTC, 0 replies.
- Issue with GlobalKTable on sink topic - posted by Daniele Tria <da...@radicalbit.io> on 2018/05/16 13:30:32 UTC, 5 replies.
- lost committed offsets during reassignment - posted by Girish Aher <gi...@gmail.com> on 2018/05/16 15:18:16 UTC, 0 replies.
- Issue with ISR Shrink and ISR Expand - posted by Arunkumar <pm...@yahoo.com.INVALID> on 2018/05/16 17:16:30 UTC, 0 replies.
- Kafka Scala debugging and diagnostics - posted by "M. Manna" <ma...@gmail.com> on 2018/05/16 21:46:29 UTC, 6 replies.
- Kafka clients timeouts - posted by Maksym Pidlisnyi <ma...@gmail.com> on 2018/05/17 07:30:36 UTC, 0 replies.
- Kafka brokers listen on multiple ports - posted by Dan Gal <da...@gmail.com> on 2018/05/18 11:01:03 UTC, 1 replies.
- Need help - posted by Sandip Mavani <sa...@avinashi.com> on 2018/05/18 12:34:19 UTC, 1 replies.
- streams windowing question - posted by Peter Kleinmann <nn...@gmail.com> on 2018/05/18 21:56:41 UTC, 4 replies.
- Re: Kafka 1.0 ack=all issue - posted by Rob Verkuylen <ro...@verkuylen.net> on 2018/05/20 06:38:12 UTC, 0 replies.
- Best practices - posted by Pavel Sapozhnikov <pa...@gmail.com> on 2018/05/20 18:00:20 UTC, 3 replies.
- Kafka consumer to unzip stream of .gz files and read - posted by mayur shah <ma...@gmail.com> on 2018/05/21 05:28:56 UTC, 3 replies.
- Unclear client-to-broker communication - posted by chw <ch...@gmx.de> on 2018/05/21 08:56:00 UTC, 1 replies.
- Tools to view logs and/or clean up problems? - posted by Skip Montanaro <sk...@gmail.com> on 2018/05/21 12:46:09 UTC, 1 replies.
- Kafka behind NAT - posted by 周正虎 <yz...@126.com> on 2018/05/21 13:05:43 UTC, 1 replies.
- Architectural patterns for full log replayability - posted by Edmondo Porcu <ed...@gmail.com> on 2018/05/22 09:25:51 UTC, 0 replies.
- How does KStream transform performs repartitioning? - posted by Edmondo Porcu <ed...@gmail.com> on 2018/05/22 10:12:46 UTC, 1 replies.
- Failed on publish to Kafka - posted by Omer Litov <om...@imperva.com> on 2018/05/22 15:32:49 UTC, 4 replies.
- Increase in Memory Cache After Upgrading to 1.1.0 - posted by ZigSphere Tech <zi...@zigsphere.com> on 2018/05/22 23:06:48 UTC, 0 replies.
- Frequent consumer rebalances, auto commit failures - posted by Shantanu Deshmukh <sh...@gmail.com> on 2018/05/23 04:58:11 UTC, 2 replies.
- How to achieve exactly one semantic in Kafka consumer - posted by Karthick Kumar <kk...@apptivo.co.in> on 2018/05/23 06:30:58 UTC, 1 replies.
- Frequent consumer rebalance, auto commit failures - posted by Shantanu Deshmukh <sh...@gmail.com> on 2018/05/23 10:18:02 UTC, 11 replies.
- Metric for follower's replication latency - posted by Uddhav Arote <ar...@gmail.com> on 2018/05/23 10:54:20 UTC, 0 replies.
- Understanding rate metrics - posted by Rodrigo Borges Pereira <ro...@gmail.com> on 2018/05/23 12:54:09 UTC, 0 replies.
- Forcing un-assignment of partitions for Kafka application - posted by Edmondo Porcu <ed...@gmail.com> on 2018/05/23 13:41:52 UTC, 1 replies.
- Non duplicated WindowStore in Kstream - KStream Join? - posted by Edmondo Porcu <ed...@gmail.com> on 2018/05/23 15:56:11 UTC, 1 replies.
- kafka-spark-stream-cassandra - posted by Jagannath Bilgi <js...@yahoo.com.INVALID> on 2018/05/23 19:55:21 UTC, 0 replies.
- Re: Monitoring and Alerting - posted by Mike Heffner <mi...@solarwinds.cloud> on 2018/05/23 22:45:18 UTC, 0 replies.
- Getting message '(Re-)joining group' every 5 seconds - posted by Caroline Even <ca...@gmail.com> on 2018/05/24 06:41:02 UTC, 0 replies.
- kafka manual commit vs auto commit - posted by Shantanu Deshmukh <sh...@gmail.com> on 2018/05/24 12:29:19 UTC, 2 replies.
- Ktable from compacted topic is using a changelog topic - posted by Todd Hughes <ju...@hotmail.com> on 2018/05/24 23:52:07 UTC, 1 replies.
- subscribe mail list - posted by 逐风者的祝福 <18...@qq.com> on 2018/05/25 03:16:26 UTC, 1 replies.
- Reliable way to purge data from Kafka topics - posted by Shantanu Deshmukh <sh...@gmail.com> on 2018/05/25 06:54:00 UTC, 5 replies.
- Can anyone help me to send messages in their original order? - posted by Raymond Xie <xi...@gmail.com> on 2018/05/26 03:56:42 UTC, 5 replies.
- Facing Duplication Issue in kakfa - posted by Karthick Kumar <kk...@apptivo.co.in> on 2018/05/28 07:17:51 UTC, 4 replies.
- Facing Duplication in consumer - posted by Dinesh Subramanian <ds...@apptivo.co.in> on 2018/05/28 08:59:52 UTC, 2 replies.
- UnknownTopicOrPartitionException & NotLeaderForPartitionException upon replication of topics. - posted by "Srinivas, Kaushik (Nokia - IN/Bangalore)" <ka...@nokia.com> on 2018/05/28 10:35:20 UTC, 0 replies.
- Effect of settings segment.ms and retention.ms not accurate - posted by Shantanu Deshmukh <sh...@gmail.com> on 2018/05/28 11:48:14 UTC, 5 replies.
- Incorrect result Kstream-Kstream Join with asymmetric time window - posted by ma...@orange.com on 2018/05/28 15:33:51 UTC, 0 replies.
- Producing a null AVRO record on a compacted topic with kafka-avro-console-producer - posted by Edmondo Porcu <ed...@gmail.com> on 2018/05/29 07:24:40 UTC, 0 replies.
- Correct usage of consumer groups - posted by Shantanu Deshmukh <sh...@gmail.com> on 2018/05/29 07:26:39 UTC, 4 replies.
- Long start time for consumer - posted by Shantanu Deshmukh <sh...@gmail.com> on 2018/05/29 11:51:13 UTC, 10 replies.
- retention.ms not honored for topic - posted by Thomas Hays <ha...@gmail.com> on 2018/05/29 16:01:42 UTC, 3 replies.
- Mirrormaker producing to only one partition in a topic - posted by Ryan En <Ry...@hotmail.com> on 2018/05/29 20:28:40 UTC, 1 replies.
- producing with acks=all (2 replicas) is 100x slower and fails on timeouts with Kafka 1.0.1 - posted by Ofir Manor <of...@equalum.io> on 2018/05/29 21:28:39 UTC, 0 replies.
- coordinator load + OffsetFetchRequest error = consumption failure - posted by Emmett Butler <em...@parsely.com> on 2018/05/29 22:52:07 UTC, 0 replies.
- Errors observed in performance test using kafka-producer-perf-test.sh| - posted by Localhost shell <un...@gmail.com> on 2018/05/30 08:19:39 UTC, 0 replies.
- Kafka Connect Fails - java.lang.OutOfMemoryError: Direct buffer memory - posted by Bunty Ray <bu...@gmail.com> on 2018/05/30 13:18:10 UTC, 0 replies.
- Question regarding offset commits by Consumers - docs - posted by "M. Manna" <ma...@gmail.com> on 2018/05/30 16:23:02 UTC, 2 replies.
- Artemis Source connector into apache kafka. - posted by meow licous <me...@gmail.com> on 2018/05/30 23:57:13 UTC, 1 replies.
- Issue when using username / password CachedSchemaRegistryClient - posted by Patrick Plaatje <pp...@gmail.com> on 2018/05/31 09:22:49 UTC, 1 replies.
- Kafka Consumer SASL fails after cluster restart - posted by Johan Rask <jo...@klipsk.se> on 2018/05/31 11:15:43 UTC, 0 replies.
- Logging authentication/authorization failures - posted by Gérald Quintana <ge...@gmail.com> on 2018/05/31 12:04:41 UTC, 1 replies.
- Best Practice for Consumer Liveliness and avoid frequent rebalancing - posted by "M. Manna" <ma...@gmail.com> on 2018/05/31 12:29:47 UTC, 0 replies.
- StreamsConfig.DEFAULT_PRODUCTION_EXCEPTION_HANDLER_CLASS_CONFIG - posted by Sumit Baurai <su...@devoteam.com> on 2018/05/31 12:48:42 UTC, 2 replies.
- Round-Robin assignment when non-nullable record key - posted by "M. Manna" <ma...@gmail.com> on 2018/05/31 13:54:29 UTC, 2 replies.
- Kafka Producer Query - how to increase throughput of producer - posted by Gnanasoundari Soundarajan <gn...@in.man.eu> on 2018/05/31 15:22:56 UTC, 0 replies.
- REMINDER: Apache EU Roadshow 2018 in Berlin is less than 2 weeks away! - posted by sh...@apache.org on 2018/05/31 20:54:32 UTC, 0 replies.
- Logcompaction with Kafka and how to send nulls or empty payloads - posted by Guillermo Ortiz <ko...@gmail.com> on 2018/05/31 22:00:09 UTC, 0 replies.