strimzi-kafka-oauth
strimzi-kafka-oauth copied to clipboard
strimzi
OAuth2 support for Apache Kafka® to work with many OAuth2 authorization servers
Hello: I am trying to use Keycloak with an on premise Kafka and Spark Streaming with Databricks on Azure. The following code snippet gets the exception copied below. ```scala val...
If a password is not specified for a truststore (or a keystore for that matter), a NullPointerException will occur at io.strimzi.kafka.oauth.common.SSLUtil.createSSLFactory(SSLUtil.java:56). It's common to not password-protect a truststore (as it...
I'm trying to set up oauth for authentication (Azure AD) but use simple authorization. I have the authenitcation/authorisation working. My issues are around linking the simple authorization through KafkaUser crds....
After defining proxy.host and proxy.port into Kafka Producer Config, I'm getting a connection error obtaining JWT token: I didn't find a way to add proxy config into the HttpURLConnection generated...
This issue might live with Quarkus or Graalvm, but I thought I'd start here. I'm using Oauth authentication (kafka-oauth-client 0.7.1) with KafkaStreams on Quarkus (0.13.0) and the io.strimzi.kafka.oauth.client.JaasClientOauthLoginCallbackHandler class for...
Inital login will work as expected ``` 021-09-08 21:18:37,517 DEBUG r-thread-2 s.o.OAuthBearerLoginModule Login succeeded; invoke commit() to commit it; current committed token count=0 2021-09-08 21:18:37,517 TRACE r-thread-2 s.o.OAuthBearerLoginModule Committing my...
Hello everybody, your implementation looks really good. Thanks for that. One question: is there a reason why only the client credential flow is implemented and not the password grant type...
While trying to build latest changes, observing below exception could you have a look. https://www.travis-ci.org/github/nageshlop/strimzi-kafka-oauth/jobs/757055757 LOG: [ERROR] Please refer to /home/travis/build/nageshlop/strimzi-kafka-oauth/testsuite/refresh-token-jwt-keycloak-test/target/surefire-reports for the individual test results. [ERROR] Please refer to...
While using the strimzi oauth on a specific listener of a Kafka broker but due to an invalid certificate, I am getting exceptions like this one: ```shell java.lang.RuntimeException: Failed to...
Hi there! First, thank you for your detailed and documented examples, that helped me a lot to understand the different topics (pun intended). I want to both authenticate my client,...
