You are viewing a plain text version of this content. The canonical link for it is here.
- Re: Partition reassignment data file is empty - posted by Brett Rann <br...@zendesk.com.INVALID> on 2018/01/01 00:51:27 UTC, 3 replies.
- RE: Kafka Streams - max.poll.interval.ms defaults to Integer.MAX_VALUE - posted by Javier Holguera <ja...@zopa.com> on 2018/01/01 12:49:48 UTC, 1 replies.
- Consumer behavior when Kafka rolls the old log file - posted by Debraj Manna <su...@gmail.com> on 2018/01/02 10:00:09 UTC, 1 replies.
- Unable to start 1st broker in a 3 node configuration - posted by "M. Manna" <ma...@gmail.com> on 2018/01/02 10:18:07 UTC, 2 replies.
- Re: Kafka Streams 0.11 consumers losing offsets for all group.ids - posted by Adam Gurson <ad...@equilibriumtech.com> on 2018/01/02 14:26:08 UTC, 0 replies.
- Kafka : To meny files open - posted by daniel brown <da...@gmail.com> on 2018/01/03 08:18:47 UTC, 1 replies.
- How to enable `kafka.(producer|consumer)` JMX metrics? - posted by Tim Visher <ti...@gmail.com> on 2018/01/03 17:01:53 UTC, 1 replies.
- Does subscription by pattern work properly? - posted by Skip Montanaro <sk...@gmail.com> on 2018/01/03 19:24:39 UTC, 0 replies.
- Kafka Replicated Partition Limits - posted by Andrey Falko <af...@salesforce.com> on 2018/01/03 21:48:25 UTC, 5 replies.
- Any suggestion about Kafka/Zookeeper migration. - posted by Tony Liu <ji...@zuora.com> on 2018/01/04 04:39:35 UTC, 6 replies.
- Dynamic topic subscription without using pattern - posted by chintan mavawala <ch...@gmail.com> on 2018/01/04 05:39:19 UTC, 9 replies.
- Streams - State store directory created automatically - posted by Kristopher Kane <kk...@gmail.com> on 2018/01/04 19:48:14 UTC, 3 replies.
- Re: [DISCUSS] KIP-174 - Deprecate and remove internal converter configs in WorkerConfig - posted by Ewen Cheslack-Postava <ew...@confluent.io> on 2018/01/05 03:33:47 UTC, 1 replies.
- Exception during topic deletion when Kafka is hosted in Docker in Windows. - posted by Alex Galperin <al...@gmail.com> on 2018/01/05 12:28:17 UTC, 1 replies.
- Consumer client not able to receive messages when one of broker is pushed down in the cluster - posted by rAhul <c....@gmail.com> on 2018/01/05 13:48:05 UTC, 2 replies.
- Re: Kafka Streams Avro SerDe version/id caching - posted by Kristopher Kane <kk...@gmail.com> on 2018/01/05 16:56:59 UTC, 0 replies.
- Re: kafka 1.0.1? - posted by Brett Rann <br...@zendesk.com.INVALID> on 2018/01/05 19:58:36 UTC, 0 replies.
- Insanely long recovery time with Kafka 0.11.0.2 - posted by Vincent Rischmann <vi...@rischmann.fr> on 2018/01/05 20:48:23 UTC, 11 replies.
- Topic/Partition Assignment in streams application cluster - posted by Karthik Selva <ka...@julysystems.com> on 2018/01/06 12:38:34 UTC, 2 replies.
- Kafka is going OutOfMemory every time when I increase max.fetch.bytes.per.partition. - posted by Shivam Sharma <28...@gmail.com> on 2018/01/06 15:53:07 UTC, 0 replies.
- KSQL table retention policy - posted by Buntu Dev <bu...@gmail.com> on 2018/01/08 08:00:45 UTC, 1 replies.
- Does MirrorMaker ensures exactly-once? - posted by Jiri Humpolicek <ji...@firma.seznam.cz> on 2018/01/08 11:36:21 UTC, 0 replies.
- Pet Project - Web based consumer for Kafka - posted by Stephen P <st...@gmail.com> on 2018/01/08 13:09:49 UTC, 2 replies.
- Controller connection to broker was unsuccessfull - posted by "chidigam ." <bh...@gmail.com> on 2018/01/08 14:24:40 UTC, 0 replies.
- Kafka Producer hangs on Init Transactions - posted by Nishanth S <ni...@gmail.com> on 2018/01/08 19:08:36 UTC, 1 replies.
- Re: [External] Topic/Partition Assignment in streams application cluster - posted by Steven Schlansker <ss...@opentable.com> on 2018/01/09 00:47:03 UTC, 0 replies.
- Need feedbacks to consumer if hangs due to some __consumer_offsets partitions failed - posted by "1095193290@qq.com" <10...@qq.com> on 2018/01/09 06:44:58 UTC, 1 replies.
- Kafka Streams | Impact on rocksdb stores by Rebalancing - posted by Sameer Kumar <sa...@gmail.com> on 2018/01/09 07:42:30 UTC, 6 replies.
- Less poll interval on StoreChangelogReader - posted by Sameer Kumar <sa...@gmail.com> on 2018/01/09 08:03:40 UTC, 1 replies.
- Need broker side property which can restrict a fetch.size - posted by Shivam Sharma <28...@gmail.com> on 2018/01/09 11:49:50 UTC, 2 replies.
- Best practice for publishing byte messages to Kafka - posted by Ali Nazemian <al...@gmail.com> on 2018/01/09 13:12:17 UTC, 8 replies.
- UNKNOWN_TOPIC_OR_PARTITION for kafka producer - posted by "chidigam ." <bh...@gmail.com> on 2018/01/09 15:28:11 UTC, 0 replies.
- Kafka per topic retention.bytes and global log.retention.bytes not working - posted by Thunder Stumpges <th...@gmail.com> on 2018/01/09 18:02:08 UTC, 5 replies.
- Upgrading Kafka from Version 0.10.2 to 1.0.0 - posted by ZigSphere Tech <zi...@zigsphere.com> on 2018/01/09 21:50:58 UTC, 1 replies.
- Broker won't exit... - posted by Skip Montanaro <sk...@gmail.com> on 2018/01/09 22:44:06 UTC, 9 replies.
- Triggers for offline partition - posted by Di Shang <sh...@au1.ibm.com> on 2018/01/10 01:27:22 UTC, 0 replies.
- map operator on KeyedStream - posted by Moein Hosseini <mo...@gmail.com> on 2018/01/10 11:45:27 UTC, 1 replies.
- KAFKA_50 - Error writing data to the Kafka broker - posted by Jayashree Sanyal <Ja...@aricent.com> on 2018/01/10 17:23:55 UTC, 1 replies.
- Does MirrorMaker ensures exactly-once delivery across clusters? - posted by Jiri Humpolicek <Ji...@seznam.cz> on 2018/01/11 08:46:12 UTC, 3 replies.
- Capturing and storing these Kafka events for query. - posted by Maria Pilar <pi...@gmail.com> on 2018/01/11 16:55:41 UTC, 2 replies.
- Kafka 1.0 upgrade - posted by Tolga Can <to...@snap.com.INVALID> on 2018/01/11 19:58:29 UTC, 1 replies.
- mirror maker producer thread dies with error - posted by Sunil Parmar <su...@gmail.com> on 2018/01/12 00:40:48 UTC, 1 replies.
- [DISCUSS] KIP-247: Add public test utils for Kafka Streams - posted by "Matthias J. Sax" <ma...@confluent.io> on 2018/01/12 02:06:06 UTC, 11 replies.
- log retention and rolling behaviors - posted by Jay Guo <gu...@gmail.com> on 2018/01/12 11:06:29 UTC, 0 replies.
- Kafka on kubernetes - posted by Devendar Rao <de...@gmail.com> on 2018/01/12 20:55:23 UTC, 2 replies.
- [ANNOUNCE] New committer: Matthias J. Sax - posted by Guozhang Wang <wa...@gmail.com> on 2018/01/12 22:59:21 UTC, 14 replies.
- how can Bind broker to specific network interface - posted by 猪少爷 <zh...@foxmail.com> on 2018/01/14 14:37:30 UTC, 0 replies.
- what are common ways to convert info on a web site into a log entry? - posted by James Smyth <sm...@gmail.com> on 2018/01/15 19:47:34 UTC, 4 replies.
- one machine that have four network..... - posted by 猪少爷 <zh...@foxmail.com> on 2018/01/16 02:14:35 UTC, 3 replies.
- Re: 1 to N transformers in Kafka Connect - posted by Konstantine Karantasis <ko...@confluent.io> on 2018/01/16 05:31:21 UTC, 0 replies.
- Re: Kafka Producer HA - using Kafka Connect - posted by Konstantine Karantasis <ko...@confluent.io> on 2018/01/16 05:40:57 UTC, 0 replies.
- Re: Connectors Information from Microsoft SQL Server to Kafka - posted by Konstantine Karantasis <ko...@confluent.io> on 2018/01/16 06:04:35 UTC, 0 replies.
- consumer.seekToBeginning() will disable "enable.auto.commit" - posted by 杨光 <la...@gmail.com> on 2018/01/16 11:25:15 UTC, 0 replies.
- 回复：one machine that have four network..... - posted by 猪少爷 <zh...@foxmail.com> on 2018/01/16 13:08:48 UTC, 0 replies.
- __consumer_offsets too big - posted by Shravan R <sk...@gmail.com> on 2018/01/16 16:28:52 UTC, 5 replies.
- Re: How can I repartition/rebalance topics processed by a Kafka Streams topology? - posted by Dmitry Minkovsky <dm...@gmail.com> on 2018/01/16 18:46:04 UTC, 0 replies.
- Intermittent NoLeaderForPartition exceptions - posted by Atul Mohan <at...@gmail.com> on 2018/01/16 19:00:56 UTC, 1 replies.
- Kafka Streams topology does not replay correctly - posted by Dmitry Minkovsky <dm...@gmail.com> on 2018/01/16 23:08:00 UTC, 9 replies.
- I would like to increase the bandwidth by binding each broker to each network card in one machine. Is this feasible? - posted by 猪少爷 <zh...@foxmail.com> on 2018/01/17 01:21:45 UTC, 1 replies.
- [HELP] Guidelines/tools to test kafka performance with application layer involved - posted by Pritam Kadam <kp...@thoughtworks.com> on 2018/01/17 05:25:12 UTC, 0 replies.
- Ambiguous entry in docs - posted by Алекс Турс <go...@gmail.com> on 2018/01/17 07:59:13 UTC, 0 replies.
- [Production Guideline] Is it good idea to provide limited number of brokers(3 brokers) in kafka client in large cluster - posted by Pritam Kadam <kp...@thoughtworks.com> on 2018/01/17 08:48:40 UTC, 1 replies.
- Kafka Replication Factor - posted by Sameer Kumar <sa...@gmail.com> on 2018/01/17 12:37:28 UTC, 2 replies.
- [ANNOUNCE] New Kafka PMC Member: Rajini Sivaram - posted by Gwen Shapira <gw...@confluent.io> on 2018/01/17 18:48:51 UTC, 12 replies.
- 答复: [ANNOUNCE] New Kafka PMC Member: Rajini Sivaram - posted by Hu Xi <hu...@hotmail.com> on 2018/01/18 00:57:02 UTC, 0 replies.
- [VOTE] KIP-247: Add public test utils for Kafka Streams - posted by "Matthias J. Sax" <ma...@confluent.io> on 2018/01/18 02:09:20 UTC, 7 replies.
- Unrecoverable kafka cluster after failed rolling restart - posted by Andrey Falko <af...@salesforce.com> on 2018/01/18 04:01:20 UTC, 0 replies.
- This server is not the leader for that topic-partition - posted by 杰 杨 <fu...@live.com> on 2018/01/18 05:37:04 UTC, 0 replies.
- Enable Kafka Authentication on 0.9 - posted by Sunil Parmar <su...@gmail.com> on 2018/01/18 19:28:08 UTC, 0 replies.
- Error sink parse Json - posted by Maria Pilar <pi...@gmail.com> on 2018/01/18 20:56:22 UTC, 0 replies.
- One type of event per topic? - posted by Maria Pilar <pi...@gmail.com> on 2018/01/18 20:57:17 UTC, 2 replies.
- What's the use of timestamp in ProducerRecord? - posted by Jake Yoon <ja...@eggbun-edu.com> on 2018/01/19 03:46:23 UTC, 4 replies.
- 回复：I would like to increase the bandwidth by binding each broker to each network card in one machine. Is this feasible? - posted by 猪少爷 <zh...@foxmail.com> on 2018/01/19 04:47:02 UTC, 0 replies.
- Topic UI not Displaying Any Topic - posted by Bunty Ray <bu...@gmail.com> on 2018/01/19 07:08:51 UTC, 0 replies.
- How many kafka streams app is recommended to run on single machine in production ? - posted by Saloni Vithalani <sa...@thoughtworks.com> on 2018/01/19 17:23:08 UTC, 1 replies.
- How to always consume from latest offset in kafka-streams - posted by Saloni Vithalani <sa...@thoughtworks.com> on 2018/01/19 17:23:47 UTC, 5 replies.
- Registering Amadeus company in the "Powered By" page - posted by Pierre DOR <pd...@amadeus.com> on 2018/01/19 17:50:57 UTC, 0 replies.
- Training and Cert course recommendation - posted by brian spallholtz <br...@gmail.com> on 2018/01/19 18:15:09 UTC, 1 replies.
- Kafka Streams and Scaling Brokers - posted by Puneet Lakhina <pu...@gmail.com> on 2018/01/19 20:30:03 UTC, 1 replies.
- Kafka functionality - posted by Aman Shaikh <am...@gmail.com> on 2018/01/21 09:15:52 UTC, 1 replies.
- Does Kafka consumer api provide a way for you to search for partition number of a topic with key? - posted by "TSANG, Brilly" <br...@hk.daiwacm.com> on 2018/01/22 02:08:02 UTC, 2 replies.
- offsetsForTimes API performance - posted by srimugunthan dhandapani <sr...@gmail.com> on 2018/01/22 14:59:51 UTC, 2 replies.
- can't feed remote broker with producer demo - posted by Rotem Jacobi <ro...@radcom.com> on 2018/01/22 15:16:00 UTC, 2 replies.
- bug config port / listeners - posted by Elias Abacioglu <el...@deltaprojects.com> on 2018/01/23 11:35:21 UTC, 0 replies.
- Adding company CICS to "Powered by" page? - posted by Christoffer Ramm <ch...@cics.se> on 2018/01/23 15:34:52 UTC, 0 replies.
- Re: Merging Two KTables - posted by Dmitry Minkovsky <dm...@gmail.com> on 2018/01/23 15:46:46 UTC, 2 replies.
- Kafka/zookeeper logs in every command - posted by José Ribeiro <jo...@hotmail.com> on 2018/01/23 15:57:18 UTC, 4 replies.
- What is the best way to re-key a KTable? - posted by Dmitry Minkovsky <dm...@gmail.com> on 2018/01/23 17:14:29 UTC, 1 replies.
- Regarding : Store stream for infinite time - posted by Aman Rastogi <am...@gmail.com> on 2018/01/23 17:30:44 UTC, 2 replies.
- Contiguous Offsets on non-compacted topics - posted by Justin Miller <ju...@protectwise.com> on 2018/01/23 17:52:03 UTC, 4 replies.
- JSONSchema Kafka Connect Converter - posted by Andrew Otto <ot...@wikimedia.org> on 2018/01/23 19:17:52 UTC, 1 replies.
- Kafka Connect high CPU / Memory usage - posted by Ziliang Chen <zl...@gmail.com> on 2018/01/23 21:57:52 UTC, 0 replies.
- Memory Leak in Kafka - posted by Avinash Herle <av...@gmail.com> on 2018/01/24 01:06:42 UTC, 3 replies.
- best practices for replication factor / partitions __consumer_offsets - posted by Dennis <da...@gmail.com> on 2018/01/24 03:21:57 UTC, 1 replies.
- uncontinuous offset for consumer seek - posted by namesuperwood <na...@gmail.com> on 2018/01/24 03:25:02 UTC, 0 replies.
- Is the key for a state need to be the key of incoming message - posted by Vincent Maurin <vi...@glispa.com> on 2018/01/24 08:07:54 UTC, 0 replies.
- Problem with multiple Kafka Streams - posted by Gustavo Torres <gu...@catho.com> on 2018/01/24 16:57:26 UTC, 2 replies.
- Re: deduplication strategy for Kafka Streams DSL - posted by Dmitry Minkovsky <dm...@gmail.com> on 2018/01/24 19:42:52 UTC, 6 replies.
- How to find the latest timestamp for a partition - posted by Caleb Spare <ca...@liftoff.io> on 2018/01/25 00:41:22 UTC, 0 replies.
- How to set partition.assignment.strategy at run time? - posted by Jun MA <mj...@gmail.com> on 2018/01/25 05:13:48 UTC, 0 replies.
- Kafka Consumer Issue - posted by Siva A <si...@gmail.com> on 2018/01/25 06:53:39 UTC, 3 replies.
- kafka controller setting for detecting broker failure and re-electing a new leader for partitions? - posted by Yu Yang <yu...@gmail.com> on 2018/01/25 07:42:58 UTC, 0 replies.
- 答复: kafka controller setting for detecting broker failure and re-electing a new leader for partitions? - posted by Hu Xi <hu...@hotmail.com> on 2018/01/25 08:02:39 UTC, 1 replies.
- Cater to processing longer than max.poll.interval.ms - posted by Sameer Kumar <sa...@gmail.com> on 2018/01/25 09:27:09 UTC, 3 replies.
- Best practices Partition Key - posted by Maria Pilar <pi...@gmail.com> on 2018/01/25 13:47:17 UTC, 3 replies.
- Kafka Reassignment - traffic is different for the same type of reassignment - posted by Yi Yin <yi...@gmail.com> on 2018/01/26 02:14:42 UTC, 0 replies.
- Kafka-streams API skipping offsets - posted by Tomáš Lach <la...@gmail.com> on 2018/01/26 08:34:14 UTC, 1 replies.
- skipped-records-rate vs skippedDueToDeserializationError-rate metric in streams app - posted by Srikanth <sr...@gmail.com> on 2018/01/26 14:30:59 UTC, 9 replies.
- Re: GDPR appliance - posted by David Espinosa <es...@gmail.com> on 2018/01/26 14:38:58 UTC, 0 replies.
- Confluent REST proxy and Kafka Headers - posted by David Espinosa <es...@gmail.com> on 2018/01/26 14:41:21 UTC, 0 replies.
- Re: Running Kafka 1.0 binaries with inter.broker.protocol.version = 0.10 - posted by Debraj Manna <su...@gmail.com> on 2018/01/27 09:17:39 UTC, 0 replies.
- Recommended max number of topics (and data separation) - posted by Monty Hindman <mo...@gmail.com> on 2018/01/28 01:22:29 UTC, 5 replies.
- How to make savepoints more robust in the face of refactorings ? - posted by jelmer <jk...@gmail.com> on 2018/01/28 16:56:48 UTC, 0 replies.
- Re: Kafka Streams app error while rebalancing - posted by Srikanth <sr...@gmail.com> on 2018/01/29 07:28:38 UTC, 0 replies.
- Log segment deletion - posted by Martin Kleppmann <ma...@kleppmann.com> on 2018/01/29 15:44:45 UTC, 4 replies.
- Choose the number of partitions/topics - posted by Maria Pilar <pi...@gmail.com> on 2018/01/29 16:58:17 UTC, 1 replies.
- New post about CDC and Kafka - posted by Ofir Sharony <of...@myheritage.com> on 2018/01/29 19:57:56 UTC, 0 replies.
- Kafka Consumers not rebalancing. - posted by satyajit vegesna <sa...@gmail.com> on 2018/01/29 23:36:36 UTC, 0 replies.
- monitor consumer offset lag script/code - posted by Sunil Parmar <su...@gmail.com> on 2018/01/30 00:40:27 UTC, 2 replies.
- ReadOnlyKeyValueStore.range API - posted by Debasish Ghosh <gh...@gmail.com> on 2018/01/30 06:49:31 UTC, 1 replies.
- Group consumer cannot consume messages if kafka service on specific node in test cluster is down - posted by Zoran <zo...@bulbtech.com> on 2018/01/30 13:59:54 UTC, 2 replies.
- what drives deletion of kafka topics - posted by karan alang <ka...@gmail.com> on 2018/01/30 19:51:48 UTC, 0 replies.
- Kafka Consumer Offsets unavailable during rebalancing - posted by Wouter Bancken <wo...@aca-it.be> on 2018/01/30 20:04:23 UTC, 0 replies.
- Load connect jars without restarting connector - posted by fa...@technify.pk on 2018/01/31 10:45:31 UTC, 0 replies.