GH-247: Fix java.nio.ReadOnlyBufferException thrown by KclMessageDriv…

…enChannelAdapter in batch mode
spring-projects · Nov 8, 2024 · 0e4d419 · 0e4d419
1 parent 93fb5eb
commit 0e4d419
Show file tree

Hide file tree

Showing 2 changed files with 241 additions and 159 deletions.
diff --git a/...a/org/springframework/integration/aws/inbound/kinesis/KclMessageDrivenChannelAdapter.java b/...a/org/springframework/integration/aws/inbound/kinesis/KclMessageDrivenChannelAdapter.java
@@ -713,7 +713,7 @@ else if (KclMessageDrivenChannelAdapter.this.converter != null) {
 							partitionKeys.add(r.partitionKey());
 							sequenceNumbers.add(r.sequenceNumber());
 
-							return KclMessageDrivenChannelAdapter.this.converter.convert(r.data().array());
+							return KclMessageDrivenChannelAdapter.this.converter.convert(BinaryUtils.copyAllBytesFrom(r.data()));
 						})
 						.toList();