users@kafka.apache.org, 2020-04

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

- Re: Statestore restoration - Error while range compacting during restoring - posted by Nicolas Carlot <ni...@chronopost.fr> on 2020/04/01 08:26:35 UTC, 9 replies.
- Re: Broker always out of ISRs - posted by Zach Cox <zc...@gmail.com> on 2020/04/01 19:50:58 UTC, 2 replies.
- Re: Get after put in stateStore returns null - posted by Jan Bols <ja...@telenet.be> on 2020/04/01 21:05:13 UTC, 3 replies.
- How is decompress called in DefaultRecordBatch#iterator - posted by Jiamei Xie <Ji...@arm.com> on 2020/04/02 04:01:15 UTC, 0 replies.
- Kafka rebalancing issue - posted by Mirtunjay Kumar <mi...@netomi.com> on 2020/04/02 05:50:40 UTC, 0 replies.
- acks this category properties in Which *.java Defined??? - posted by 一直以来 <27...@qq.com> on 2020/04/02 15:30:33 UTC, 1 replies.
- Arcsight Logs into Vertica through Kafka - posted by Sebastian Schmitz <se...@propellerhead.co.nz> on 2020/04/02 18:24:24 UTC, 0 replies.
- Global state store: Lazy loading - posted by Navneeth Krishnan <re...@gmail.com> on 2020/04/02 19:08:44 UTC, 4 replies.
- Rpm spec file for kafka - posted by Divyansh Bokadia <db...@gmail.com> on 2020/04/03 04:50:52 UTC, 0 replies.
- Kafka connect didn't reach end of config log quickly enough error - posted by Behroz Sikander <be...@gmail.com> on 2020/04/03 08:46:21 UTC, 0 replies.
- Kafka Quota help - posted by Ravinder Matte <RM...@walmartlabs.com.INVALID> on 2020/04/04 03:54:14 UTC, 1 replies.
- i how do use java kafka-client can test acks 0 and 1 and all between difference??? - posted by 一直以来 <27...@qq.com> on 2020/04/05 03:35:33 UTC, 0 replies.
- java kafka-client use "props.put("retries", "5")" ,why print 2 log ? - posted by 一直以来 <27...@qq.com> on 2020/04/05 04:06:59 UTC, 1 replies.
- Consumer loses partition offset and resets post 2.4.1 version upgrade - posted by Nitay Kufert <ni...@ironsrc.com> on 2020/04/05 17:13:25 UTC, 3 replies.
- Topics naming convention - posted by Fares Oueslati <ou...@gmail.com> on 2020/04/06 14:19:39 UTC, 0 replies.
- Apache Kafka Tool Evaluation related queries - posted by Rajneesh Shukla <ra...@gmail.com> on 2020/04/06 14:36:51 UTC, 0 replies.
- Re: [External] Topics naming convention - posted by Brian Sang <ba...@yelp.com.INVALID> on 2020/04/06 17:59:53 UTC, 0 replies.
- High write operations rate on disk - posted by Soumyajit Sahu <so...@gmail.com> on 2020/04/07 06:28:39 UTC, 7 replies.
- Reg: Dual Kafka Clients - Issues with jar version conflicts - posted by Gowtham S <go...@gmail.com> on 2020/04/07 07:01:09 UTC, 5 replies.
- How to set custom properties and message expiration for Kafka topic message. - posted by Naveen Kumar M <ea...@gmail.com> on 2020/04/07 08:57:21 UTC, 6 replies.
- EOL - posted by "Gaudet, Timothy" <Ti...@GDIT.com> on 2020/04/07 12:54:10 UTC, 3 replies.
- RE: Brokers session terminated and removed - posted by Pradeep Badiger <Pr...@fico.com> on 2020/04/07 14:03:02 UTC, 0 replies.
- Adding new connector Jars dynamically in Kafka Connect - posted by nitin agarwal <ni...@gmail.com> on 2020/04/07 17:24:18 UTC, 2 replies.
- [VOTE] 2.5.0 RC3 - posted by David Arthur <mu...@gmail.com> on 2020/04/08 04:03:21 UTC, 1 replies.
- Oauthbearer - Azure - posted by Antony Alphonse <an...@gmail.com> on 2020/04/08 04:37:09 UTC, 3 replies.
- Kafka CPU spikes every 5 minutes - posted by Jacek Szewczyk <ja...@gmail.com> on 2020/04/08 08:46:27 UTC, 1 replies.
- Kafka: documentation - reliable reference? - posted by "Walenwein. Jakob" <j....@seeburger.de> on 2020/04/09 06:11:32 UTC, 1 replies.
- could not find implicit kstreams.Consumed[String,Entity] - posted by Nicolae Marasoiu <ni...@ovoenergy.com> on 2020/04/09 10:49:46 UTC, 1 replies.
- Kafka Streams endless rebalancing - posted by Alex Craig <al...@gmail.com> on 2020/04/09 13:33:41 UTC, 5 replies.
- how to start DEBUG level - posted by deadwind4 <de...@outlook.com> on 2020/04/10 05:51:49 UTC, 1 replies.
- Re: [kafka-clients] Re: [VOTE] 2.5.0 RC3 - posted by Bill Bejeck <bb...@gmail.com> on 2020/04/10 14:23:08 UTC, 2 replies.
- Potential message incompatibility between versions 0.11 and 2.2.1 of Kafka? - posted by Malcolm McFarland <mm...@cavulus.com> on 2020/04/10 22:33:15 UTC, 0 replies.
- Process offsets from particular point - posted by KhajaAsmath Mohammed <md...@gmail.com> on 2020/04/11 12:54:31 UTC, 4 replies.
- MessagesOutPerSec JMX metric - posted by 张祥 <xi...@gmail.com> on 2020/04/13 02:34:53 UTC, 2 replies.
- Request for adding Jira Id into dev list of Apache Kafka - posted by Wong Lucent <ma...@live.cn> on 2020/04/13 03:19:28 UTC, 2 replies.
- Request for adding into contributors list - posted by Wong Lucent <ma...@live.cn> on 2020/04/13 13:14:59 UTC, 1 replies.
- 回复: Request for adding into contributors list - posted by Wong Lucent <ma...@live.cn> on 2020/04/13 13:58:07 UTC, 0 replies.
- Re: [kafka-clients] [VOTE] 2.5.0 RC3 - posted by Jun Rao <ju...@confluent.io> on 2020/04/13 21:25:37 UTC, 2 replies.
- Consumer Group got stuck in CompletingRebalance - posted by James Brown <jb...@easypost.com> on 2020/04/13 22:07:47 UTC, 0 replies.
- CVEs for the dependency software guava and rocksdbjni of Kafka - posted by kangbotao <ka...@huawei.com> on 2020/04/14 01:18:59 UTC, 2 replies.
- How to alter topic config with broker endpoint - posted by Weichu Liu <we...@indeed.com.INVALID> on 2020/04/14 04:17:02 UTC, 1 replies.
- 1 of 3 brokers can't replicate to specific 1 broker - posted by Neta Hofesh <ne...@imperva.com> on 2020/04/14 06:49:42 UTC, 0 replies.
- Essential of Kafka - posted by "Kara, Tamer" <Ta...@ordina.nl> on 2020/04/14 09:22:43 UTC, 0 replies.
- [RESULTS] [VOTE] 2.5.0 RC3 - posted by David Arthur <mu...@gmail.com> on 2020/04/14 15:15:14 UTC, 3 replies.
- Access Kafka cli for SASL Kafka cluster - posted by KhajaAsmath Mohammed <md...@gmail.com> on 2020/04/14 15:45:09 UTC, 0 replies.
- How commits are tested for kafka? travis or jenkins? - posted by Jiamei Xie <Ji...@arm.com> on 2020/04/15 03:19:56 UTC, 0 replies.
- Kafka Streams - issues with windowing and suppress - posted by Liam Clarke <li...@adscale.co.nz> on 2020/04/15 03:43:33 UTC, 12 replies.
- how do reset Broker after auto add cluster?? - posted by 一直以来 <27...@qq.com> on 2020/04/15 09:46:50 UTC, 0 replies.
- Want to ask three questions about the connector to kafka! - posted by 大吃一惊 <md...@qq.com> on 2020/04/15 13:08:16 UTC, 0 replies.
- How to add partitions to an existing kafka topic - posted by Sachin Mittal <sj...@gmail.com> on 2020/04/15 14:22:45 UTC, 4 replies.
- [ANNOUNCE] Apache Kafka 2.5.0 - posted by David Arthur <da...@apache.org> on 2020/04/15 20:15:32 UTC, 4 replies.
- topics metadata, OWL ontologies and AVRO - posted by Nicolae Marasoiu <ni...@ovoenergy.com> on 2020/04/15 21:08:33 UTC, 0 replies.
- updates on Kafka Summit in 2020 - posted by Jun Rao <ju...@confluent.io> on 2020/04/15 23:52:54 UTC, 1 replies.
- how do restart Broker after auto add cluster?? - posted by startjava <27...@qq.com> on 2020/04/15 23:57:43 UTC, 0 replies.
- Kafka Java Client not support --unavailable-partitions and --topics-with-overrides param? - posted by 一直以来 <27...@qq.com> on 2020/04/16 07:35:10 UTC, 0 replies.
- endless authorizer log - posted by 张祥 <xi...@gmail.com> on 2020/04/16 08:44:07 UTC, 0 replies.
- Restart without shutdown log - posted by 张祥 <xi...@gmail.com> on 2020/04/16 09:04:44 UTC, 0 replies.
- Client Crashes - posted by 徐广云 <gy...@hotmail.com> on 2020/04/16 11:18:14 UTC, 0 replies.
- who show this execption:The proposed assignment contains non-existent partitions: ListBuffer??? - posted by 一直以来 <27...@qq.com> on 2020/04/16 11:20:01 UTC, 1 replies.
- 回复： who show this execption:The proposed assignment contains non-existent partitions: ListBuffer??? - posted by 一直以来 <27...@qq.com> on 2020/04/16 11:44:51 UTC, 0 replies.
- why new node not add cluster? - posted by 一直以来 <27...@qq.com> on 2020/04/16 11:50:08 UTC, 0 replies.
- Retention period for __consumer_offsets topic - posted by nitin agarwal <ni...@gmail.com> on 2020/04/16 13:21:52 UTC, 3 replies.
- Kafka slow reads from beginning of topic - posted by Ilya R <mr...@gmail.com> on 2020/04/16 15:28:01 UTC, 2 replies.
- Kafka slow reads from beggining of topic - posted by Ilya R <mr...@gmail.com> on 2020/04/16 15:49:16 UTC, 1 replies.
- log.message.timestamp.difference.max.ms and future timestamps? - posted by Andrew Otto <ot...@wikimedia.org> on 2020/04/16 16:39:39 UTC, 0 replies.
- logical delete from a log compacted topic; tombstone message? with kafka-streams - posted by Nicolae Marasoiu <ni...@ovoenergy.com> on 2020/04/16 17:48:58 UTC, 1 replies.
- New CoGroup, how to do a left join - posted by Murilo Tavares <mu...@gmail.com> on 2020/04/16 20:22:50 UTC, 3 replies.
- Cannot terminate query on KSQL - posted by Federico D'Ambrosio <fe...@gmail.com> on 2020/04/17 09:07:13 UTC, 4 replies.
- New blog post: A quick and dirty way to monitor data arriving on Kafka - posted by Robin Moffatt <ro...@confluent.io> on 2020/04/17 09:29:35 UTC, 0 replies.
- Getting Classpath is empty. Please build the project first e.g. by running 'gradlew jarAll' all the time - posted by Naveen Kumar M <ea...@gmail.com> on 2020/04/17 11:20:39 UTC, 3 replies.
- linking different topics AVRO schemas with OWL/RDFS ontologies - posted by Nicolae Marasoiu <ni...@ovoenergy.com> on 2020/04/17 11:54:58 UTC, 0 replies.
- Consumer Group got stuck in PreparingRebalance - posted by Antonio Rocco IORFINO <an...@alten.ch> on 2020/04/17 13:56:09 UTC, 0 replies.
- Confluent Virtual User Group (VUG) - posted by Robin Moffatt <ro...@confluent.io> on 2020/04/17 14:10:13 UTC, 0 replies.
- Kafka Meetup hosted by Confluent Online, Tuesday 4:00pm, April 21st, 2020 - posted by Guozhang Wang <wa...@gmail.com> on 2020/04/17 19:15:57 UTC, 0 replies.
- Right to modify Apache Kafka logo - posted by Sylvain Le Gouellec <sy...@gmail.com> on 2020/04/18 11:54:33 UTC, 2 replies.
- Unexpected behaviour on windowing aggregations - posted by Liam Clarke <li...@adscale.co.nz> on 2020/04/19 08:08:05 UTC, 4 replies.
- Need advice on how to deploy and update a streams app - posted by Mathieu D <ma...@gmail.com> on 2020/04/19 22:17:48 UTC, 1 replies.
- Help with setting up Kafka Node - posted by in...@fluent-software.de on 2020/04/20 15:19:37 UTC, 5 replies.
- Sybase Connection - posted by Jonatan Frank <jo...@latbc.com.mx> on 2020/04/20 16:30:36 UTC, 1 replies.
- Unknown topic at org.apache.kafka.streams.TopologyTestDriver.pipeRecord - posted by Dumitru-Nicolae Marasoui <ni...@ovoenergy.com> on 2020/04/20 19:19:28 UTC, 6 replies.
- Re: kafka-consumer-groups.sh CURRENT-OFFSET column show "-" , what mean about it ! thank you ! - posted by Liam Clarke-Hutchinson <li...@adscale.co.nz> on 2020/04/20 20:22:06 UTC, 3 replies.
- Retrieve Kafka Principal from Client - posted by "Newton, Brandt (CAI - Burlington)" <Br...@coxautoinc.com> on 2020/04/20 20:30:27 UTC, 2 replies.
- Deserialization Exception when performing state store operations - posted by Carl Graving <cg...@gmail.com> on 2020/04/21 02:59:23 UTC, 4 replies.
- thank you ! which java-client api can has same effect about kafka-consumer-groups.sh command ? - posted by 一直以来 <27...@qq.com> on 2020/04/22 06:37:23 UTC, 3 replies.
- 回复： thank you ! which java-client api can has same effect about kafka-consumer-groups.sh command ? - posted by 一直以来 <27...@qq.com> on 2020/04/22 07:42:53 UTC, 0 replies.
- 回复： kafka-consumer-groups.sh CURRENT-OFFSET column show "-" , what mean about it ! thank you ! - posted by 一直以来 <27...@qq.com> on 2020/04/22 08:02:27 UTC, 0 replies.
- MirrorMaker2 ordering guarantees - posted by Péter Sinóros-Szabó <pe...@transferwise.com.INVALID> on 2020/04/22 08:39:16 UTC, 5 replies.
- How to add (intercept?) messages in the broker before and after they are serialized? - posted by "del Castillo Perez, Daniel" <da...@vonage.com.INVALID> on 2020/04/22 13:35:19 UTC, 0 replies.
- Clarification regarding multi topics implementation - posted by Suresh Chidambaram <ch...@gmail.com> on 2020/04/22 16:40:57 UTC, 2 replies.
- MM2 with older Kafka version - posted by Henry Cai <hc...@pinterest.com.INVALID> on 2020/04/23 01:03:12 UTC, 1 replies.
- Error in kafka streams: The producer attempted to use a producer id which is not currently assigned to its transactional id - posted by Pushkar Deole <pd...@gmail.com> on 2020/04/24 06:59:40 UTC, 5 replies.
- Mirrormaker 2 failed to get offset - posted by Ravin <ra...@orkash.com.INVALID> on 2020/04/24 12:07:37 UTC, 0 replies.
- Consumer not receiving messages after connection loss - posted by Goran Sliskovic <gs...@yahoo.com.INVALID> on 2020/04/26 11:35:18 UTC, 2 replies.
- How to handle RebalanceInProgressException? - posted by Benoit Delbosc <bd...@nuxeo.com> on 2020/04/27 07:45:15 UTC, 5 replies.
- Kafka Connect ignores the bootstrap.servers parameter - posted by Valentin Kulichenko <va...@gmail.com> on 2020/04/28 03:43:49 UTC, 4 replies.
- Getting NotLeaderForPartitionException for a very long time - posted by "M.Gopala Krishnan" <mg...@gmail.com> on 2020/04/28 08:08:00 UTC, 2 replies.
- Can kafka state stores be used without streams and accessed globally through multiple application instances? - posted by Pushkar Deole <pd...@gmail.com> on 2020/04/28 14:25:53 UTC, 0 replies.
- Kafka: Messages disappearing from topics, largestTime=0 - posted by JP MB <jo...@gmail.com> on 2020/04/28 14:36:45 UTC, 13 replies.
- Apache Kafka Streams with Sprinng Boot - posted by Suresh Chidambaram <ch...@gmail.com> on 2020/04/28 14:54:53 UTC, 6 replies.
- Kafka Streams support for connecting to different Kafka clusters - posted by Daniel Germain <da...@gmail.com> on 2020/04/28 21:10:04 UTC, 1 replies.
- A general question regarding Kefka clients version - posted by hassan <ha...@hardstoneenterprises.com> on 2020/04/29 02:39:16 UTC, 0 replies.
- are kafka state stores global or local? - posted by Pushkar Deole <pd...@gmail.com> on 2020/04/29 10:08:55 UTC, 6 replies.
- Kstreams Database - posted by KhajaAsmath Mohammed <md...@gmail.com> on 2020/04/29 15:46:45 UTC, 1 replies.
- One cluster topic to another cluster topic - posted by vishnu murali <vi...@gmail.com> on 2020/04/29 18:40:32 UTC, 1 replies.
- Apache Kafka cluster to cluster - posted by vishnu murali <vi...@gmail.com> on 2020/04/29 18:47:19 UTC, 8 replies.
- JDBC source connector to Kafka topic - posted by vishnu murali <vi...@gmail.com> on 2020/04/29 19:01:44 UTC, 2 replies.
- Kafka Mirror Maker 2 - posted by Himanshu Tyagi <ty...@gmail.com> on 2020/04/29 19:46:25 UTC, 2 replies.
- can kafka state stores be used as a application level cache by application to modify it from outside the stream topology? - posted by Pushkar Deole <pd...@gmail.com> on 2020/04/30 05:52:53 UTC, 3 replies.
- kafka rdd save to hive errer - posted by 姜戎 <21...@qq.com> on 2020/04/30 08:02:57 UTC, 0 replies.
- Metrics in Kafka Connect - posted by Gérald Quintana <ge...@gmail.com> on 2020/04/30 19:57:06 UTC, 1 replies.