fix

Author: maniskum

streaming-connect-sink/src/test/java/com/adobe/platform/streaming/integration/AEPSinkConnectorErrorReporterTest.java

@@ -153,7 +153,7 @@ public void kafkaErrorReporterMultiMessageWithHeadersTest() throws HttpException
 
     // Check if error record sent to error topic
     ConsumerRecords<byte[], byte[]> consumerRecords = getConnect().kafka()
-            .consume(1, 8000, connectorConfig.get(DEAD_LETTER_TOPIC));
+      .consume(1, 8000, connectorConfig.get(DEAD_LETTER_TOPIC));
 
     Assertions.assertEquals(1, consumerRecords.count());
 
@@ -164,13 +164,13 @@ public void kafkaErrorReporterMultiMessageWithHeadersTest() throws HttpException
 
     final Headers errorHeaders = consumerRecord.headers();
     errorHeaders.headers(ERROR_CLASS_NAME)
-            .forEach(header -> Assertions.assertEquals(EXPECTED_EXCEPTION_CLASS, new String(header.value())));
+      .forEach(header -> Assertions.assertEquals(EXPECTED_EXCEPTION_CLASS, new String(header.value())));
     errorHeaders.headers(ERROR_HEADER_MESSAGE).forEach(header ->
-            Assertions.assertTrue(new String(header.value()).contains(String.valueOf(HTTP_BAD_REQUEST_ERROR_CODE))));
+      Assertions.assertTrue(new String(header.value()).contains(String.valueOf(HTTP_BAD_REQUEST_ERROR_CODE))));
 
     // Verify inlet endpoint received 2 XDM record
     getWiremockServer().verify(postRequestedFor(urlEqualTo(getRelativeUrl()))
-            .withRequestBody(equalToJson(payloadReceivedMultiMessageXdmData(XDM_MULTI_MESSAGE_PAYLOAD_FILE))));
+      .withRequestBody(equalToJson(payloadReceivedMultiMessageXdmData(XDM_MULTI_MESSAGE_PAYLOAD_FILE))));
   }
 
   @Test
@@ -217,8 +217,7 @@ public String payloadReceivedMultiMessageXdmData(String payloadfile) throws Http
     messageNode.set("messages", xdmDataValues);
     return JacksonFactory.OBJECT_MAPPER.writeValueAsString(messageNode);
   }
-
-
+  
   public String payloadReceivedXdmData(String payloadfile) throws HttpException, JsonProcessingException {
     String xdmData = xdmData(payloadfile);
     ObjectNode messageNode = JacksonFactory.OBJECT_MAPPER.createObjectNode();