Re: Kafka 2.0: High level consumer is slow to deal with SSL certification expiration

2019-03-10 Thread Henry Cai
I looked the latest code (Kafka 2.2.0) code in NetworkClient.java, I don't see any changes in the related code, I believe the problem also existed there. Created this JIRA to track the issue: https://issues.apache.org/jira/browse/KAFKA-8089 On Thu, Mar 7, 2019 at 11:39 PM Ismael Juma wrote: > H

Re: Kafka 2.0: High level consumer is slow to deal with SSL certification expiration

2019-03-07 Thread Ismael Juma
Hi, It would be great to verify that this happens with Kafka 2.2.0 RC1. If it does, then please file a JIRA so that this doesn't get lost. Ismael On Thu, Mar 7, 2019 at 4:19 PM Henry Cai wrote: > Hi, > > We have been using Kafka 2.0's mirror maker (which used High level > consumer) to do repli

Kafka 2.0: High level consumer is slow to deal with SSL certification expiration

2019-03-07 Thread Henry Cai
Hi, We have been using Kafka 2.0's mirror maker (which used High level consumer) to do replication. The topic is SSL enabled and the certificate will expire at a random time within 12 hours. When the certificate expired we will see many SSL related exception in the log [2019-03-07 18:02:54,128]