users@kafka.apache.org, 2018-07

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

- How to fix ISR/URP when there is no new FetchRequest made? - posted by Henry Cai <hc...@pinterest.com.INVALID> on 2018/07/01 00:49:46 UTC, 0 replies.
- Re: Partitions reassignment is failing in Kafka 1.1.0 - posted by Ted Yu <yu...@gmail.com> on 2018/07/01 01:07:51 UTC, 2 replies.
- Specifying negative number as partition in ProducerRecord prior to 1.1.0 - posted by Debraj Manna <su...@gmail.com> on 2018/07/01 10:24:13 UTC, 0 replies.
- Cannot run the inbuild zookeeper server. - posted by Vineet Herenj <vi...@gmail.com> on 2018/07/01 11:45:42 UTC, 1 replies.
- Re: [VOTE] 0.11.0.3 RC0 - posted by Ismael Juma <is...@juma.me.uk> on 2018/07/01 14:59:01 UTC, 0 replies.
- Re: [VOTE] 1.0.2 RC1 - posted by Ismael Juma <is...@juma.me.uk> on 2018/07/01 17:57:17 UTC, 0 replies.
- Re: [kafka-clients] Re: [VOTE] 0.11.0.3 RC0 - posted by Manikumar <ma...@gmail.com> on 2018/07/01 18:28:29 UTC, 1 replies.
- Re: [kafka-clients] Re: [VOTE] 1.0.2 RC1 - posted by Manikumar <ma...@gmail.com> on 2018/07/01 18:29:44 UTC, 0 replies.
- RE: [External] Re: Cannot run the inbuild zookeeper server. - posted by "Yi, Gene" <Ge...@sc.com.INVALID> on 2018/07/02 01:04:19 UTC, 2 replies.
- Change in email id for Subscription - posted by "Malik, Shibha (GE Renewable Energy, consultant)" <Sh...@ge.com> on 2018/07/02 04:19:09 UTC, 1 replies.
- KIP 179 - AdminClient Partition Assignment - posted by Eli Jordan <el...@gmail.com> on 2018/07/02 07:50:55 UTC, 0 replies.
- Re: [DISCUSS] KIP-328: Ability to suppress updates for KTables - posted by John Roesler <jo...@confluent.io> on 2018/07/02 15:23:20 UTC, 2 replies.
- Re: [kafka-clients] [VOTE] 0.10.2.2 RC1 - posted by "Matthias J. Sax" <ma...@confluent.io> on 2018/07/02 16:27:41 UTC, 0 replies.
- Re: Possible bug? Duplicates when searching kafka stream state store with caching - posted by Christian Henry <ch...@gmail.com> on 2018/07/02 16:29:12 UTC, 4 replies.
- [RESULTS] [VOTE] Release Kafka version 0.10.2.2 - posted by "Matthias J. Sax" <ma...@confluent.io> on 2018/07/02 16:30:16 UTC, 0 replies.
- [RESULTS] [VOTE] Release Kafka version 0.11.0.3 - posted by "Matthias J. Sax" <ma...@confluent.io> on 2018/07/02 16:54:38 UTC, 1 replies.
- Re: [VOTE] 2.0.0 RC1 - posted by Vahid S Hashemian <va...@us.ibm.com> on 2018/07/02 18:13:24 UTC, 3 replies.
- Re: [kafka-clients] [VOTE] 1.0.2 RC1 - posted by Jun Rao <ju...@confluent.io> on 2018/07/02 18:57:29 UTC, 4 replies.
- How much time does it usually take for a rolling upgrade to complete? - posted by Kostas Christidis <ko...@gmail.com> on 2018/07/02 20:19:59 UTC, 1 replies.
- RecordTooLargeException - posted by je...@tutanota.com on 2018/07/03 00:08:40 UTC, 8 replies.
- what need to be done if we increase the Kafka nodes from 3 to 5? - posted by "Yi, Gene" <Ge...@sc.com.INVALID> on 2018/07/03 02:05:13 UTC, 1 replies.
- Kafka Streams release - posted by Ayushi Sharma <ay...@indix.com> on 2018/07/03 04:57:10 UTC, 1 replies.
- Benchmark tests of producer - posted by darekAsz <da...@gmail.com> on 2018/07/03 08:41:00 UTC, 0 replies.
- How to get best concurrency performance while using KafkaProducer? - posted by Rohan Kulkarni <ro...@gmail.com> on 2018/07/03 09:49:25 UTC, 0 replies.
- How to connect kafka with Industrial Sensor Devices - posted by "Sreenivasa murthy, Sudheer [GTSUS Non-J&J]" <SS...@its.jnj.com> on 2018/07/03 15:31:04 UTC, 0 replies.
- Offset reprocess loop - posted by adrien ruffie <ad...@hotmail.fr> on 2018/07/03 15:41:23 UTC, 0 replies.
- [ANNOUNCE] Apache Kafka 0.11.0.3 Released - posted by "Matthias J. Sax" <mj...@apache.org> on 2018/07/03 18:31:29 UTC, 5 replies.
- [ANNOUNCE] Apache Kafka 0.10.2.2 Released - posted by "Matthias J. Sax" <mj...@apache.org> on 2018/07/03 19:48:26 UTC, 1 replies.
- Kafka performance tests - posted by Csenge Virág Maruzsi <cs...@cloudera.com.INVALID> on 2018/07/04 10:25:52 UTC, 2 replies.
- Kafka disk recommendation for cloud - posted by Ali Nazemian <al...@gmail.com> on 2018/07/04 13:57:37 UTC, 2 replies.
- Brokers are failing to handle UpdateMetadata and LeaderAndIsRequest requests from controller - posted by Chris Richardson <ch...@chrisrichardson.net> on 2018/07/04 14:03:51 UTC, 0 replies.
- Offset reprocess loop over - posted by Adrien Ruffie <ad...@gmail.com> on 2018/07/04 15:14:06 UTC, 0 replies.
- Processor API, how to get last N hours word count - posted by Gleb Stsenov <gl...@gmail.com> on 2018/07/04 15:34:06 UTC, 3 replies.
- Re: Kafka Streams - Shared Ktable State Store - posted by Guozhang Wang <wa...@gmail.com> on 2018/07/04 18:26:02 UTC, 0 replies.
- RE: [kafka-clients] [VOTE] 1.1.1 RC2 - posted by "Skrzypek, Jonathan" <Jo...@gs.com> on 2018/07/05 09:06:04 UTC, 5 replies.
- Very long consumer rebalances - posted by Shantanu Deshmukh <sh...@gmail.com> on 2018/07/06 09:54:57 UTC, 5 replies.
- Kafka Consumer Hung on Certain Partitions - Single Kafka Consumer - posted by dev loper <sp...@gmail.com> on 2018/07/06 16:55:02 UTC, 8 replies.
- Ordering in a Kafka Pipe line - posted by chinchu chinchu <ch...@gmail.com> on 2018/07/06 17:15:46 UTC, 1 replies.
- broker logs unusable after KAFKA-6150: Make Repartition Topics Transient - posted by Henry Cai <hc...@pinterest.com.INVALID> on 2018/07/06 22:08:23 UTC, 3 replies.
- Kafak-Sink-solR - posted by Jagannath Bilgi <js...@yahoo.com.INVALID> on 2018/07/08 05:57:41 UTC, 0 replies.
- Real time streaming as a microservice - posted by Mich Talebzadeh <mi...@gmail.com> on 2018/07/08 08:59:21 UTC, 13 replies.
- Why is kafka poll method blocking? - posted by AmirHossein JavanAmoli <am...@gmail.com> on 2018/07/08 10:23:54 UTC, 0 replies.
- [VOTE] 1.1.1 RC3 - posted by Dong Lin <li...@gmail.com> on 2018/07/08 22:35:40 UTC, 6 replies.
- Monitoring Kafka - posted by Adrien Ruffie <ad...@gmail.com> on 2018/07/09 09:12:45 UTC, 4 replies.
- Good practice when using kafka with jpa - posted by Zbigniew Grzybek <zb...@grzybek.org.pl> on 2018/07/09 10:38:11 UTC, 0 replies.
- Ksql - posted by Praveen Joshi <pr...@gmail.com> on 2018/07/09 12:26:42 UTC, 0 replies.
- Register now for ApacheCon and save $250 - posted by Rich Bowen <rb...@apache.org> on 2018/07/09 14:31:16 UTC, 0 replies.
- EndToEndLatency failing - posted by ph...@orange.com on 2018/07/09 16:06:01 UTC, 0 replies.
- How to create scheduled tasks in Kafka Stream? - posted by Bin Zhu <mi...@gmail.com> on 2018/07/09 16:09:58 UTC, 3 replies.
- Spark structured streaming + kafka - posted by Pulkit Manchanda <pu...@gmail.com> on 2018/07/09 21:23:59 UTC, 2 replies.
- flatMapValues does not calculate timestamp for each record generated - posted by Sicheng Liu <lz...@gmail.com> on 2018/07/10 02:27:45 UTC, 3 replies.
- Kafka Streams Application Failing to Start Due to State Store Recovery Time Exceeding Producer Transaction Timeout - posted by David Chu <da...@appdynamics.com> on 2018/07/10 02:58:58 UTC, 3 replies.
- how to use SMT to transform a filed value in kafka connect? - posted by 刘波 <10...@qq.com> on 2018/07/10 10:48:17 UTC, 0 replies.
- Steadily increasing open file descriptors on one node a cluster - posted by Michael Rauter <MR...@anexia-it.com> on 2018/07/10 13:05:25 UTC, 1 replies.
- Create a Topic if Not Exists - posted by chinchu chinchu <ch...@gmail.com> on 2018/07/10 16:05:45 UTC, 3 replies.
- Flink ignoring -yn - posted by Garrett Barton <ga...@gmail.com> on 2018/07/10 17:09:14 UTC, 2 replies.
- [VOTE] 2.0.0 RC2 - posted by Rajini Sivaram <ra...@gmail.com> on 2018/07/10 17:17:09 UTC, 11 replies.
- RE: cleanup.policy - doesn't accept compact,delete - posted by "Jayaraman, AshokKumar (CCI-Atlanta-CON)" <As...@cox.com> on 2018/07/10 17:43:49 UTC, 4 replies.
- Re: how to use SMT to transform a filed value in kafka connect? - posted by Robin Moffatt <ro...@confluent.io> on 2018/07/10 19:20:57 UTC, 0 replies.
- Stream processing meetup at LinkedIn (Sunnyvale) on Thursday, July 19 at 6pm - posted by Dong Lin <li...@gmail.com> on 2018/07/10 19:31:18 UTC, 0 replies.
- Questions about state stores and KSQL - posted by Jonathan Roy <jo...@caldera.com.INVALID> on 2018/07/11 08:41:58 UTC, 2 replies.
- Apache Kafka QuickStart - posted by Nicholas Chang <nc...@yahoo.com.INVALID> on 2018/07/11 12:33:22 UTC, 2 replies.
- Kafka disk recommendation for production cluster - posted by Ali Nazemian <al...@gmail.com> on 2018/07/11 13:31:18 UTC, 4 replies.
- Http streaming using Kafka+Akka - posted by Pulkit Manchanda <pu...@gmail.com> on 2018/07/11 13:53:29 UTC, 3 replies.
- Kafka for Vehicle location tracking - posted by Yash Ganthe <ya...@gmail.com> on 2018/07/11 14:17:01 UTC, 0 replies.
- Partition assignment doesn't look right - posted by c....@ocado.com, c....@ocado.com on 2018/07/11 16:04:09 UTC, 0 replies.
- Kafka Streams processor node metrics process rate with multiple stream threads - posted by Sam Lendle <sl...@pandora.com> on 2018/07/11 18:42:09 UTC, 5 replies.
- Kafka-streams calling subtractor with null aggregator value in KGroupedTable.reduce() and other weirdness - posted by Vasily Sulatskov <va...@sulatskov.net> on 2018/07/12 16:50:48 UTC, 12 replies.
- Error while creating ephemeral at /brokers/ids/BROKER_ID - posted by Jonathan Santilli <jo...@gmail.com> on 2018/07/14 10:43:27 UTC, 2 replies.
- Accessing Zookepper and Kafka through designated ports in a container - posted by Mich Talebzadeh <mi...@gmail.com> on 2018/07/14 18:42:41 UTC, 6 replies.
- zookeeper as systemctl - posted by Adrien Ruffie <ad...@gmail.com> on 2018/07/15 06:31:49 UTC, 0 replies.
- [ANNOUCE] Apache Kafka 1.0.2 Released - posted by "Matthias J. Sax" <ma...@confluent.io> on 2018/07/16 04:34:02 UTC, 0 replies.
- Kafka stream or ksql design question - posted by Will Du <wi...@gmail.com> on 2018/07/16 12:06:08 UTC, 1 replies.
- Topics strategy to avoid starvation - posted by חנן אואנונו <ha...@gmail.com> on 2018/07/16 12:52:05 UTC, 0 replies.
- Zookeeper and Kafka cluster docker issue - posted by Mich Talebzadeh <mi...@gmail.com> on 2018/07/16 14:41:08 UTC, 6 replies.
- how to aggregate sessions - posted by vb...@hushmail.com on 2018/07/17 08:09:39 UTC, 3 replies.
- Kafka Performance Producer - posted by Nerissa D'Souza <ne...@gmail.com> on 2018/07/17 10:50:34 UTC, 0 replies.
- Restrict access on kafka with multiple listener - posted by Matt L <ma...@gmail.com> on 2018/07/18 00:05:59 UTC, 2 replies.
- Kafka Streams: Share state store across processors - posted by Druhin Sagar Goel <dr...@arrcus.com> on 2018/07/18 06:12:16 UTC, 3 replies.
- If timeout is short, the first poll does not return records - posted by jingguo yao <ya...@gmail.com> on 2018/07/18 08:41:09 UTC, 1 replies.
- The relation between min.insync.replicas and offsets.topic.replication.factor - posted by jingguo yao <ya...@gmail.com> on 2018/07/18 09:27:26 UTC, 0 replies.
- What is meaning of buffer in KafkaConsumer's Javadoc? - posted by jingguo yao <ya...@gmail.com> on 2018/07/18 09:48:29 UTC, 0 replies.
- The asynchronous sending of a message returns no error if the Kafka server is not started - posted by jingguo yao <ya...@gmail.com> on 2018/07/18 14:45:07 UTC, 1 replies.
- Re: [kafka-clients] Re: [VOTE] 1.1.1 RC3 - posted by Dong Lin <li...@gmail.com> on 2018/07/18 17:24:09 UTC, 1 replies.
- Fwd: Recovering partition leadership outside ISR - posted by Jack Foy <jf...@hiya.com> on 2018/07/18 18:24:25 UTC, 0 replies.
- Kafka Connect: Increase Consumer Consumption - posted by Vishnu Manivannan <vi...@arrcus.com> on 2018/07/18 19:00:50 UTC, 5 replies.
- org.apache.kafka.common.errors.TimeoutException : xxx passed since batch creation plus linger time - posted by ig...@taboola.com, ig...@taboola.com on 2018/07/19 10:21:50 UTC, 0 replies.
- Monitor the state of an event-based choreography - posted by Jonathan Roy <jo...@caldera.com.INVALID> on 2018/07/19 10:22:08 UTC, 2 replies.
- Kafka Broker Not Responding - posted by SenthilKumar K <se...@gmail.com> on 2018/07/19 11:58:30 UTC, 0 replies.
- Re: Problem consuming from broker 1.1.0 - posted by SenthilKumar K <se...@gmail.com> on 2018/07/19 13:13:33 UTC, 1 replies.
- UNKNOWN_PRODUCER_ID error when running Streams WordCount demo with processing.guarantee set to EXACTLY_ONCE - posted by "lambdaliu (刘少波)" <la...@tencent.com> on 2018/07/19 13:58:54 UTC, 3 replies.
- Use Kafka Streams for windowing data and processing each window at once - posted by Bruno Bottazzini <br...@targatelematics.com> on 2018/07/19 16:06:48 UTC, 7 replies.
- Measure latency from Source to Sink - posted by antonio saldivar <an...@gmail.com> on 2018/07/19 20:09:24 UTC, 4 replies.
- Measure Latency from Source to Sink - posted by antonio saldivar <an...@gmail.com> on 2018/07/19 20:12:29 UTC, 0 replies.
- [ANNOUNCE] Apache Kafka 1.1.1 Released - posted by Dong Lin <li...@apache.org> on 2018/07/19 23:53:54 UTC, 2 replies.
- Admin Client - posted by Stefan Angelov <ce...@gmail.com> on 2018/07/20 13:56:52 UTC, 0 replies.
- Question - Partition Lag - posted by Antony A <an...@gmail.com> on 2018/07/20 17:31:07 UTC, 3 replies.
- Unable to read topic from beginning after certain runs - posted by Rag <ra...@gmail.com> on 2018/07/20 21:42:25 UTC, 2 replies.
- Documentation/Article/Case Study on Scala as the Kafka Backbone Language - posted by "M. Manna" <ma...@gmail.com> on 2018/07/23 12:40:12 UTC, 3 replies.
- Re: UNKNOWN_PRODUCER_ID error when running Streams WordCount demowith processing.guarantee set to EXACTLY_ONCE - posted by "lambdaliu (刘少波)" <la...@tencent.com> on 2018/07/23 13:56:20 UTC, 0 replies.
- Debugging message timestamps in Sarama - posted by Craig Ching <cr...@gmail.com> on 2018/07/23 14:10:58 UTC, 6 replies.
- Graph Processing with Kafka - posted by Robert Yokota <ra...@gmail.com> on 2018/07/23 16:58:42 UTC, 0 replies.
- Kafka Streams throughput performance overtime - posted by Siva Ram <si...@gmail.com> on 2018/07/24 01:19:38 UTC, 1 replies.
- Kafka Broker : Socket.request.max.bytes & Socket.receive.buffer.bytes - posted by nitin sharma <ku...@gmail.com> on 2018/07/24 02:51:05 UTC, 0 replies.
- Storing a list of values for the same key - posted by Andrea Spina <an...@radicalbit.io> on 2018/07/24 10:53:54 UTC, 3 replies.
- How many producers can publish to same topic concurrently? - posted by Pulkit Manchanda <pu...@gmail.com> on 2018/07/24 13:16:08 UTC, 3 replies.
- [VOTE] 2.0.0 RC3 - posted by Rajini Sivaram <ra...@gmail.com> on 2018/07/24 15:28:06 UTC, 3 replies.
- Kafka Producer TimeOut - posted by chinchu chinchu <ch...@gmail.com> on 2018/07/24 16:26:49 UTC, 0 replies.
- Single node in six node broker pool is under-utilized - posted by Joe Hammerman <jh...@squarespace.com.INVALID> on 2018/07/24 16:52:15 UTC, 0 replies.
- Next Release - posted by xiejing <xi...@shandagames.com> on 2018/07/25 03:01:53 UTC, 1 replies.
- Native memory allocation (mmap) failed to map on Kafka 1.0.1 broker - posted by uday s <si...@gmail.com> on 2018/07/25 03:26:51 UTC, 0 replies.
- Max utilization of avlbl nodes - posted by Srinivasa T N <se...@gmail.com> on 2018/07/25 08:10:32 UTC, 0 replies.
- Any one using oracle event hub - dedicated ? - posted by Vaibhav Jain <va...@ezedox.com> on 2018/07/25 10:25:43 UTC, 2 replies.
- CVE-2017-12610: Authenticated Kafka clients may impersonate other users - posted by Rajini Sivaram <rs...@apache.org> on 2018/07/26 09:19:45 UTC, 0 replies.
- CVE-2018-1288: Authenticated Kafka clients may interfere with data replication - posted by Rajini Sivaram <ra...@gmail.com> on 2018/07/26 09:25:22 UTC, 1 replies.
- Re: INVALID_FETCH_SESSION_EPOCH after upgrade to 1.1.0 - posted by Mark Anderson <ma...@gmail.com> on 2018/07/26 11:28:20 UTC, 0 replies.
- I can't use the command to close my kafka - posted by ? ?? <Ly...@outlook.com> on 2018/07/27 09:45:24 UTC, 1 replies.
- Viewing transactional markers in client - posted by ma...@kafkatool.com on 2018/07/27 12:58:15 UTC, 1 replies.
- [RESULTS] [VOTE] Release Kafka version 2.0.0 - posted by Rajini Sivaram <ra...@gmail.com> on 2018/07/28 08:37:05 UTC, 0 replies.
- Kafka stream application load balancing - posted by Siva Ram <si...@gmail.com> on 2018/07/29 17:37:47 UTC, 1 replies.
- How set properly infinite retention - posted by David Espinosa <es...@gmail.com> on 2018/07/30 09:06:54 UTC, 4 replies.
- Kafka sometime truncate new messages - posted by Soheil Pourbafrani <so...@gmail.com> on 2018/07/30 09:31:01 UTC, 3 replies.
- [ANNOUNCE] Apache Kafka 2.0.0 Released - posted by Rajini Sivaram <rs...@apache.org> on 2018/07/30 10:25:35 UTC, 7 replies.
- RocksDB error with KStream - posted by Vishnu Viswanath <vi...@gmail.com> on 2018/07/30 15:44:22 UTC, 1 replies.
- How to know the begin offset of a partition - posted by Pierre Coquentin <pi...@gmail.com> on 2018/07/31 09:49:14 UTC, 5 replies.
- New 3 Node Setup - posted by Kurt Rudolph <ru...@gmail.com> on 2018/07/31 12:54:32 UTC, 0 replies.
- Re-partitioning topic with through (Kafka Streams) - posted by Francesco Frontera <fr...@radicalbit.io> on 2018/07/31 13:37:50 UTC, 1 replies.
- Creating and deleting Kafka Topics in Scala App - posted by Pulkit Manchanda <pu...@gmail.com> on 2018/07/31 15:57:25 UTC, 0 replies.