[CAMEL-17994] Camel-aws2-kinesis: Integration test does not work - KinesisComponentManualIT

• Type: Test
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 3.17.0
• Component/s: camel-aws2, tests
• Estimated Complexity: Unknown
• Assignee: Jiri Ondrusek
• Reporter: Jiri Ondrusek
• Created: 20/Apr/22 13:29
• Updated: 11/May/22 13:10
• Resolved: 11/May/22 13:10

Description

There is a code in the test 

Record record = resultExchange.getIn().getBody(Record.class); assertEquals(data, new String(record.data().asByteArray()));

Body of the exchange is already converted in to InputStream in Kinesis2Consumer class.

Working code should be:

assertEquals(data,resultExchange.getIn().getBody(String.class));

 

Issue Links

• links to: GitHub Pull Request #7591