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
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
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
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
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
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
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
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