Don't use OAuth'd requests if OAuth is disabled (#462)

zalando-nakadi · Jan 29, 2024 · a22668f · a22668f
1 parent d785d72
commit a22668f
Showing 1 changed file with 8 additions and 2 deletions.
diff --git a/.../src/main/java/org/zalando/spring/boot/fahrschein/nakadi/config/CursorManagerFactory.java b/.../src/main/java/org/zalando/spring/boot/fahrschein/nakadi/config/CursorManagerFactory.java
@@ -4,13 +4,19 @@
 import org.zalando.fahrschein.ManagedCursorManager;
 import org.zalando.fahrschein.http.api.RequestFactory;
 import org.zalando.spring.boot.fahrschein.nakadi.config.properties.AbstractConfig;
+import org.zalando.spring.boot.fahrschein.nakadi.config.properties.OAuthConfig;
 
 import java.net.URI;
 
 class CursorManagerFactory {
 
     static CursorManager create(AbstractConfig config, RequestFactory requestFactory) {
-        return new ManagedCursorManager(URI.create(config.getNakadiUrl()), requestFactory,
-                OAuth.buildAccessTokenProvider(config.getOauth()));
+        OAuthConfig oauth = config.getOauth();
+        if (oauth.getEnabled()) {
+            return new ManagedCursorManager(URI.create(config.getNakadiUrl()), requestFactory,
+                    OAuth.buildAccessTokenProvider(oauth));
+        }
+
+        return new ManagedCursorManager(URI.create(config.getNakadiUrl()), requestFactory);
     }
 }