From 64445fac5c42a801bf62b94e0a002353c4065972 Mon Sep 17 00:00:00 2001
From: Qi Chen <qchea@amazon.com>
Date: Fri, 19 Apr 2024 09:28:20 -0500
Subject: [PATCH] MAINT: allow either plain or plaintext under SASL (#4433)

Signed-off-by: George Chen <qchea@amazon.com>
---
 .../dataprepper/plugins/kafka/configuration/AuthConfig.java     | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/data-prepper-plugins/kafka-plugins/src/main/java/org/opensearch/dataprepper/plugins/kafka/configuration/AuthConfig.java b/data-prepper-plugins/kafka-plugins/src/main/java/org/opensearch/dataprepper/plugins/kafka/configuration/AuthConfig.java
index fc469950de..9f04b42b3e 100644
--- a/data-prepper-plugins/kafka-plugins/src/main/java/org/opensearch/dataprepper/plugins/kafka/configuration/AuthConfig.java
+++ b/data-prepper-plugins/kafka-plugins/src/main/java/org/opensearch/dataprepper/plugins/kafka/configuration/AuthConfig.java
@@ -5,6 +5,7 @@
 
 package org.opensearch.dataprepper.plugins.kafka.configuration;
 
+import com.fasterxml.jackson.annotation.JsonAlias;
 import com.fasterxml.jackson.annotation.JsonProperty;
 import jakarta.validation.Valid;
 import jakarta.validation.constraints.AssertTrue;
@@ -18,6 +19,7 @@
 public class AuthConfig {
 
     public static class SaslAuthConfig {
+        @JsonAlias("plain")
         @JsonProperty("plaintext")
         private PlainTextAuthConfig plainTextAuthConfig;