feat : fixes issue with parsing data received

rajadilipkolli · Mar 18, 2024 · d11aee2 · d11aee2
1 parent 4db9b0a
commit d11aee2
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 5 deletions.
diff --git a/aws-kinesis-project/consumer/src/main/java/com/learning/aws/spring/consumer/IpConsumer.java b/aws-kinesis-project/consumer/src/main/java/com/learning/aws/spring/consumer/IpConsumer.java
@@ -41,14 +41,15 @@ public Consumer<Flux<List<Record>>> consumeEvent() {
                                             kinessRecord.partitionKey(),
                                             kinessRecord.approximateArrivalTimestamp());
 
-                                    String utf8String = kinessRecord.data().asUtf8String();
-                                    String substring =
-                                            utf8String.substring(utf8String.indexOf("[{"));
+                                    String recordString =
+                                            new String(kinessRecord.data().asByteArray());
+                                    String payload =
+                                            recordString.substring(recordString.indexOf("[{"));
                                     List<IpAddressDTO> ipAddressDTOS;
                                     try {
                                         ipAddressDTOS =
                                                 objectMapper.readValue(
-                                                        substring, new TypeReference<>() {});
+                                                        payload, new TypeReference<>() {});
                                     } catch (JsonProcessingException e) {
                                         throw new RuntimeException(e);
                                     }

diff --git a/aws-kinesis-project/consumer/src/test/resources/application-test.properties b/aws-kinesis-project/consumer/src/test/resources/application-test.properties
@@ -5,5 +5,6 @@ spring.cloud.function.definition=producerSupplier;consumeEvent
 spring.cloud.stream.bindings.producerSupplier-out-0.destination=my-test-stream
 
 spring.cloud.stream.kinesis.binder.autoAddShards=true
-spring.cloud.stream.kinesis.binder.auto-create-stream=true
+spring.cloud.stream.kinesis.binder.auto-create-stream=false
 
+spring.testcontainers.beans.startup=parallel