Fixed Encrypted tests

Signed-off-by: Jeffrey Aaron Jeyasingh <jeffreyaaron06@gmail.com>

Author: jeffreyAaron

data-prepper-plugins/kafka-plugins/src/integrationTest/java/org/opensearch/dataprepper/plugins/kafka/buffer/KafkaBufferIT.java

@@ -448,6 +448,31 @@ class Encrypted {
 
         @BeforeEach
         void setUp() throws NoSuchAlgorithmException, InvalidKeyException, NoSuchPaddingException {
+            random = new Random();
+            acknowledgementSetManager = mock(AcknowledgementSetManager.class);
+            acknowledgementSet = mock(AcknowledgementSet.class);
+            lenient().doAnswer((a) -> null).when(acknowledgementSet).complete();
+            lenient().when(acknowledgementSetManager.create(any(), any(Duration.class))).thenReturn(acknowledgementSet);
+            objectMapper = new ObjectMapper().registerModule(new JavaTimeModule());
+
+            when(pluginSetting.getPipelineName()).thenReturn(UUID.randomUUID().toString());
+
+            topicName = "buffer-" + RandomStringUtils.randomAlphabetic(5);
+
+            Map<String, Object> topicConfigMap = new java.util.HashMap<>(Map.of(
+                    "name", topicName,
+                    "group_id", "buffergroup-" + RandomStringUtils.randomAlphabetic(6),
+                    "create_topic", true
+            ));
+
+            topicConfig = objectMapper.convertValue(topicConfigMap, BufferTopicConfig.class);
+
+            final Map<String, Object> bufferConfigMap = new java.util.HashMap<>(Map.of(
+                    "topics", List.of(topicConfigMap),
+                    "bootstrap_servers", List.of(bootstrapServersCommaDelimited),
+                    "encryption", Map.of("type", "none")
+            ));
+
             final KeyGenerator aesKeyGenerator = KeyGenerator.getInstance("AES");
             aesKeyGenerator.init(256);
             final SecretKey secretKey = aesKeyGenerator.generateKey();
@@ -459,11 +484,11 @@ void setUp() throws NoSuchAlgorithmException, InvalidKeyException, NoSuchPadding
             final byte[] base64Bytes = Base64.getEncoder().encode(secretKey.getEncoded());
             aesKey = new String(base64Bytes);
 
-            final Map<String, Object> topicConfigMap = objectMapper.convertValue(topicConfig, Map.class);
             topicConfigMap.put("encryption_key", aesKey);
-            final Map<String, Object> bufferConfigMap = objectMapper.convertValue(kafkaBufferConfig, Map.class);
             bufferConfigMap.put("topics", List.of(topicConfigMap));
             kafkaBufferConfig = objectMapper.convertValue(bufferConfigMap, KafkaBufferConfig.class);
+
+            byteDecoder = null;
         }
 
         @Test