Topic Messages: addy_system-customer-dlt

Partition: 0   Offset: 0   Key: empty   Timestamp: 2025-12-15 18:17:16.566 Headers: __TypeId__: addy.salepro.dao.model.EventModel, kafka_dlt-exception-cause-fqcn: com.google.gson.JsonSyntaxException, kafka_dlt-exception-fqcn: org.springframework.kafka.listener.ListenerExecutionFailedException, kafka_dlt-exception-message: Listener method 'public void addy.salepro.scheduler.customer.CustomerEventConsumer.consumeCustomerEvent(addy.salepro.dao.model.EventModel)' threw exception; java.lang.IllegalStateException: Expected BEGIN_ARRAY but was BEGIN_OBJECT at line 1 column 2 path $ See https://github.com/google/gson/blob/main/Troubleshooting.md#unexpected-json-structure, kafka_dlt-exception-stacktrace: org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public void addy.salepro.scheduler.customer.CustomerEventConsumer.consumeCustomerEvent(addy.salepro.dao.model.EventModel)' threw exception at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.decorateException(KafkaMessageListenerContainer.java:2994) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2901) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2865) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2777) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2614) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2503) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:2152) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1528) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1466) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1335) at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) at java.base/java.lang.Thread.run(Thread.java:1583) Suppressed: org.springframework.kafka.listener.ListenerExecutionFailedException: Restored Stack Trace at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:490) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invoke(MessagingMessageListenerAdapter.java:421) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:85) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:50) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2887) Caused by: com.google.gson.JsonSyntaxException: java.lang.IllegalStateException: Expected BEGIN_ARRAY but was BEGIN_OBJECT at line 1 column 2 path $ See https://github.com/google/gson/blob/main/Troubleshooting.md#unexpected-json-structure at com.google.gson.Gson.fromJson(Gson.java:1382) at com.google.gson.Gson.fromJson(Gson.java:1260) at com.google.gson.Gson.fromJson(Gson.java:1170) at com.google.gson.Gson.fromJson(Gson.java:1136) at addy.salepro.scheduler.customer.CustomerEventConsumer.handleCustomerActivated(CustomerEventConsumer.java:146) at addy.salepro.scheduler.customer.CustomerEventConsumer.consumeCustomerEvent(CustomerEventConsumer.java:66) at java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:103) at java.base/java.lang.reflect.Method.invoke(Method.java:580) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:169) at org.springframework.kafka.listener.adapter.KotlinAwareInvocableHandlerMethod.doInvoke(KotlinAwareInvocableHandlerMethod.java:45) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:119) at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:78) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:475) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invoke(MessagingMessageListenerAdapter.java:421) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:85) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:50) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2887) ... 10 more Caused by: java.lang.IllegalStateException: Expected BEGIN_ARRAY but was BEGIN_OBJECT at line 1 column 2 path $ See https://github.com/google/gson/blob/main/Troubleshooting.md#unexpected-json-structure at com.google.gson.stream.JsonReader.unexpectedTokenError(JsonReader.java:1831) at com.google.gson.stream.JsonReader.beginArray(JsonReader.java:470) at com.google.gson.internal.bind.CollectionTypeAdapterFactory$Adapter.read(CollectionTypeAdapterFactory.java:82) at com.google.gson.internal.bind.CollectionTypeAdapterFactory$Adapter.read(CollectionTypeAdapterFactory.java:64) at com.google.gson.Gson.fromJson(Gson.java:1359) ... 26 more , kafka_dlt-original-consumer-group: customer-group, kafka_dlt-original-offset: , kafka_dlt-original-partition: , kafka_dlt-original-timestamp: �!�_, kafka_dlt-original-timestamp-type: CreateTime, kafka_dlt-original-topic: addy_system-customer
 
