users@kafka.apache.org, 2018-02

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

- Streams: Why is ForwardingCacheFlushListener internal? Can I replicate its functionality in my code? - posted by Dmitry Minkovsky <dm...@gmail.com> on 2018/02/01 02:19:22 UTC, 5 replies.
- Re: monitor consumer offset lag script/code - posted by Sunil Parmar <su...@gmail.com> on 2018/02/01 03:41:54 UTC, 0 replies.
- NoClassDefFoundError: Could not initialize class com.yammer.metrics.Metrics - posted by ? ?? <wa...@outlook.com> on 2018/02/01 06:11:16 UTC, 2 replies.
- KAFKA step by step installation help - posted by trading DEV <tr...@neml.in> on 2018/02/01 10:19:49 UTC, 0 replies.
- Fixing Wrecked Kafka Topic Partitions after a cluster reconfigure - posted by Traiano Welcome <tr...@gmail.com> on 2018/02/01 13:28:25 UTC, 2 replies.
- Failed to send SSL Close messages unexpected status returned by SSLEngine.wrap, expected Close received Ok - posted by John Chu <yy...@gmail.com> on 2018/02/01 17:26:23 UTC, 0 replies.
- Re: Kafka Consumers not rebalancing. - posted by satyajit vegesna <sa...@gmail.com> on 2018/02/01 21:53:30 UTC, 0 replies.
- Re: Recommended max number of topics (and data separation) - posted by Andrey Falko <af...@salesforce.com> on 2018/02/02 01:28:33 UTC, 1 replies.
- Can leader be removed from ISR if leader is unstable - posted by tao xiao <xi...@gmail.com> on 2018/02/02 07:26:49 UTC, 0 replies.
- Re: Group consumer cannot consume messages if kafka service on specific node in test cluster is down - posted by Zoran <zo...@bulbtech.com> on 2018/02/02 09:06:51 UTC, 1 replies.
- Kafka Log deletion Problem - posted by SenthilKumar K <se...@gmail.com> on 2018/02/02 13:38:15 UTC, 0 replies.
- Re: skipped-records-rate vs skippedDueToDeserializationError-rate metric in streams app - posted by Srikanth <sr...@gmail.com> on 2018/02/02 13:43:08 UTC, 0 replies.
- subscribe kafka topics - posted by Krishnakumar Gurumurthy <Kr...@alten.se> on 2018/02/02 13:49:26 UTC, 0 replies.
- Usual remedy for "Under Replicated" and "Offline Partitions" - posted by Richard Rodseth <rr...@gmail.com> on 2018/02/02 19:27:56 UTC, 2 replies.
- Moving data from one cluster to another with Kafka Streams - posted by Geoffrey Holmes <gh...@pinsightmedia.com> on 2018/02/02 22:54:48 UTC, 2 replies.
- Kafka streams API for .net - posted by "Bykov, Serge" <se...@bell.ca> on 2018/02/02 23:03:04 UTC, 0 replies.
- Shouldn't KStream#through let you specify a Consumed? - posted by Dmitry Minkovsky <dm...@gmail.com> on 2018/02/02 23:54:52 UTC, 3 replies.
- Recovering Under Replicated Partitions - posted by Dylan Martin <dm...@istreamplanet.com> on 2018/02/03 00:12:06 UTC, 0 replies.
- Choosing Kafka for Real Time Dashboard Application - posted by Matan Givo <ma...@gmail.com> on 2018/02/03 02:50:58 UTC, 1 replies.
- Partition rebalancing when both leader and follower is down? - posted by Devendar Rao <de...@gmail.com> on 2018/02/03 20:45:13 UTC, 2 replies.
- Store not ready - posted by dizzy0ny <di...@gmail.com> on 2018/02/04 03:39:51 UTC, 3 replies.
- Strange Topic ... - posted by adrien ruffie <ad...@hotmail.fr> on 2018/02/04 19:14:09 UTC, 3 replies.
- Re: Kafka Consumer Offsets unavailable during rebalancing - posted by Wouter Bancken <wo...@aca-it.be> on 2018/02/04 19:51:26 UTC, 7 replies.
- Kafka Streams : Connection to node -1 could not be established. Broker may not be available. - posted by Tony John <to...@gmail.com> on 2018/02/05 08:00:38 UTC, 4 replies.
- Issues with Kafka Group Coordinator Failover - posted by Krishnakumar Gurumurthy <Kr...@alten.se> on 2018/02/05 08:10:20 UTC, 1 replies.
- kafka-streams using throught - posted by Pegerto Fernandez Torres <pe...@opencredo.com> on 2018/02/05 11:27:32 UTC, 1 replies.
- Custom window implementation - posted by Claudia Wegmann <c....@kasasi.de> on 2018/02/05 12:51:45 UTC, 0 replies.
- Which record is processed when topology restart ? - posted by Saïd Bouras <sa...@gmail.com> on 2018/02/05 17:09:22 UTC, 1 replies.
- Consumer group - posted by Maria Pilar <pi...@gmail.com> on 2018/02/05 18:59:25 UTC, 0 replies.
- [VOTE] 1.0.1 RC0 - posted by Ewen Cheslack-Postava <ew...@confluent.io> on 2018/02/06 03:48:59 UTC, 4 replies.
- Kafka Utilities - posted by Bryan Baugher <bj...@gmail.com> on 2018/02/06 20:13:25 UTC, 0 replies.
- log.retention.bytes not working as expected - posted by Raghav <ra...@gmail.com> on 2018/02/06 20:24:27 UTC, 8 replies.
- Re: Kafka per topic retention.bytes and global log.retention.bytes not working - posted by Raghav <ra...@gmail.com> on 2018/02/06 20:27:32 UTC, 0 replies.
- How to calculate consumer lag in wall-clock time by querying the broker? - posted by Jeff Widman <je...@jeffwidman.com> on 2018/02/07 05:39:44 UTC, 1 replies.
- Kafka Streams balancing of tasks across nodes - posted by Russell Teabeault <rt...@twitter.com.INVALID> on 2018/02/07 18:37:34 UTC, 10 replies.
- Any idea why zookeeper will run into connection issue. - posted by Tony Liu <ji...@zuora.com> on 2018/02/07 19:39:28 UTC, 0 replies.
- Bay Area Apache Kafka Meetup - Morning of Feb 20 - posted by Vahid S Hashemian <va...@us.ibm.com> on 2018/02/07 20:19:46 UTC, 0 replies.
- Consume latest offset after rebalance - posted by James Buchan <ja...@googlemail.com> on 2018/02/07 20:47:18 UTC, 0 replies.
- how to enhance Kafka streaming Consumer rate ? - posted by ? ? <fu...@live.com> on 2018/02/08 08:30:59 UTC, 1 replies.
- are offsets per consumer or per consumer group? - posted by Xavier Noria <fx...@hashref.com> on 2018/02/08 12:58:38 UTC, 4 replies.
- ProducerFencedException: Producer attempted an operation with an old epoch. - posted by dan bress <da...@gmail.com> on 2018/02/08 17:54:11 UTC, 1 replies.
- Information regarding Kafka 2.10-0.10.1.1 version - posted by Pawan K <pa...@gmail.com> on 2018/02/08 18:28:52 UTC, 1 replies.
- Question Related to Zookeeper and kafka java error message. - posted by "Raymond, Shawn P CTR USARMY NETCOM (US)" <sh...@mail.mil> on 2018/02/08 19:39:16 UTC, 2 replies.
- mistake in Kafka the definitive guide - posted by adrien ruffie <ad...@hotmail.fr> on 2018/02/08 21:14:53 UTC, 5 replies.
- Cross-cluster mirror making - posted by Husna Hadi <hh...@adobe.com.INVALID> on 2018/02/08 22:21:07 UTC, 1 replies.
- How start with Kafka? - posted by Andy <bo...@gmail.com> on 2018/02/08 23:44:56 UTC, 2 replies.
- Cancel partition reassignment? - posted by Dylan Martin <dm...@istreamplanet.com> on 2018/02/09 00:12:07 UTC, 1 replies.
- why kafka index file use memory mapped files ,however log file doesn't - posted by YuFeng Shen <vb...@hotmail.com> on 2018/02/09 05:47:03 UTC, 6 replies.
- Need to know kafka client api version - posted by Pawan Gandhi <pa...@gmail.com> on 2018/02/09 10:58:43 UTC, 0 replies.
- [Streams] partition expansion of input streams - posted by Pegerto Fernandez Torres <pe...@opencredo.com> on 2018/02/09 14:51:45 UTC, 2 replies.
- Filebeat 6.1 not publishing logs to kafka 0.11.0.1 and kafka 0.10.2.0 - posted by Sandeep Sarkar <sa...@oracle.com> on 2018/02/09 15:13:21 UTC, 0 replies.
- max.block.ms and TimeoutException on startup question - posted by Shane Gannon <sg...@gmail.com> on 2018/02/09 16:29:56 UTC, 0 replies.
- Filebeat 6.1 is not pushing logs to kafka - posted by Sandeep Sarkar <sa...@oracle.com> on 2018/02/10 04:03:52 UTC, 0 replies.
- question on serialization .. - posted by Debasish Ghosh <gh...@gmail.com> on 2018/02/10 19:00:50 UTC, 11 replies.
- DumpLogSegment - posted by adrien ruffie <ad...@hotmail.fr> on 2018/02/10 21:54:14 UTC, 4 replies.
- Re: Ambiguous entry in docs - posted by Kamal <ka...@gmail.com> on 2018/02/11 08:45:07 UTC, 0 replies.
- unable to find custom JMX metrics - posted by Salah Alkawari <sa...@yahoo.com.INVALID> on 2018/02/12 11:52:06 UTC, 2 replies.
- [VOTE] 1.0.1 RC1 - posted by Ewen Cheslack-Postava <ew...@confluent.io> on 2018/02/12 18:15:35 UTC, 14 replies.
- org.apache.kafka.clients.consumer.OffsetOutOfRangeException - posted by Mina Aslani <as...@gmail.com> on 2018/02/12 19:04:52 UTC, 6 replies.
- Causes of partition leader re election - posted by Sunil Parmar <su...@gmail.com> on 2018/02/12 21:07:11 UTC, 0 replies.
- Typo in "Processing with local state" - posted by Ted Yu <yu...@gmail.com> on 2018/02/12 21:49:47 UTC, 1 replies.
- Confluent Replicator - posted by "Tauzell, Dave" <Da...@surescripts.com> on 2018/02/12 22:39:45 UTC, 0 replies.
- Kafka Transactions with a stretch cluster - posted by Joe Hammerman <jh...@squarespace.com.INVALID> on 2018/02/13 01:40:32 UTC, 0 replies.
- How to manually delete all files under a topic's partitioins - posted by "le.cui@qtparking.com" <le...@qtparking.com> on 2018/02/13 07:45:58 UTC, 0 replies.
- Kafka Stream tuning. - posted by "TSANG, Brilly" <br...@hk.daiwacm.com> on 2018/02/13 07:49:39 UTC, 4 replies.
- The Problem about Kafka 1.0 - posted by cs...@dev.neoncrm.com on 2018/02/13 10:15:30 UTC, 0 replies.
- Authentication between Producer and Broker - posted by Sivaprakash <si...@gmail.com> on 2018/02/13 11:56:46 UTC, 0 replies.
- one topic, one partition, many consumer instances - posted by Xavier Noria <fx...@hashref.com> on 2018/02/13 13:30:39 UTC, 3 replies.
- Kafka consumer commit behaviour on rebalance - posted by pradeep s <sr...@gmail.com> on 2018/02/13 17:31:20 UTC, 1 replies.
- questions about replication factor of __consumer_offsets topic - posted by Dennis <da...@gmail.com> on 2018/02/14 03:47:23 UTC, 0 replies.
- error when attempting a unit test of spring kafka producer - posted by Ian Ewing <ia...@gmail.com> on 2018/02/14 04:03:50 UTC, 3 replies.
- Compression in Kafka - posted by Uddhav Arote <ar...@gmail.com> on 2018/02/14 05:28:56 UTC, 4 replies.
- Finding consumer group coordinator from CLI? - posted by Devendar Rao <de...@gmail.com> on 2018/02/14 08:06:07 UTC, 1 replies.
- Kafka cluster instablility - posted by Avinash Herle <av...@gmail.com> on 2018/02/14 17:38:51 UTC, 1 replies.
- Re: Kafka Streams 0.11 consumers losing offsets for all group.ids - posted by "Matthias J. Sax" <ma...@confluent.io> on 2018/02/14 21:11:12 UTC, 0 replies.
- Static IP Configuration - posted by Sivaprakash <si...@gmail.com> on 2018/02/15 11:50:29 UTC, 7 replies.
- Producer fails to write to broker - Quickstart guide - posted by "J.Jackson" <jo...@gmail.com> on 2018/02/15 16:23:49 UTC, 0 replies.
- Spike in Metarequest call timings in Java client - posted by Biju N <bi...@gmail.com> on 2018/02/15 17:22:21 UTC, 0 replies.
- Kafka Streams app can not be reset. - posted by Russell Teabeault <rt...@twitter.com.INVALID> on 2018/02/16 06:09:03 UTC, 5 replies.
- Error handling - posted by Maria Pilar <pi...@gmail.com> on 2018/02/16 06:18:23 UTC, 1 replies.
- Fwd: Message throughput per day - Kafka - posted by siva prasad <si...@gmail.com> on 2018/02/16 11:26:54 UTC, 6 replies.
- Java Consumer Not reading message - - posted by Debraj Manna <su...@gmail.com> on 2018/02/16 11:53:58 UTC, 3 replies.
- Review for ISSUE #1194 - Windows Support - posted by "M. Manna" <ma...@gmail.com> on 2018/02/16 13:19:47 UTC, 0 replies.
- Recovering from disk full - posted by Biju N <bi...@gmail.com> on 2018/02/16 17:41:06 UTC, 0 replies.
- Kafka connect mysql - posted by adrien ruffie <ad...@hotmail.fr> on 2018/02/17 19:04:04 UTC, 6 replies.
- Zookeeper Error - posted by Maria Pilar <pi...@gmail.com> on 2018/02/18 01:45:35 UTC, 7 replies.
- ey.converter: Class io.confluent.connect.avro.AvroConverter could not be found - posted by adrien ruffie <ad...@hotmail.fr> on 2018/02/18 20:26:12 UTC, 0 replies.
- KafkaUtils.createStream(..) is removed for API - posted by naresh Goud <na...@gmail.com> on 2018/02/19 01:17:33 UTC, 3 replies.
- Aggregation events Stream Kafka - posted by Maria Pilar <pi...@gmail.com> on 2018/02/19 09:19:35 UTC, 2 replies.
- Testing with MockConsumer - posted by Gabriel Giussi <ga...@gmail.com> on 2018/02/19 12:39:03 UTC, 3 replies.
- Kafka control messages - posted by "Young, Ben" <Be...@fisglobal.com> on 2018/02/19 12:53:05 UTC, 1 replies.
- connecting to 2 different clusters with different sasl realms in a single process - posted by Michal Hariš <mi...@gmail.com> on 2018/02/19 14:40:57 UTC, 1 replies.
- timestamp-oriented API - posted by Xavier Noria <fx...@hashref.com> on 2018/02/19 15:36:52 UTC, 2 replies.
- Kafka broker throwing ConfigException Invalid value configuration log.segment.bytes: Not a number of type INT - posted by Debraj Manna <su...@gmail.com> on 2018/02/19 17:39:13 UTC, 0 replies.
- Consumer group intermittently can not read any records from a cluster with 3 nodes that has one node down - posted by Behrang <be...@gmail.com> on 2018/02/20 08:00:50 UTC, 3 replies.
- Issues with Kafka - posted by Shatadeep Banerjee <sh...@yahoo.co.in.INVALID> on 2018/02/20 10:47:11 UTC, 1 replies.
- Who is assigned to which partitions - posted by Per Steffensen <pe...@gmail.com> on 2018/02/20 13:13:40 UTC, 3 replies.
- Save the date: ApacheCon North America, September 24-27 in Montréal - posted by Rich Bowen <rb...@apache.org> on 2018/02/20 14:21:23 UTC, 0 replies.
- broker properties explanations - posted by adrien ruffie <ad...@hotmail.fr> on 2018/02/20 20:45:48 UTC, 2 replies.
- Building a bugfix branch and using it with existing distributions - posted by Niek Peeters <ni...@outlook.com> on 2018/02/21 10:32:49 UTC, 0 replies.
- Doubts in KStreams - posted by pravin kumar <pk...@gmail.com> on 2018/02/21 10:40:53 UTC, 1 replies.
- commiting consumed offsets synchronously (every message) - posted by "Marasoiu, Nicu" <ni...@metrosystems.net> on 2018/02/21 10:57:24 UTC, 3 replies.
- FINAL REMINDER: CFP for Apache EU Roadshow Closes 25th February - posted by Sharan F <sh...@apache.org> on 2018/02/21 17:18:07 UTC, 0 replies.
- difference between key.serializer & default.key.serde - posted by adrien ruffie <ad...@hotmail.fr> on 2018/02/21 21:28:21 UTC, 2 replies.
- [VOTE] 1.0.1 RC2 - posted by Ewen Cheslack-Postava <ew...@confluent.io> on 2018/02/22 00:06:41 UTC, 0 replies.
- Doubts about multiple instance in kafka - posted by pravin kumar <pk...@gmail.com> on 2018/02/22 06:15:31 UTC, 1 replies.
- usage of depricated method in kafka 2_12.1.0.0 - posted by pravin kumar <pk...@gmail.com> on 2018/02/22 07:08:56 UTC, 1 replies.
- Re: Consumer group describe issue - posted by sahil aggarwal <sa...@gmail.com> on 2018/02/22 08:39:47 UTC, 1 replies.
- Kafka Streams : TimeoutException Expiring Records - posted by Tony John <to...@gmail.com> on 2018/02/22 13:14:51 UTC, 2 replies.
- Producer blocks on send to topic that doesn't exist if auto create is disabled - posted by Josef Ludvíček <jo...@gmail.com> on 2018/02/22 14:45:20 UTC, 0 replies.
- Review fo patch JIRA 1194 (pull req 3838) - posted by "M. Manna" <ma...@gmail.com> on 2018/02/22 19:46:57 UTC, 0 replies.
- ProcessorTopology - posted by pravin kumar <pk...@gmail.com> on 2018/02/23 05:09:44 UTC, 2 replies.
- Kafka Consumer v1.0 terminates prematurely - posted by "Javed, Haseeb" <ja...@buckeyemail.osu.edu> on 2018/02/23 23:04:33 UTC, 0 replies.
- Restricting client access to zookeeper metadata - posted by Reema Chugani <re...@outlook.com> on 2018/02/24 03:11:27 UTC, 5 replies.
- Kafka Zookeeper Connection - posted by Soheil Pourbafrani <so...@gmail.com> on 2018/02/24 08:03:34 UTC, 6 replies.
- Re: Kafka/zookeeper logs in every command - posted by 张家利 <zh...@126.com> on 2018/02/24 10:01:07 UTC, 0 replies.
- Kafka metrics attribute meaning - posted by Soheil Pourbafrani <so...@gmail.com> on 2018/02/24 15:01:39 UTC, 3 replies.
- [VOTE] 1.1.0 RC0 - posted by Damian Guy <da...@gmail.com> on 2018/02/24 16:16:11 UTC, 5 replies.
- replica.fetch.max.bytes split message or not ? - posted by adrien ruffie <ad...@hotmail.fr> on 2018/02/24 16:52:20 UTC, 4 replies.
- Kafka 0.8.2 Producers -> Kafka Brokers 0.9.x - posted by Waleed Fateem <wa...@gmail.com> on 2018/02/24 19:19:34 UTC, 1 replies.
- Zookeeper server failover with kakfa - posted by Biplob Biswas <re...@gmail.com> on 2018/02/26 08:53:09 UTC, 0 replies.
- difference between 2 options - posted by adrien ruffie <ad...@hotmail.fr> on 2018/02/26 13:51:28 UTC, 3 replies.
- Writing a message to all partitions - posted by Ryan Worsley <ry...@gmail.com> on 2018/02/26 16:18:09 UTC, 1 replies.
- Re: kafka 1.0.1? - posted by Joseph Ziegler <jo...@gmail.com> on 2018/02/26 19:23:59 UTC, 1 replies.
- question on doing deduplication with KafkaStreams - posted by "Marasoiu, Nicu" <ni...@metrosystems.net> on 2018/02/27 09:03:32 UTC, 2 replies.
- If KafkaConsumer's commitAsync() has been multiply call, are corresponding commit callbacks invoked in the same order? - posted by "yan.chengyu@embedway.com" <ya...@embedway.com> on 2018/02/27 10:02:10 UTC, 0 replies.
- kafka-streams died with org.apache.kafka.clients.consumer.CommitFailedException - posted by Dmitriy Vsekhvalnov <dv...@gmail.com> on 2018/02/27 16:06:40 UTC, 2 replies.
- Zookeeper and Kafka JMX metrics - posted by Arunkumar <pm...@yahoo.com.INVALID> on 2018/02/27 22:19:33 UTC, 1 replies.
- Restrictions on distributing Kafka - posted by Patrick Siddle <ps...@gmail.com> on 2018/02/27 22:57:31 UTC, 0 replies.
- Total ordering of messages across partitions - posted by Feiran Wang <fe...@gmail.com> on 2018/02/28 00:13:08 UTC, 0 replies.
- unsubscribe me - posted by Yuejie Chen <ch...@gmail.com> on 2018/02/28 03:49:22 UTC, 1 replies.
- kafka streams, docker/k18s and rocksdb - storage performance - posted by "Marasoiu, Nicu" <ni...@metrosystems.net> on 2018/02/28 08:39:59 UTC, 1 replies.
- Setting topic's offset from the shell - posted by Zoran <zo...@bulbtech.com> on 2018/02/28 08:48:56 UTC, 2 replies.
- aggregation tables mirrored in kafka & rocksdb - posted by "Marasoiu, Nicu" <ni...@metrosystems.net> on 2018/02/28 13:45:39 UTC, 1 replies.
- MockConsumer class for Python? - posted by Skip Montanaro <sk...@gmail.com> on 2018/02/28 15:40:14 UTC, 1 replies.