Kafka checks the validity of SSL certificates keystore or trust store?

2021-08-12 Thread Deepak Jain
Hello, We are using Kafka for data uploading via SSL. While doing the SSL certificate expiry test, we found that Kafka checks the expiry of keystore and does not start when the current date exceed the validity end date of keystore and dump the following exception in server.log

AW: Kafka 2.8.0 "KRaft" - advertised.listeners port mismatch?

2021-08-12 Thread c...@uweeisele.eu
Hello Mike, this is a bug which I also have already noticed. This has already been fixed (https://github.com/apache/kafka/pull/10935) and it will be released with Kafka 3.0.0 (https://issues.apache.org/jira/browse/KAFKA-13003). [https://opengraph.githubassets.com/0ca691b1fbe7df32144cb42a8cca70a8

Kafka Streams leave group behaviour

2021-08-12 Thread c...@uweeisele.eu
Hello all, I have a question about the Group Membership lifecycle of Kafka Streams, or more specific about when Kafka Streams does leave the consumer group (in case of dynamic membership). My expectation was, that a call to the method KafkaStreams.close() also sends a LeaveGroup request to the

RE: [EXTERNAL]Re: KSQLdb Stream, Getting Topic Key

2021-08-12 Thread Greer, Andrew C
This worked for me, thank you for the help! Andrew Greer -Original Message- From: Daniel Hinojosa Sent: Tuesday, August 10, 2021 2:33 PM To: users@kafka.apache.org Subject: [EXTERNAL]Re: KSQLdb Stream, Getting Topic Key CAUTION:This email originated from outside of the organization. Do

Re: Kafka Streams leave group behaviour

2021-08-12 Thread Lerh Chuan Low
I think you may have stumbled upon this: https://issues.apache.org/jira/browse/KAFKA-4881. 1 thing that you could try is using static membership - we have yet to try that though so can't comment yet on how that might work out. On Thu, Aug 12, 2021 at 11:29 PM c...@uweeisele.eu wrote: > Hello all

Re: Kafka Streams leave group behaviour

2021-08-12 Thread Boyang Chen
You are right Uwe, Kafka Streams won't leave group no matter dynamic or static membership. If you want to have fast scale down, consider trying static membership and use the admin command `removeMemberFromGroup` when you need to rescale. Boyang On Thu, Aug 12, 2021 at 4:37 PM Lerh Chuan Low wrot

Re: Kafka 2.8.0 "KRaft" - advertised.listeners port mismatch?

2021-08-12 Thread Mike Pontillo
On Thu, Aug 12, 2021 at 11:44 AM c...@uweeisele.eu wrote: > this is a bug which I also have already noticed. This has already been > fixed (https://github.com/apache/kafka/pull/10935) and it will be > released with Kafka 3.0.0 ( > https://issues.apache.org/jira/browse/KAFKA-13003). Thank you fo