Invalid token error while setting up OAuth2 SASL authentication on Kafka

2024-12-17 Thread Subra I
Hi All, I have the following setup: Kafka broker (3.9.0) Kafka producer (for now, using the producer-console in kafka itself) This setup works fine for basic TCP, TLS and even tried SASL authentication using PLAIN, SHA256. Now, I am trying to setup OAuth2 SASL authentication on this setup and get

KafkaProducer client (Java) does not start (starts when there is a delay though)

2024-12-19 Thread Subra I
Hi All, I already have an app implemented in Java that creates a kafka producer and consumer to connect to kafka. It is working fine. I have even run it with PLAIN and SHA256 authentication. Worked perfectly fine. Now, I have configured it to use oauthbearer. Suddenly , kafka producer does not co

Re: Invalid token error while setting up OAuth2 SASL authentication on Kafka

2024-12-19 Thread Subra I
the long run? We got the JWKS JSON by running a curl command to get the access token and then using this access token to access the JWKS URL. Then saved this output to the json file. On Tue, Dec 17, 2024 at 6:25 PM Subra I wrote: > Hi All, > > I have the following setup: > Kafka b

Kafka Partitions using Helidon framework.

2025-01-21 Thread Subra I
I want to use Helidon SE 4.1.6 and produce the data to a specific partition of Apache Kafka using the producer. Detail : I have gone through the https://helidon.io/docs/latest/se/reactive-messaging#_kafka_connectorpage and written below code which is able to send the data using kafka producer to t

Re: [DISCUSS] Issue with Windows Batch File: "The input line is too long"

2025-01-27 Thread Subra I
I thought this issue has been there for a long time on Windows. I see a similar issue too while starting kafka on Windows if the path is too long. In my setup I have short path names. Ex: D:\kafka\. If I have longer paths like (D:\myuser\project1\kafka), it gives me an error similar to what you m

Support for other OAuth2 grant types in Kafka

2025-02-25 Thread Subra I
Hello All, I see that Kafka by itself supports client credentials as grant type for OAuth2. I see this mentioned in one of the kafka KIP as well: https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=186877575 Is there a way to support other grant types as well? I came across the follo

Re: Support for other OAuth2 grant types in Kafka

2025-02-27 Thread Subra I
True wrote: > Hi Subra, > > I'm one of the authors of the OAuth support in Kafka. Answers to your > questions are below... > > On Tue, Feb 25, 2025, at 3:05 AM, Subra I wrote: > > Hello All, > > > > I see that Kafka by itself supports client credentials

Kafka setup with OAuth2 for client-broker and PLAINTEXT for inter-broker

2025-05-16 Thread Subra I
Hi All, I am trying to have a kafka configuration where we use *OAuth2 for client broker communication and PLAINTEXT for inter broker communication. Kafa broker should not need to talk to the OAuth server. * THis is what the configuration looks like: advertised.listeners is set to SASL_PLAINTEXT