diff --git a/dagger-core/src/main/java/com/gotocompany/dagger/core/utils/Constants.java b/dagger-core/src/main/java/com/gotocompany/dagger/core/utils/Constants.java
index 78fdbe707..c2cd4dbce 100644
--- a/dagger-core/src/main/java/com/gotocompany/dagger/core/utils/Constants.java
+++ b/dagger-core/src/main/java/com/gotocompany/dagger/core/utils/Constants.java
@@ -188,7 +188,7 @@ public enum ExternalPostProcessorVariableType { REQUEST_VARIABLES, HEADER_VARIAB
     public static final String SINK_ERROR_TYPES_FOR_FAILURE_DEFAULT = "";
 
     public static final String[] SUPPORTED_SOURCE_KAFKA_CONSUMER_CONFIG_SECURITY_PROTOCOL = {"SASL_PLAINTEXT", "SASL_SSL", "SSL"};
-    public static final String[] SUPPORTED_SOURCE_KAFKA_CONSUMER_CONFIG_SASL_MECHANISM = {"PLAIN", "SCRAM-SHA-256", "SCRAM-SHA-512"};
+    public static final String[] SUPPORTED_SOURCE_KAFKA_CONSUMER_CONFIG_SASL_MECHANISM = {"PLAIN", "SCRAM-SHA-256", "SCRAM-SHA-512", "OAUTHBEARER"};
 
     public static final String[] SUPPORTED_SOURCE_KAFKA_CONSUMER_CONFIG_SSL_PROTOCOL = {"TLS", "TLSv1.1", "TLSv1.2", "TLSv1.3", "SSL", "SSLv2", "SSLv3"};
     public static final String[] SUPPORTED_SOURCE_KAFKA_CONSUMER_CONFIG_SSL_STORE_FILE_TYPE = {"JKS", "PKCS12", "PEM"};
diff --git a/dagger-core/src/test/java/com/gotocompany/dagger/core/source/config/adapter/DaggerSASLMechanismAdaptorTest.java b/dagger-core/src/test/java/com/gotocompany/dagger/core/source/config/adapter/DaggerSASLMechanismAdaptorTest.java
index 37288849b..32f330f82 100644
--- a/dagger-core/src/test/java/com/gotocompany/dagger/core/source/config/adapter/DaggerSASLMechanismAdaptorTest.java
+++ b/dagger-core/src/test/java/com/gotocompany/dagger/core/source/config/adapter/DaggerSASLMechanismAdaptorTest.java
@@ -28,6 +28,14 @@ public void shouldAcceptConfiguredValue() throws IOException {
         assertEquals("SCRAM-SHA-512", saslMechanism);
     }
 
+    @Test
+    public void shouldAcceptOauthbearer() throws IOException {
+        when(jsonReader.nextString()).thenReturn("OAUTHBEARER");
+        DaggerSASLMechanismAdaptor daggerSASLMechanismAdaptor = new DaggerSASLMechanismAdaptor();
+        String saslMechanism = daggerSASLMechanismAdaptor.read(jsonReader);
+        assertEquals("OAUTHBEARER", saslMechanism);
+    }
+
     @Test
     public void shouldNotAcceptConfiguredValue() throws IOException {
         when(jsonReader.nextString()).thenReturn("SCRAMSHA512");