kafka-users mailing list archives: February 2017

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · 6 · 7 · Next »Thread · Author · Date
+8618611626818 Re: log.flush.interval.messages setting of Kafka 0.9.0.0 Sun, 18 Dec, 03:06
陈江枫 Schema registry Wed, 15 Feb, 09:48
陈江枫 Re: How to choose one broker as Group Coordinator Wed, 15 Feb, 10:01
이산하 How to change the logging level or logging place of KafkaServerStable? Thu, 23 Feb, 08:20
Nicolas Fouché Wait a few seconds before initializing state stores, so others don't have to wait before joining. Tue, 28 Feb, 17:10
Nicolas Fouché Re: Wait a few seconds before initializing state stores, so others don't have to wait before joining. Tue, 28 Feb, 17:34
Stevo Slavić Re: Fault tolerance not working in Kafka Mon, 06 Feb, 06:38
Stevo Slavić Re: Is there any command can be used to get broker.id on one of broker with command? Thu, 16 Feb, 07:02
Stevo Slavić zookeeper.set.acl=false not considered by ZookeeperLeaderElector Mon, 27 Feb, 15:03
Stevo Slavić Re: zookeeper.set.acl=false not considered by ZookeeperLeaderElector Tue, 28 Feb, 17:02
飘落 Messages not received (C/C++ client) Fri, 10 Feb, 09:50
宋鑫/NemoVisky Re: Getting NotLeaderForPartitionException in kafka broker Sun, 26 Feb, 04:23
Henning Røigaard-Petersen Purpose of the metadata field of Offset Commit and Fetch Tue, 14 Feb, 09:12
Isabelle Giguère ConsumerInterceptor in Tomcat app Thu, 09 Feb, 17:27
Алексей Федосов log.retention.hours Mon, 06 Feb, 06:46
揣立武 Kafka exception Thu, 16 Feb, 06:29
Henning Røigaard-Petersen RE: How to choose one broker as Group Coordinator Wed, 15 Feb, 14:59
Adam Warski Kafka streams: Getting a state store associated to a processor Mon, 13 Feb, 18:59
Adam Warski Re: Kafka streams: Getting a state store associated to a processor Mon, 13 Feb, 19:50
Adam Warski Re: Kafka streams: Getting a state store associated to a processor Mon, 13 Feb, 19:57
Adam Warski Re: Kafka streams: Getting a state store associated to a processor Mon, 13 Feb, 20:27
Adam Warski Re: Kafka streams: Getting a state store associated to a processor Tue, 14 Feb, 08:57
Adrian McCague ProcessorContext commit question Thu, 09 Feb, 16:06
Adrian McCague RE: ProcessorContext commit question Thu, 09 Feb, 16:22
Akhilesh Pathodia Re: log.retention.hours Mon, 06 Feb, 18:44
Anahita Talebi Re: No main class set in JAR; please specify one with --class and java.lang.ClassNotFoundException Sat, 25 Feb, 21:48
Anahita Talebi Re: No main class set in JAR; please specify one with --class and java.lang.ClassNotFoundException Sat, 25 Feb, 22:27
Andrew Otto Re: Is there any command can be used to get broker.id on one of broker with command? Thu, 16 Feb, 19:16
Anjani Gupta Closing socket connection to /127.0.0.1. (kafka.network.Processor) Wed, 01 Feb, 00:09
Antony Vo Scaling To Many Kafka Consumers For Particular Topic Wed, 22 Feb, 17:17
Anup.Ban...@cognizant.com Kafka to connect to Azure Data Lake Mon, 20 Feb, 15:39
Apurva Mehta Re: [DISCUSS] KIP-118: Drop Support for Java 7 in Kafka 0.11 Fri, 03 Feb, 22:05
Ara Ebrahimi kafka-streams ktable recovery after rebalance crash Wed, 01 Feb, 20:08
Ara Ebrahimi kafka-consumer-offset-checker complaining about NoNode for X in zk Wed, 01 Feb, 20:14
Ara Ebrahimi Re: kafka-consumer-offset-checker complaining about NoNode for X in zk Thu, 02 Feb, 22:13
Ara Ebrahimi KTable TTL Mon, 13 Feb, 16:57
Ara Ebrahimi kafka streams locking issue in 0.10.20.0 Thu, 23 Feb, 18:25
Ara Ebrahimi Re: kafka streams locking issue in 0.10.20.0 Sat, 25 Feb, 19:20
Ashish Bhushan Re: Kerberos/SASL Enabled Kafka - broker fails NoAuth due ACL Wed, 08 Feb, 18:18
Ashish Bhushan Re: Kerberos/SASL Enabled Kafka - broker fails NoAuth due ACL Thu, 09 Feb, 07:43
Ashish Bhushan Re: Kerberos/SASL Enabled Kafka - broker fails NoAuth due ACL Thu, 09 Feb, 08:42
Becket Qin Re: [ANNOUNCE] Apache Kafka 0.10.2.0 Released Wed, 22 Feb, 17:02
Ben Stopford Re: KIP-122: Add a tool to Reset Consumer Group Offsets Wed, 08 Feb, 21:43
Bhavi C Re: Kafka offset being reset Tue, 28 Feb, 04:17
BigData dev Reg: Kafka Kerberos Wed, 08 Feb, 00:25
BigData dev Reg: Kafka HDFS Connector with (HDFS SSL enabled) Wed, 15 Feb, 19:03
Christian Kafka SASL and custom LoginModule and Authorizer Sun, 26 Feb, 02:48
Christian Re: Kafka SASL and custom LoginModule and Authorizer Sun, 26 Feb, 22:59
Christopher Shannon Passing SSL client principal to custom JAAS module with SSL or SASL_SSL Fri, 10 Feb, 17:46
Christopher Shannon Re: Passing SSL client principal to custom JAAS module with SSL or SASL_SSL Mon, 13 Feb, 13:17
Christopher Shannon Re: Passing SSL client principal to custom JAAS module with SSL or SASL_SSL Mon, 13 Feb, 13:40
Colin McCabe Re: KIP-119: Drop Support for Scala 2.10 in Kafka 0.11 Mon, 06 Feb, 18:59
Colin McCabe Re: log.flush.interval.messages setting of Kafka 0.9.0.0 Fri, 17 Feb, 17:52
Colin McCabe Re: Reg: Kafka HDFS Connector with (HDFS SSL enabled) Fri, 17 Feb, 21:47
Colin McCabe Re: Kafka exception Fri, 17 Feb, 22:10
Collin Lee Surveying for Applications of Kafka Fri, 03 Feb, 00:55
Damian Guy Re: Kafka docs for current trunk Wed, 01 Feb, 09:30
Damian Guy Re: Kafka Streams punctuate with slow-changing KTables Thu, 02 Feb, 09:46
Damian Guy Re: Streams InvalidStateStoreException: Store ... is currently closed Thu, 02 Feb, 16:27
Damian Guy Re: Does KafkaStreams be configured to use multiple broker clusters in the same topology Thu, 02 Feb, 17:10
Damian Guy Re: Does KafkaStreams be configured to use multiple broker clusters in the same topology Thu, 02 Feb, 17:35
Damian Guy Re: Does KafkaStreams be configured to use multiple broker clusters in the same topology Thu, 02 Feb, 18:02
Damian Guy Re: Running cluster of stream processing application Fri, 03 Feb, 09:56
Damian Guy Re: At Least Once semantics for Kafka Streams Fri, 03 Feb, 09:59
Damian Guy Re: [DISCUSS] KIP-118: Drop Support for Java 7 in Kafka 0.11 Fri, 03 Feb, 14:49
Damian Guy Re: At Least Once semantics for Kafka Streams Fri, 03 Feb, 14:54
Damian Guy Re: Potential memory leak in rocksdb Sat, 04 Feb, 16:31
Damian Guy Re: Potential memory leak in rocksdb Sat, 04 Feb, 18:59
Damian Guy Re: Potential memory leak in rocksdb Sat, 04 Feb, 19:54
Damian Guy Re: Need help in understanding bunch of rocksdb errors on kafka_2.10-0.10.1.1 Mon, 06 Feb, 10:28
Damian Guy Re: [DISCUSS] KIP-120: Cleanup Kafka Streams builder API Mon, 06 Feb, 16:07
Damian Guy Re: Need help in understanding bunch of rocksdb errors on kafka_2.10-0.10.1.1 Mon, 06 Feb, 16:40
Damian Guy Re: KIP-121 [Discuss]: Add KStream peek method Tue, 07 Feb, 09:37
Damian Guy Re: Need help in understanding bunch of rocksdb errors on kafka_2.10-0.10.1.1 Tue, 07 Feb, 09:51
Damian Guy Re: Need help in understanding bunch of rocksdb errors on kafka_2.10-0.10.1.1 Thu, 09 Feb, 06:25
Damian Guy Re: Getting CommitFailedException in 0.10.2.0 due to member id is not valid or unknown Thu, 09 Feb, 08:02
Damian Guy Re: Getting CommitFailedException in 0.10.2.0 due to member id is not valid or unknown Thu, 09 Feb, 08:44
Damian Guy Re: Getting CommitFailedException in 0.10.2.0 due to member id is not valid or unknown Fri, 10 Feb, 10:12
Damian Guy Re: Getting CommitFailedException in 0.10.2.0 due to member id is not valid or unknown Fri, 10 Feb, 12:31
Damian Guy Re: [DISCUSS] KIP-120: Cleanup Kafka Streams builder API Tue, 14 Feb, 16:37
Damian Guy Re: RocksDB error when running Kafka with a larger data set Wed, 15 Feb, 14:56
Damian Guy Re: [KIP-94] SessionWindows - IndexOutOfBoundsException in simple use case Wed, 22 Feb, 09:54
Damian Guy Re: kafka streams locking issue in 0.10.20.0 Fri, 24 Feb, 11:15
Damian Guy Re: Kafka Streams vs Spark Streaming Tue, 28 Feb, 14:40
Dan Ofir Lock Exception - Failed to lock the state directory Sun, 26 Feb, 13:37
David Garcia Re: How to measure the load capacity of kafka cluster Thu, 09 Feb, 15:41
Deepak Pengoria System went OutOfMemory when running Kafka-Streaming Fri, 17 Feb, 13:30
Dmitry Minkovsky Kafka Streams: Is automatic repartitioning before joins public/stable API? Wed, 08 Feb, 03:06
Dmitry Minkovsky Re: Kafka Streams: Is automatic repartitioning before joins public/stable API? Wed, 08 Feb, 18:04
Dmitry Minkovsky Kafka Streams: How to best maintain changelog indices using the DSL? Wed, 08 Feb, 18:22
Dmitry Minkovsky Re: Shutting down a Streams job Wed, 08 Feb, 20:34
Dmitry Minkovsky Re: Kafka Streams: How to best maintain changelog indices using the DSL? Wed, 08 Feb, 21:14
Dmitry Minkovsky Re: Kafka Streams: How to best maintain changelog indices using the DSL? Thu, 09 Feb, 02:07
Dmitry Minkovsky Re: Shutting down a Streams job Thu, 09 Feb, 16:54
Dmitry Minkovsky KTable send old values API Tue, 21 Feb, 22:01
Dmitry Minkovsky Re: KTable send old values API Tue, 21 Feb, 23:39
Dmitry Minkovsky Re: KTable send old values API Wed, 22 Feb, 17:14
Dong Lin Re: [DISCUSS] KIP-118: Drop Support for Java 7 in Kafka 0.11 Fri, 03 Feb, 22:11
Dong Lin Re: KIP-122: Add a tool to Reset Consumer Group Offsets Wed, 08 Feb, 03:04
Ed Yakabosky Next week: Streams Processing meetup with speakers from LinkedIn, Uber, and Optimizely Mon, 06 Feb, 19:49
Message list1 · 2 · 3 · 4 · 5 · 6 · 7 · Next »Thread · Author · Date
Box list
Oct 2018148
Sep 2018275
Aug 2018347
Jul 2018380
Jun 2018302
May 2018271
Apr 2018251
Mar 2018370
Feb 2018389
Jan 2018372
Dec 2017349
Nov 2017446
Oct 2017406
Sep 2017371
Aug 2017409
Jul 2017526
Jun 2017550
May 2017576
Apr 2017413
Mar 2017659
Feb 2017641
Jan 2017524
Dec 2016703
Nov 2016614
Oct 2016649
Sep 2016468
Aug 2016536
Jul 2016580
Jun 2016718
May 2016668
Apr 2016553
Mar 2016695
Feb 2016532
Jan 2016527
Dec 2015355
Nov 2015488
Oct 2015353
Sep 2015367
Aug 2015494
Jul 2015456
Jun 2015429
May 2015437
Apr 2015446
Mar 2015782
Feb 2015764
Jan 2015666
Dec 2014460
Nov 2014557
Oct 2014561
Sep 2014381
Aug 2014434
Jul 2014426
Jun 2014561
May 2014424
Apr 2014388
Mar 2014452
Feb 2014474
Jan 2014538
Dec 2013459
Nov 2013456
Oct 2013562
Sep 2013278
Aug 2013672
Jul 2013418
Jun 2013445
May 2013421
Apr 2013391
Mar 2013361
Feb 2013170
Jan 2013245
Dec 2012240
Nov 2012338
Oct 2012234
Sep 2012126
Aug 2012164
Jul 2012155
Jun 2012251
May 2012261
Apr 2012151
Mar 2012110
Feb 2012109
Jan 2012124
Dec 2011162
Nov 2011212
Oct 2011225
Sep 201169
Aug 201165
Jul 201140