Kafka CPU spikes every 5 minutes

2020-04-08 Thread Jacek Szewczyk
Hi All, I am seeing strange behavior for Kafka 2.0.0.3.1.4. My cluster contains 9 brokers + 3 dedicated zookeepers and for unknown reason there is spike in CPU every 5 minutes which cause timeouts between producers, consumers and brokers. Basically every 5 minutes CPU spikes to 90+ % and at th

Re: Oauthbearer - Azure

2020-04-08 Thread Marko Strukelj
Hello, you could give Strimzi Kafka OAuth [1] a try. It's a Kafka add-on that plugs into SASL_OAUTHBEARER functionality. On the server side it adds support for fast local JWT token validation using signature checks, and keys retrieved from your authorization server's JWKS endpoint. It also has

Re: [VOTE] 2.5.0 RC3

2020-04-08 Thread David Arthur
Passing Jenkins build on 2.5 branch: https://builds.apache.org/job/kafka-2.5-jdk8/90/ On Wed, Apr 8, 2020 at 12:03 AM David Arthur wrote: > Hello Kafka users, developers and client-developers, > > This is the forth candidate for release of Apache Kafka 2.5.0. > > * TLS 1.3 support (1.2 is now th

Re: How to set custom properties and message expiration for Kafka topic message.

2020-04-08 Thread Naveen Kumar M
Hello Team, Could you please help me on this? Thanks and regards, Naveen On Tue, Apr 7, 2020, 2:27 PM Naveen Kumar M wrote: > Hello Friends, > > Hope you are all doing good! > > I am bit new to Kafka messaging system. > > We are using Kafka as messaging broker. > > Could someone let me know ho

Re: Oauthbearer - Azure

2020-04-08 Thread Marko Strukelj
Hello, you can give Strimzi Kafka OAuth [1] a try. It is an add-on for Kafka that plugs into the existing SASL_OAUTHBEARER authentication mechanism, providing fast JWT signature validation using your authorization server's JWKS endpoint, and the OAuth2 introspection endpoint based approach wher

Re: Oauthbearer - Azure

2020-04-08 Thread Antony Alphonse
Thanks Marko. If we have other options I would like to explore them as well. On Wed, Apr 8, 2020 at 9:14 AM Marko Strukelj wrote: > Hello, you can give Strimzi Kafka OAuth [1] a try. > > It is an add-on for Kafka that plugs into the existing SASL_OAUTHBEARER > authentication mechanism, providing