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

[da...@apache.org]

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 7d24ce778a2 CAMEL-17994 Camel-aws2-kinesis: Integration test does not work - KinesisComponentManualIT (#7591)
7d24ce778a2 is described below

commit 7d24ce778a235927133bafba6b9bcf6e8b093347
Author: JiriOndrusek <on...@gmail.com>
AuthorDate: Wed May 11 14:35:02 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 bb009f6dc59..048f79b7270 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
@@ -71,8 +71,7 @@ public class KinesisComponentManualIT extends CamelTestSupport {
     }
 
     private void assertResultExchange(Exchange resultExchange, String data, String partition) {
-        Record record = resultExchange.getIn().getBody(Record.class);
-        assertEquals(data, new String(record.data().asByteArray()));
+        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));