You are viewing a plain text version of this content. The canonical link for it is here.
- Tips for debugging per partition stream time? - posted by dan bress <da...@gmail.com> on 2018/04/02 18:26:24 UTC, 4 replies.
- Possible to enable client SSL when PLAINTEXT brokers exist in the cluster? - posted by Alexander Maniates <ma...@gmail.com> on 2018/04/02 21:07:58 UTC, 1 replies.
- SSL does not work - posted by Eduard <ed...@nestlogic.com> on 2018/04/03 07:28:11 UTC, 1 replies.
- Making a Window services for kafka having sasl and ssl configuration - posted by ashish chauhan <as...@gmail.com> on 2018/04/03 08:16:11 UTC, 1 replies.
- accessing Kafka broker 0.9.0.1 with Kafka-client 1.0.0 - posted by Nomar Morado <no...@gmail.com> on 2018/04/03 13:36:38 UTC, 2 replies.
- Closing a KafkaConsumer triggers a rebalance in KafkaConsumers subscribed to other topics. Is this the expected behavior? - posted by Gabriel Giussi <ga...@gmail.com> on 2018/04/03 16:17:41 UTC, 1 replies.
- Error with kafka stream and kafka - posted by Ariel Debernardi <ad...@hexacta.com> on 2018/04/03 17:58:22 UTC, 1 replies.
- Re: advertised.listeners - posted by Darshan <pu...@gmail.com> on 2018/04/03 21:45:21 UTC, 9 replies.
- Re: Running SSL and PLAINTEXT mode together (Kafka 10.2.1) - posted by Darshan <pu...@gmail.com> on 2018/04/03 22:01:47 UTC, 0 replies.
- Kafka topic retention - posted by Tony DOIN <to...@thales-services.fr> on 2018/04/04 05:53:16 UTC, 1 replies.
- kafka-streams Invalid transition attempted from state READY to state ABORTING_TRANSACTION - posted by Frederic Arno <fr...@gmail.com> on 2018/04/04 09:49:07 UTC, 7 replies.
- kafka-streams TopologyTestDriver problem with EXACTLY_ONCE - posted by Frederic Arno <fr...@gmail.com> on 2018/04/04 10:03:12 UTC, 5 replies.
- TimeoutException not being triggered, stuck on OUT_OF_ORDER_SEQUENCE_NUMBER - posted by Saheb Motiani <sa...@cakesolutions.net> on 2018/04/04 10:05:30 UTC, 1 replies.
- message queueing questions? - posted by Victor L <vl...@gmail.com> on 2018/04/04 21:41:11 UTC, 1 replies.
- SSL Keymanager implementation using OS managed keystore - posted by Koushik Chitta <kc...@microsoft.com.INVALID> on 2018/04/05 01:29:04 UTC, 0 replies.
- Question regarding batch.max.rows - posted by Mike MBS <di...@gmail.com> on 2018/04/05 02:17:49 UTC, 0 replies.
- Kafka high IO wait on certain nodes - posted by XiaoChuan Yu <xi...@kik.com> on 2018/04/05 03:08:47 UTC, 0 replies.
- poll returns records while paused (Kafka 0.10.2) - posted by Scott Thibault <sc...@multiscalehn.com> on 2018/04/05 15:16:33 UTC, 0 replies.
- Re: delivery semantics? - posted by Jacob Sheck <sh...@gmail.com> on 2018/04/05 15:54:41 UTC, 0 replies.
- What causes partitions to be revoked? - posted by Scott Thibault <sc...@multiscalehn.com> on 2018/04/05 17:36:32 UTC, 5 replies.
- Move to Kafka 1.1 from 0.10.2.x ? - posted by Raghav <ra...@gmail.com> on 2018/04/05 18:57:22 UTC, 1 replies.
- Re: Kafka Consumer rebalancing frequently - posted by "Reitzig, Jochen, DSE Extern" <Jo...@bamf.bund.de> on 2018/04/06 07:17:12 UTC, 0 replies.
- Batch.max.rows question - posted by Mike MBS <di...@gmail.com> on 2018/04/06 14:30:01 UTC, 0 replies.
- Kafka-streams: mix Processor API with windowed grouping - posted by Dmitriy Vsekhvalnov <dv...@gmail.com> on 2018/04/06 15:49:55 UTC, 9 replies.
- Re: Kafka Mirrormaker issue - posted by Jeff Field <jv...@blizzard.com> on 2018/04/06 20:09:08 UTC, 3 replies.
- Re: Kafka Streams Internal Topic Retention not applied - posted by Björn Häuser <bj...@gmail.com> on 2018/04/06 21:10:26 UTC, 3 replies.
- Re: kafka in unrecoverable state - posted by SenthilKumar K <se...@gmail.com> on 2018/04/07 13:06:55 UTC, 0 replies.
- Scaling up kafka consumer applications(kafka streams) - posted by Shivam Sharma <28...@gmail.com> on 2018/04/08 18:23:36 UTC, 3 replies.
- join 2 topic streams --> to another topic - posted by adrien ruffie <ad...@hotmail.fr> on 2018/04/08 20:34:56 UTC, 0 replies.
- Re: join 2 topic streams --> to another topic - posted by "Matthias J. Sax" <ma...@confluent.io> on 2018/04/08 21:04:24 UTC, 4 replies.
- one of bootstrap.servers unavailable causes producer error - posted by 许志峰 <zh...@gmail.com> on 2018/04/09 05:33:57 UTC, 0 replies.
- RE: Issue deleting topic on Windows - posted by "Young, Ben" <Be...@fisglobal.com> on 2018/04/09 10:12:43 UTC, 0 replies.
- subscribe kafka user group - posted by "vinly.zhao" <vi...@gmail.com> on 2018/04/09 12:21:35 UTC, 1 replies.
- Re: Apache Kafka / Spark Integration - Exception - The server disconnected before a response was received. - posted by M Singh <ma...@yahoo.com.INVALID> on 2018/04/09 15:47:02 UTC, 2 replies.
- kafka streams consumer ERROR The coordinator is not aware of this member. - posted by 杰 杨 <fu...@live.com> on 2018/04/10 14:34:07 UTC, 0 replies.
- Re: kafka streams consumer ERROR The coordinator is not aware of this member. - posted by Guozhang Wang <wa...@gmail.com> on 2018/04/10 17:39:17 UTC, 0 replies.
- 答复: kafka streams consumer ERROR The coordinator is not aware of this member. - posted by 杰 杨 <fu...@live.com> on 2018/04/11 04:16:28 UTC, 0 replies.
- Kafka Cluster - Partition offset reset to 0. How is this possible? - posted by Yi Yin <yi...@gmail.com> on 2018/04/11 05:30:18 UTC, 0 replies.
- How frequent does the follower replica issue a fetch request to leader replica? - posted by Yu Watanabe <yu...@gmail.com> on 2018/04/11 05:54:07 UTC, 2 replies.
- NotLeaderForPartitionException while restaring kafka brokers - posted by Mihaela Stoycheva <mi...@gmail.com> on 2018/04/12 14:43:33 UTC, 0 replies.
- FetcherLagMetrics is not displaying in JConsole - posted by ishwar panjari <pa...@gmail.com> on 2018/04/12 14:50:09 UTC, 1 replies.
- log retention bytes and log segment bytes - posted by amit mishra <am...@gmail.com> on 2018/04/12 17:10:49 UTC, 2 replies.
- Re: ListOffsets parameters - posted by Andras Beni <an...@cloudera.com> on 2018/04/12 20:19:36 UTC, 1 replies.
- Kafka behaviour on contolled shutdown of brokers - posted by Ashutosh Bharti <as...@hotmail.com> on 2018/04/13 16:31:49 UTC, 1 replies.
- Turning on compaction - can I rolling restart? - posted by "McNealy, Sean" <SE...@ncr.com> on 2018/04/13 19:09:06 UTC, 1 replies.
- Aggregating data when a base is already present - posted by Gaurav Arora <ga...@gmail.com> on 2018/04/16 13:25:12 UTC, 0 replies.
- Partitions Question with java Producer - posted by ESS Gee <ka...@gmail.com> on 2018/04/16 19:31:17 UTC, 1 replies.
- Bug report: Topologies affecting each other through store: Partition XXX is not assigned to any tasks: {} - posted by Erwin Joost BOLWIDT <er...@dbs.com> on 2018/04/17 02:10:03 UTC, 1 replies.
- Retrieving a specific message for re-delivery without moving head using seek() - posted by "M. Manna" <ma...@gmail.com> on 2018/04/17 11:26:20 UTC, 0 replies.
- Kafka using existing certificate authority. - posted by Shawn Raymond <su...@gmail.com> on 2018/04/17 14:25:12 UTC, 1 replies.
- Commit in Kafka streams reduces throughput - posted by Shivam Sharma <28...@gmail.com> on 2018/04/17 15:11:39 UTC, 2 replies.
- Kafka bug ISR expands/shrinks "Count" JMX attribute doesn't work as expected - posted by Stanislav Antic <st...@gmail.com> on 2018/04/17 15:11:52 UTC, 2 replies.
- UnknownProducerIdException in Kafka streams when enabling exactly once - posted by Odin <od...@odinodin.com> on 2018/04/17 17:52:50 UTC, 0 replies.
- Possible to Disable Offset Checkpointing for an In-Memory Global Store? - posted by David Chu <da...@appdynamics.com> on 2018/04/17 21:16:34 UTC, 1 replies.
- Apache Kafka topic security for PLAINTEXT port reg. - posted by Vinay Danda <vi...@gmail.com> on 2018/04/18 15:19:01 UTC, 0 replies.
- Restrict kafka consumers from PLAINTEXT port. - posted by Vinay Kumar <vi...@gmail.com> on 2018/04/18 15:23:23 UTC, 0 replies.
- Default kafka log.dir /tmp | tmp-file-cleaner process - posted by Marc van den Bogaard <ma...@neozo.de> on 2018/04/18 15:43:07 UTC, 3 replies.
- org.apache.kafka.common.errors.UnsupportedVersionException in Java - posted by James Yu <cy...@gmail.com> on 2018/04/18 23:06:22 UTC, 0 replies.
- Kafka stream error about message format - posted by "sy.pan" <sh...@gmail.com> on 2018/04/19 03:05:43 UTC, 1 replies.
- KIP-226 - Dynamic Broker Configuration - posted by Darshan <pu...@gmail.com> on 2018/04/19 05:51:21 UTC, 2 replies.
- Is KTable cleaned up automatically in a Kafka streams application? - posted by Mihaela Stoycheva <mi...@gmail.com> on 2018/04/19 11:41:22 UTC, 4 replies.
- Consuming messages from topics based on keys - posted by JO...@DENSO-DIAM.COM on 2018/04/19 12:06:55 UTC, 1 replies.
- Using Kafka CLI without specifying the URLs every single time? - posted by Horváth Péter Gergely <ho...@gmail.com> on 2018/04/20 10:23:16 UTC, 4 replies.
- Ordering guarantee after branching a stream - posted by "Botuck, Jacob (STL) - contr" <JB...@express-scripts.com> on 2018/04/20 14:31:59 UTC, 1 replies.
- Re: Broker cannot start switch to Java9 - weird file system issue ? - posted by Enrico Olivelli <eo...@gmail.com> on 2018/04/20 15:18:30 UTC, 7 replies.
- Kafka streams state directory - help - posted by pradeep s <sr...@gmail.com> on 2018/04/21 06:34:38 UTC, 2 replies.
- Monitoring Kafka - posted by Raghu Arur <ra...@gmail.com> on 2018/04/21 10:54:35 UTC, 4 replies.
- Kafka rebalancing behavior on broker failures - posted by Raghu Arur <ra...@gmail.com> on 2018/04/22 17:47:12 UTC, 1 replies.
- Keeping track of ingest time of messages in pipeline (cluster 1-> mm -> cluster 2 -> ..) - posted by Uddhav Arote <ar...@gmail.com> on 2018/04/23 05:47:24 UTC, 0 replies.
- Unavailable partitions after upgrade to kafka 1.0.0 - posted by Mika Linnanoja <mi...@rovio.com> on 2018/04/23 06:04:33 UTC, 10 replies.
- UNKNOWN_PRODUCER_ID When using apache kafka streams (scala) - posted by Nitay Kufert <ni...@ironsrc.com> on 2018/04/23 07:19:02 UTC, 0 replies.
- Kafka Log Compaction (LogCleaner) and retry - posted by Rabin Banerjee <de...@gmail.com> on 2018/04/23 08:40:39 UTC, 0 replies.
- having a problem with SSL and kafka - posted by Philip Gerow <Ph...@equifax.com> on 2018/04/23 19:32:55 UTC, 0 replies.
- Topic partitions logSize are way behind the offsets. - posted by Kim Chew <kc...@gmail.com> on 2018/04/24 00:19:12 UTC, 0 replies.
- Re: Keeping track of ingest time of messages in pipeline (cluster 1-> mm -> cluster 2 -> ..) - posted by Uddhav Arote <ar...@gmail.com> on 2018/04/24 02:28:55 UTC, 0 replies.
- Transfer data between kerberized kafka clusters (different principals) - posted by "Zieger, Antoine" <An...@morganstanley.com> on 2018/04/24 17:28:14 UTC, 6 replies.
- ConsumerCoordinator Offset commit failed on partition xxx at offset nnn - posted by "Ramin Farajollah (BLOOMBERG/ 731 LEX)" <rf...@bloomberg.net> on 2018/04/24 22:49:30 UTC, 0 replies.
- How do I specify jdbc connection porperites in kafka-jdbc-connector - posted by Niels Ull Harremoes <ul...@lundogbendsen.dk> on 2018/04/25 16:19:54 UTC, 3 replies.
- KeyValueStore implementation that allows retention policy - posted by Javier Holguera <ja...@zopa.com> on 2018/04/25 17:23:03 UTC, 1 replies.
- Write access required to Confluence wiki - posted by Piyush Vijay <pi...@gmail.com> on 2018/04/25 18:45:34 UTC, 1 replies.
- Monitoring and Alerting - posted by Arunkumar <pm...@yahoo.com.INVALID> on 2018/04/25 22:05:41 UTC, 6 replies.
- Re: Re: kafka steams with TimeWindows ,incorrect result - posted by 杰 杨 <fu...@live.com> on 2018/04/26 11:39:57 UTC, 4 replies.
- kafka error after upgrading to 1.1.0: “the state store…may have migrated to another instance” - posted by "mahendra.b.singh" <ma...@gmail.com> on 2018/04/26 14:27:13 UTC, 3 replies.
- Kafka mirror maker help - posted by saravanan kannappan <sk...@gmail.com> on 2018/04/27 02:17:20 UTC, 5 replies.
- Re: Re: kafka streams with TimeWindows ,incorrect result - posted by Ted Yu <yu...@gmail.com> on 2018/04/27 08:39:24 UTC, 1 replies.
- Kafka Streams 1.1.0 - Significant Performance Drop - posted by Tony John <to...@gmail.com> on 2018/04/27 15:43:50 UTC, 1 replies.
- Kafka-Connect- org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment. - posted by Jagannath Bilgi <js...@yahoo.com.INVALID> on 2018/04/27 20:09:57 UTC, 0 replies.
- source code location for KSQL - posted by Henry Cai <hc...@pinterest.com.INVALID> on 2018/04/27 23:23:06 UTC, 3 replies.
- KStreams API Usage - posted by pradeep s <sr...@gmail.com> on 2018/04/28 02:15:27 UTC, 0 replies.
- No retries when a broker is unavailable - posted by Omer Litov <om...@imperva.com> on 2018/04/29 06:48:11 UTC, 0 replies.
- Workaround for KTable/KTable join followed by groupBy and aggregate/count can result in duplicated results KAFKA-4609? - posted by Artur Mrozowski <ar...@gmail.com> on 2018/04/30 06:19:51 UTC, 1 replies.
- SSL metrics for simple Producer/Consumer implementation - posted by "M. Manna" <ma...@gmail.com> on 2018/04/30 11:28:34 UTC, 0 replies.
- Re: The Problem about Kafka 1.0 - posted by ga...@gmail.com, ga...@gmail.com on 2018/04/30 18:15:14 UTC, 0 replies.
- Fw: Kafka-Connect - Error while creating kafka JDBC Connector with avro data - posted by Jagannath Bilgi <js...@yahoo.com.INVALID> on 2018/04/30 22:21:25 UTC, 0 replies.