[camel] branch main updated: CAMEL-17994 Camel-aws2-kinesis: Integration test does not work - KinesisComponentManualIT (#7591)

[davsclaus]

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/main by this push:
     new 5cde4a1cb11 CAMEL-17994 Camel-aws2-kinesis: Integration test does not 
work - KinesisComponentManualIT (#7591)
5cde4a1cb11 is described below

commit 5cde4a1cb11abef55522a9017d064bc397b71aa1
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Wed May 11 14:35:36 2022 +0200

    CAMEL-17994 Camel-aws2-kinesis: Integration test does not work - 
KinesisComponentManualIT (#7591)
---
 .../component/aws2/kinesis/integration/KinesisComponentManualIT.java   | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/integration/KinesisComponentManualIT.java
 
b/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/integration/KinesisComponentManualIT.java
index 048f79b7270..f41756854d9 100644
--- 
a/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/integration/KinesisComponentManualIT.java
+++ 
b/components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/integration/KinesisComponentManualIT.java
@@ -29,7 +29,6 @@ import org.apache.camel.test.junit5.CamelTestSupport;
 import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import software.amazon.awssdk.services.kinesis.KinesisClient;
-import software.amazon.awssdk.services.kinesis.model.Record;
 
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertNotNull;
@@ -71,7 +70,7 @@ public class KinesisComponentManualIT extends 
CamelTestSupport {
     }
 
     private void assertResultExchange(Exchange resultExchange, String data, 
String partition) {
-        assertEquals(data,resultExchange.getIn().getBody(String.class));
+        assertEquals(data, resultExchange.getIn().getBody(String.class));
         assertEquals(partition, 
resultExchange.getIn().getHeader(Kinesis2Constants.PARTITION_KEY));
         
assertNotNull(resultExchange.getIn().getHeader(Kinesis2Constants.APPROX_ARRIVAL_TIME));
         
assertNotNull(resultExchange.getIn().getHeader(Kinesis2Constants.SEQUENCE_NUMBER));