You are viewing a plain text version of this content. The canonical link for it is here.
- Re: 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/05/01 06:11:12 UTC, 19 replies.
- Re: Kafka: Messages disappearing from topics, largestTime=0 - posted by JP MB <jo...@gmail.com> on 2020/05/01 06:49:24 UTC, 7 replies.
- Cant Able to start Kafka MirrorMaker - posted by vishnu murali <vi...@gmail.com> on 2020/05/01 06:58:26 UTC, 1 replies.
- Connector For MirrorMaker - posted by vishnu murali <vi...@gmail.com> on 2020/05/01 12:56:56 UTC, 3 replies.
- Request for adding into contributors list - posted by Jun Wang <wj...@hotmail.com> on 2020/05/01 18:21:11 UTC, 4 replies.
- Connect-Mirror 2.5.0 - posted by vishnu murali <vi...@gmail.com> on 2020/05/02 09:56:14 UTC, 2 replies.
- Re: Consumer not receiving messages after connection loss - posted by Liam Clarke-Hutchinson <li...@adscale.co.nz> on 2020/05/02 13:32:59 UTC, 1 replies.
- Re: kafka rdd save to hive errer - posted by Liam Clarke-Hutchinson <li...@adscale.co.nz> on 2020/05/02 13:50:35 UTC, 1 replies.
- Connect-Mirror Error - posted by vishnu murali <vi...@gmail.com> on 2020/05/02 15:21:27 UTC, 1 replies.
- Kafka - FindCoordinator error - posted by Rajib Deb <Ra...@infosys.com> on 2020/05/03 16:51:25 UTC, 2 replies.
- Need to consume one by one data - posted by vishnu murali <vi...@gmail.com> on 2020/05/04 04:59:36 UTC, 0 replies.
- Kafka consumer - posted by vishnu murali <vi...@gmail.com> on 2020/05/04 08:03:36 UTC, 2 replies.
- FAILED tasks in connector status - posted by Abdoulaye Diallo <ab...@gmail.com> on 2020/05/05 02:01:08 UTC, 1 replies.
- Avro DeSerializeation Issue in Kafka Streams - posted by Suresh Chidambaram <ch...@gmail.com> on 2020/05/05 15:12:52 UTC, 1 replies.
- com.typesafe.scalalogging.BaseLogger can not implement com.typesafe.scalalogging.Logger - posted by Venkata MR <Ve...@hcl.com> on 2020/05/05 15:15:37 UTC, 0 replies.
- KafkaConsumer.partitionsFor() Vs KafkaAdminClient.describeTopics() - posted by SenthilKumar K <se...@gmail.com> on 2020/05/05 18:43:53 UTC, 4 replies.
- Separate Kafka partitioning from key compaction - posted by "Young, Ben" <Be...@fisglobal.com.INVALID> on 2020/05/06 10:24:38 UTC, 2 replies.
- Re: [EXTERNAL] Re: Master-Slave being DB locked both - posted by Jose Manuel Vega Monroy <jo...@williamhill.com> on 2020/05/06 15:02:34 UTC, 0 replies.
- Kafka long running job consumer config best practices and what to do to avoid stuck consumer - posted by Ali Nazemian <al...@gmail.com> on 2020/05/07 04:38:22 UTC, 9 replies.
- Consumer call retries - posted by Chris Toomey <ct...@gmail.com> on 2020/05/07 05:21:17 UTC, 0 replies.
- JDBC Sink Connector - posted by vishnu murali <vi...@gmail.com> on 2020/05/07 05:47:36 UTC, 4 replies.
- Identity Mirroring - posted by Henry Cai <hc...@pinterest.com.INVALID> on 2020/05/07 07:46:28 UTC, 1 replies.
- records with key as string and value as java ArrayList in topic - posted by Pushkar Deole <pd...@gmail.com> on 2020/05/07 12:31:53 UTC, 11 replies.
- Is committing offset required for Consumer - posted by Boyuan Zhang <bo...@apache.org> on 2020/05/07 22:51:57 UTC, 4 replies.
- Kafka Connect SMT to insert key into message - posted by Liam Clarke-Hutchinson <li...@adscale.co.nz> on 2020/05/08 00:14:14 UTC, 2 replies.
- Is it possible to send avro serialized data to kafka using kafka-console-producer.sh - posted by "wanglei2@geekplus.com.cn" <wa...@geekplus.com.cn> on 2020/05/08 09:53:12 UTC, 2 replies.
- Re: 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/05/08 13:28:53 UTC, 1 replies.
- JDBC SINK SCHEMA - posted by vishnu murali <vi...@gmail.com> on 2020/05/08 13:59:24 UTC, 4 replies.
- I have a wired issue - posted by 王铁 <37...@qq.com> on 2020/05/08 15:28:06 UTC, 0 replies.
- Re: log.message.timestamp.difference.max.ms and future timestamps? - posted by "Matthias J. Sax" <mj...@apache.org> on 2020/05/08 18:53:25 UTC, 1 replies.
- Change RF factor... - posted by Rajib Deb <Ra...@infosys.com> on 2020/05/08 19:16:24 UTC, 4 replies.
- Write to database directly by referencing schema registry, no jdbc sink connector - posted by "wanglei2@geekplus.com.cn" <wa...@geekplus.com.cn> on 2020/05/09 02:38:15 UTC, 7 replies.
- Is there any difference between conflunt kafka and apache kafka? - posted by "wanglei2@geekplus.com.cn" <wa...@geekplus.com.cn> on 2020/05/09 08:46:28 UTC, 6 replies.
- graceful shutdown may be cause loss message - posted by yang chen <sh...@gmail.com> on 2020/05/09 14:17:07 UTC, 0 replies.
- Kafka Streams, WindowBy, Grace Period, Late events, Suppres operation - posted by Baki Hayat <ba...@gmail.com> on 2020/05/10 10:29:50 UTC, 4 replies.
- TransactionalIdAuthorizationException - posted by Cenk Oguz <ce...@gmail.com> on 2020/05/10 23:53:40 UTC, 0 replies.
- kafka-console-consumer.sh: Port already in use Exception after enable JMX - posted by "wanglei2@geekplus.com.cn" <wa...@geekplus.com.cn> on 2020/05/11 02:48:51 UTC, 4 replies.
- Re: kafka-console-consumer.sh: Port already in use Exception after enable JMX - posted by rohit garg <ro...@gmail.com> on 2020/05/11 04:54:40 UTC, 1 replies.
- How actually jdbc sink connetor run - posted by "wanglei2@geekplus.com.cn" <wa...@geekplus.com.cn> on 2020/05/11 10:10:25 UTC, 1 replies.
- Are there any plans for MM2 to expose functionality to mutate records? - posted by Liam Clarke-Hutchinson <li...@adscale.co.nz> on 2020/05/11 10:57:18 UTC, 1 replies.
- compacting to keep oldest values? - posted by Dumitru-Nicolae Marasoui <ni...@ovoenergy.com> on 2020/05/11 11:02:16 UTC, 0 replies.
- How to config multiple tables in kafka jdbc sink connector? - posted by "wanglei2@geekplus.com.cn" <wa...@geekplus.com.cn> on 2020/05/11 12:17:16 UTC, 0 replies.
- How can I create a KSQL-DB materialized view that captures the oldest values for each key? - posted by Dumitru-Nicolae Marasoui <ni...@ovoenergy.com> on 2020/05/11 12:52:17 UTC, 0 replies.
- Re: How to handle RebalanceInProgressException? - posted by Benoit Delbosc <bd...@nuxeo.com> on 2020/05/11 13:36:27 UTC, 0 replies.
- how can I manually do a compaction? - posted by Dumitru-Nicolae Marasoui <ni...@ovoenergy.com> on 2020/05/11 16:15:39 UTC, 1 replies.
- Kafka upgrade from 0.10 to 2.3.x - posted by Praveen <pr...@gmail.com> on 2020/05/11 16:50:23 UTC, 5 replies.
- Kafka metrics - posted by Eleanore Jin <el...@gmail.com> on 2020/05/12 00:23:30 UTC, 3 replies.
- Offset Management... - posted by Rajib Deb <Ra...@infosys.com> on 2020/05/12 01:51:36 UTC, 2 replies.
- Merging multiple streams into one - posted by Alessandro Tagliapietra <ta...@gmail.com> on 2020/05/12 03:01:40 UTC, 2 replies.
- Custom Connector - posted by vishnu murali <vi...@gmail.com> on 2020/05/12 06:27:13 UTC, 3 replies.
- Need a connector to listening Rest Endpoint - posted by vishnu murali <vi...@gmail.com> on 2020/05/12 07:33:33 UTC, 0 replies.
- data structures used by GlobalKTable, KTable - posted by Pushkar Deole <pd...@gmail.com> on 2020/05/12 09:35:16 UTC, 11 replies.
- Timestamps with Kafka REST proxy - posted by Sachin Nikumbh <sa...@yahoo.com.INVALID> on 2020/05/13 03:15:10 UTC, 0 replies.
- Kafka ACL Support - posted by "Jadhawar, Ganesh" <Ga...@harman.com> on 2020/05/13 06:36:52 UTC, 1 replies.
- tranactions can across two kafka cluster ? - posted by Jedi Knight <12...@gmail.com> on 2020/05/13 07:28:55 UTC, 0 replies.
- AzkarraStreams 0.7.0 released - posted by Florian Hussonnois <fh...@gmail.com> on 2020/05/13 08:17:58 UTC, 0 replies.
- Jdbc Source Connector Config - posted by vishnu murali <vi...@gmail.com> on 2020/05/13 09:34:29 UTC, 1 replies.
- hangup of kafka consumer in case of unclean leader election - posted by Dmitry Sorokin <dm...@gmail.com> on 2020/05/13 09:43:23 UTC, 0 replies.
- kafka connector distributed mode balance stratety - posted by "wanglei2@geekplus.com.cn" <wa...@geekplus.com.cn> on 2020/05/14 03:42:06 UTC, 0 replies.
- KafkaStream groupBy + count on KTable behaviour - posted by Raffaele Esposito <ra...@gmail.com> on 2020/05/14 10:17:20 UTC, 6 replies.
- JDBC source connector - posted by vishnu murali <vi...@gmail.com> on 2020/05/14 11:14:52 UTC, 3 replies.
- What to use to copy data from one kafka to another ? - posted by JP MB <jo...@gmail.com> on 2020/05/14 12:12:38 UTC, 2 replies.
- Re: [External] kafka connector distributed mode balance stratety - posted by "Tauzell, Dave" <Da...@surescripts.com> on 2020/05/14 13:38:22 UTC, 0 replies.
- ACL/SSL Issue with Configuration = ssl.principal.mapping.rules - posted by Jonathan Goings <JG...@jackhenry.com> on 2020/05/14 16:30:45 UTC, 0 replies.
- InvalidRecordException: Inner record LegacyRecordBatch - posted by Gérald Quintana <ge...@gmail.com> on 2020/05/14 17:39:41 UTC, 0 replies.
- Need help regarding missing kafka producer metrics while upgrade from 1.1.0 to 2.0.0 - posted by Rajkumar Natarajan <ra...@gmail.com> on 2020/05/14 23:42:51 UTC, 0 replies.
- Problem in Docker - posted by vishnu murali <vi...@gmail.com> on 2020/05/15 07:16:18 UTC, 1 replies.
- topic input parameter in org.apache.kafka.common.serialization.Serializer interface - posted by Pushkar Deole <pd...@gmail.com> on 2020/05/15 09:30:18 UTC, 1 replies.
- About Kafka Stream parallelism - posted by "Rapeepat (Lookmoo) Sriwichai" <ra...@central.tech> on 2020/05/15 11:45:50 UTC, 1 replies.
- idempotency issue and transactions on producer - posted by Raffaele Esposito <ra...@gmail.com> on 2020/05/15 18:47:45 UTC, 3 replies.
- Re: High write operations rate on disk - posted by Alexandre Dupriez <al...@gmail.com> on 2020/05/16 11:16:18 UTC, 1 replies.
- Need Swift revert - for Kafka solution - posted by "ravi.gangaiah@wipro.com.INVALID" <ra...@wipro.com.INVALID> on 2020/05/17 10:03:12 UTC, 0 replies.
- Is Zombie instance problem consumer related ? - posted by Raffaele Esposito <ra...@gmail.com> on 2020/05/17 12:55:25 UTC, 1 replies.
- Partitioning issue when a broker is going down - posted by Victoria Zuberman <vi...@imperva.com> on 2020/05/17 17:35:57 UTC, 4 replies.
- Question on Kafka Connect - posted by Richard Ney <ka...@gmail.com> on 2020/05/17 22:30:08 UTC, 1 replies.
- swagger/openapi spec for Kafka-Connect REST API? - posted by Aki Yoshida <el...@gmail.com> on 2020/05/18 07:59:33 UTC, 3 replies.
- MM2 Message Handlers - posted by Jamie <ja...@aol.co.uk.INVALID> on 2020/05/18 11:17:19 UTC, 2 replies.
- SFTP Connector - posted by vishnu murali <vi...@gmail.com> on 2020/05/18 13:28:14 UTC, 1 replies.
- Exception in SFTP CSV SOURCE - posted by vishnu murali <vi...@gmail.com> on 2020/05/18 13:44:39 UTC, 3 replies.
- Connector&JsonConverter&decimal&base64 - posted by 18624049226 <18...@163.com> on 2020/05/18 14:12:44 UTC, 0 replies.
- ACLs - How To Allow Anyone To Access of A Topic - posted by Jun Wang <wj...@hotmail.com> on 2020/05/18 15:09:51 UTC, 0 replies.
- Re: ACLs - How To Allow Anyone To Access of A Topic - posted by Andrew Otto <ot...@wikimedia.org> on 2020/05/18 15:51:42 UTC, 2 replies.
- Batch size, linger-ms not working as intended - posted by Bibek Shrestha <sb...@gmail.com> on 2020/05/18 23:03:26 UTC, 1 replies.
- Question regarding Kafka Streams Global State Store - posted by "Schmidt-Dumont Georg (BCI/ESW17)" <Ge...@de.bosch.com.INVALID> on 2020/05/19 08:23:23 UTC, 6 replies.
- Cannot access to kafka by server domain and port. - posted by 深大李展发 <xl...@foxmail.com> on 2020/05/19 09:57:41 UTC, 0 replies.
- Re:Cannot access to kafka by server domain and port. - posted by lxy <lx...@163.com> on 2020/05/19 10:15:43 UTC, 1 replies.
- 回复:Cannot access to kafka by server domain and port. - posted by 深大李展发 <xl...@foxmail.com> on 2020/05/19 10:48:34 UTC, 0 replies.
- 回复: Cannot access to kafka by server domain and port. - posted by 深大李展发 <xl...@foxmail.com> on 2020/05/19 11:56:17 UTC, 0 replies.
- Persist Kafka Topics and ksqldb - posted by Mohammed Ait Haddou <mo...@gmail.com> on 2020/05/19 13:45:26 UTC, 1 replies.
- Add Jira ID to Contributors - posted by 阮良 <ru...@163.com> on 2020/05/19 14:00:14 UTC, 0 replies.
- KSQL to search for data in Kafka Topics - posted by "M. Manna" <ma...@gmail.com> on 2020/05/19 14:35:02 UTC, 1 replies.
- KTable as a compacted topic, implications - posted by Raffaele Esposito <ra...@gmail.com> on 2020/05/19 15:21:24 UTC, 5 replies.
- Effect of changing rack id - posted by Amitav Mohanty <am...@gmail.com> on 2020/05/19 16:38:15 UTC, 0 replies.
- Cassandra Sink Connector with KSQLDB : "DataException: Key must be a struct or map" - posted by Mohammed Ait Haddou <mo...@gmail.com> on 2020/05/19 18:01:10 UTC, 0 replies.
- Understanding Kafka controller log - posted by Amitav Mohanty <am...@gmail.com> on 2020/05/19 19:03:58 UTC, 2 replies.
- Re: Kafka Connect Connector Tasks Uneven Division - posted by Deepak Raghav <de...@gmail.com> on 2020/05/20 05:45:50 UTC, 9 replies.
- SFTP config problem - posted by vishnu murali <vi...@gmail.com> on 2020/05/20 08:34:10 UTC, 0 replies.
- SFTP config Details as a JSON - posted by vishnu murali <vi...@gmail.com> on 2020/05/20 09:28:54 UTC, 0 replies.
- Field does not exist on Debezium transformation to extract key - posted by Mohammed Ait Haddou <mo...@gmail.com> on 2020/05/20 17:16:56 UTC, 0 replies.
- Field does not exist on transformations to extract key with Debezium - posted by Mohammed Ait Haddou <mo...@gmail.com> on 2020/05/20 17:31:38 UTC, 0 replies.
- Avro schema registry error - posted by AJ Chen <ca...@gmail.com> on 2020/05/20 23:56:14 UTC, 2 replies.
- Kafka consumer is taking time to recognize new partition - posted by Kafka Shil <ka...@gmail.com> on 2020/05/21 01:06:13 UTC, 1 replies.
- Problem getting the correct values for records-lag from JMX when using Kafka Connect - posted by Leon Bam <le...@walkme.com> on 2020/05/21 11:13:09 UTC, 0 replies.
- Kafka retention policy per topic not working as expected - posted by Don Ky <as...@gmail.com> on 2020/05/21 16:49:16 UTC, 3 replies.
- Is that a bug? - posted by Jiamei Xie <Ji...@arm.com> on 2020/05/22 07:31:12 UTC, 4 replies.
- User ID / Password based authentication for Kafka Connect Source connector REST Interface - posted by As...@cognizant.com on 2020/05/22 08:14:05 UTC, 3 replies.
- KafkaProducer Metadata versioning - posted by Murilo Tavares <mu...@gmail.com> on 2020/05/22 15:07:35 UTC, 0 replies.
- Should there be separate Kafka for producers and consumers - posted by nitin agarwal <ni...@gmail.com> on 2020/05/23 07:37:46 UTC, 1 replies.
- How should I measure the time spent in various stages of kafka - posted by 张瑞 <zh...@fudan.edu.cn> on 2020/05/24 11:29:47 UTC, 0 replies.
- Request for adding to contributors list - posted by Guruprasad Tahasildar <gc...@cs.ucla.edu> on 2020/05/25 03:31:45 UTC, 6 replies.
- KSQL in Production - posted by Carl Graving <cg...@gmail.com> on 2020/05/25 22:23:00 UTC, 1 replies.
- Kafka Timeout Exception - posted by "JOHN, BIBIN" <bj...@att.com> on 2020/05/26 04:48:14 UTC, 2 replies.
- Broker side partition round robin - posted by Vinicius Scheidegger <vi...@gmail.com> on 2020/05/26 09:26:46 UTC, 3 replies.
- How to manually start ingesting in kafka source connector ? - posted by Yu Watanabe <yu...@gmail.com> on 2020/05/28 03:11:50 UTC, 3 replies.
- NEED HELP : OutOfMemoryError: Java heap space error while starting KafkaStream with a simple topology - posted by Pushkar Deole <pd...@gmail.com> on 2020/05/28 03:43:39 UTC, 4 replies.
- Clients may fetch incomplete set of topic partitions during cluster startup - posted by Debraj Manna <su...@gmail.com> on 2020/05/28 10:15:38 UTC, 3 replies.
- Repeated UnknownProducerIdException - posted by "Schmidt-Dumont Georg (BCI/ESW17)" <Ge...@de.bosch.com.INVALID> on 2020/05/28 10:29:16 UTC, 2 replies.
- a few URP causes high latencies to producers and consumers - posted by nitin agarwal <ni...@gmail.com> on 2020/05/28 16:47:05 UTC, 0 replies.
- Kafka _Querys - posted by Csk Raju <cs...@gmail.com> on 2020/05/29 05:01:39 UTC, 0 replies.
- Single Task running both worker node - posted by Deepak Raghav <de...@gmail.com> on 2020/05/29 07:45:38 UTC, 0 replies.
- Apache Kafka MirrorMaker2 issue - posted by "Peri, Viswanadh" <vp...@deloitte.com> on 2020/05/29 11:05:14 UTC, 0 replies.
- Intial Data Load - posted by Suresh Chidambaram <ch...@gmail.com> on 2020/05/30 06:52:09 UTC, 4 replies.