{"id":"700467af-81ad-4a9e-b9cc-f9fc7f454ed1","subjectId":"56090355-320f-45cf-9bc4-6272778d6f0b","eventType":"CUSTOMER_REGISTERED","body":"{\n  \"createdDate\": \"2025-12-15T18:16:51.970519947\",\n  \"currentPoint\": 0.0,\n  \"modifiedDate\": \"2025-12-15T18:16:51.970162659\",\n  \"validSecretCode\": false,\n  \"status\": \"ACTIVE\",\n  \"customerType\": \"REGULAR\",\n  \"username\": \"0389765234\",\n  \"memberCode\": \"0389765234\",\n  \"totalSpend\": 0,\n  \"totalDebt\": 0,\n  \"totalOrder\": 0,\n  \"totalPoint\": 0.0,\n  \"deleteImageIds\": [],\n  \"leadSource\": \"REFERRAL\",\n  \"id\": \"56090355-320f-45cf-9bc4-6272778d6f0b\",\n  \"fullName\": \"KH_1512\",\n  \"phoneNumber\": \"0389765234\",\n  \"gender\": \"OTHER\"\n}","message":null,"author":null,"status":"PROCESSING","createdDate":[2025,12,15,18,16,52,200696000],"organizationId":"f2608cbf-649d-4960-954e-f3d3a1f822ad"}
Partition: 0   Offset: 1   Key: empty   Timestamp: 2025-12-15 19:44:39.331 Headers: __TypeId__: addy.salepro.dao.model.EventModel, kafka_dlt-exception-cause-fqcn: com.google.gson.JsonSyntaxException, kafka_dlt-exception-fqcn: org.springframework.kafka.listener.ListenerExecutionFailedException, kafka_dlt-exception-message: Listener method 'public void addy.salepro.scheduler.customer.CustomerEventConsumer.consumeCustomerEvent(addy.salepro.dao.model.EventModel)' threw exception; java.lang.IllegalStateException: Expected BEGIN_ARRAY but was BEGIN_OBJECT at line 1 column 2 path $ See https://github.com/google/gson/blob/main/Troubleshooting.md#unexpected-json-structure, kafka_dlt-exception-stacktrace: org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public void addy.salepro.scheduler.customer.CustomerEventConsumer.consumeCustomerEvent(addy.salepro.dao.model.EventModel)' threw exception at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.decorateException(KafkaMessageListenerContainer.java:2994) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2901) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2865) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2777) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2614) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2503) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:2152) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1528) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1466) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1335) at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) at java.base/java.lang.Thread.run(Thread.java:1583) Suppressed: org.springframework.kafka.listener.ListenerExecutionFailedException: Restored Stack Trace at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:490) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invoke(MessagingMessageListenerAdapter.java:421) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:85) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:50) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2887) Caused by: com.google.gson.JsonSyntaxException: java.lang.IllegalStateException: Expected BEGIN_ARRAY but was BEGIN_OBJECT at line 1 column 2 path $ See https://github.com/google/gson/blob/main/Troubleshooting.md#unexpected-json-structure at com.google.gson.Gson.fromJson(Gson.java:1382) at com.google.gson.Gson.fromJson(Gson.java:1260) at com.google.gson.Gson.fromJson(Gson.java:1170) at com.google.gson.Gson.fromJson(Gson.java:1136) at addy.salepro.scheduler.customer.CustomerEventConsumer.handleCustomerActivated(CustomerEventConsumer.java:146) at addy.salepro.scheduler.customer.CustomerEventConsumer.consumeCustomerEvent(CustomerEventConsumer.java:66) at java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:103) at java.base/java.lang.reflect.Method.invoke(Method.java:580) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:169) at org.springframework.kafka.listener.adapter.KotlinAwareInvocableHandlerMethod.doInvoke(KotlinAwareInvocableHandlerMethod.java:45) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:119) at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:78) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:475) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invoke(MessagingMessageListenerAdapter.java:421) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:85) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:50) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2887) ... 10 more Caused by: java.lang.IllegalStateException: Expected BEGIN_ARRAY but was BEGIN_OBJECT at line 1 column 2 path $ See https://github.com/google/gson/blob/main/Troubleshooting.md#unexpected-json-structure at com.google.gson.stream.JsonReader.unexpectedTokenError(JsonReader.java:1831) at com.google.gson.stream.JsonReader.beginArray(JsonReader.java:470) at com.google.gson.internal.bind.CollectionTypeAdapterFactory$Adapter.read(CollectionTypeAdapterFactory.java:82) at com.google.gson.internal.bind.CollectionTypeAdapterFactory$Adapter.read(CollectionTypeAdapterFactory.java:64) at com.google.gson.Gson.fromJson(Gson.java:1359) ... 26 more , kafka_dlt-original-consumer-group: customer-group, kafka_dlt-original-offset: , kafka_dlt-original-partition: , kafka_dlt-original-timestamp: �" _, kafka_dlt-original-timestamp-type: CreateTime, kafka_dlt-original-topic: addy_system-customer
 
{"id":"f196d79a-32d6-4e43-865a-31ca1d9b1d2b","subjectId":"a5a1d195-9dcf-4b99-a330-055979691b59","eventType":"CUSTOMER_REGISTERED","body":"{\n  \"createdDate\": \"2025-12-15T19:44:15.329206781\",\n  \"currentPoint\": 0.0,\n  \"modifiedDate\": \"2025-12-15T19:44:15.329076945\",\n  \"validSecretCode\": false,\n  \"status\": \"ACTIVE\",\n  \"customerType\": \"REGULAR\",\n  \"username\": \"0389765235\",\n  \"memberCode\": \"0389765235\",\n  \"totalSpend\": 0,\n  \"totalDebt\": 0,\n  \"totalOrder\": 0,\n  \"totalPoint\": 0.0,\n  \"deleteImageIds\": [],\n  \"leadSource\": \"REFERRAL\",\n  \"id\": \"a5a1d195-9dcf-4b99-a330-055979691b59\",\n  \"fullName\": \"KH235\",\n  \"phoneNumber\": \"0389765235\",\n  \"gender\": \"OTHER\"\n}","message":null,"author":null,"status":"PROCESSING","createdDate":[2025,12,15,19,44,15,595693000],"organizationId":"f2608cbf-649d-4960-954e-f3d3a1f822ad"}