{"@timestamp":"2020-02-14T13:33:20.295+00:00","@version":1,"message":"org.springframework.messaging.MessagingException: Exception thrown while invoking com.oboz.order.po_changes_processing.Application#processMessage[1 args]; nested exception is java.lang.IllegalStateException: data.fromLocationUuid must not be null, failedMessage=GenericMessage [payload={\"info\":{\"version\":\"1.0\",\"uuid\":\"a923de42-2ab8-4e5d-bbec-9b077d4238ca\",\"started_at\":\"2020-02-14T13:33:15.910881Z\"},\"data\":{\"type\":\"order-changed\",\"uuid\":\"55b1b616-ee8f-484a-b48c-68e182a258db\",\"creatorUuid\":\"519b6516-32ed-4144-b915-c266f4072bf2\",\"authorUuid\":\"07356515-3286-4cd3-b170-079aabe78e97\",\"clientUuid\":\"519b6516-32ed-4144-b915-c266f4072bf2\",\"number\":\"PO20 632 6329\",\"externalNumber\":\"PO20 632 6329\",\"status\":\"FORMED\",\"isArriveDatetime\":true,\"arriveOrDepartureDt\":\"2020-02-13T08:00:00.000Z\",\"fromLocationUuid\":\"\",\"toLocationUuid\":\"\",\"tariffRur\":129800,\"archived\":false}}, headers={kafka_offset=4, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@45bd359a, deliveryAttempt=3, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=49f8097a-9bf4-43cc-99e7-98c17b3f4648, kafka_receivedPartitionId=0, kafka_receivedTopic=order.orders, kafka_receivedTimestamp=1581687197115, contentType=application/json}]\n\tat org.springframework.cloud.stream.binding.StreamListenerMessageHandler.handleRequestMessage(StreamListenerMessageHandler.java:63)\n\tat org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:123)\n\tat org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:169)\n\tat org.springframework.integration.dispatcher.AbstractDispatcher.tryOptimizedDispatch(AbstractDispatcher.java:115)\n\tat org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:132)\n\tat org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:105)\n\tat org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:73)\n\tat org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:453)\n\tat org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:401)\n\tat org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:187)\n\tat org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:166)\n\tat org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:47)\n\tat org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:109)\n\tat org.springframework.integration.endpoint.MessageProducerSupport.sendMessage(MessageProducerSupport.java:205)\n\tat org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter.sendMessageIfAny(KafkaMessageDrivenChannelAdapter.java:369)\n\tat org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter.access$400(KafkaMessageDrivenChannelAdapter.java:74)\n\tat org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter$IntegrationRecordMessageListener.onMessage(KafkaMessageDrivenChannelAdapter.java:431)\n\tat org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter$IntegrationRecordMessageListener.onMessage(KafkaMessageDrivenChannelAdapter.java:402)\n\tat org.springframework.kafka.listener.adapter.RetryingMessageListenerAdapter.lambda$onMessage$0(RetryingMessageListenerAdapter.java:120)\n\tat org.springframework.retry.support.RetryTemplate.doExecute(RetryTemplate.java:287)\n\tat org.springframework.retry.support.RetryTemplate.execute(RetryTemplate.java:211)\n\tat org.springframework.kafka.listener.adapter.RetryingMessageListenerAdapter.onMessage(RetryingMessageListenerAdapter.java:114)\n\tat org.springframework.kafka.listener.adapter.RetryingMessageListenerAdapter.onMessage(RetryingMessageListenerAdapter.java:40)\n\tat org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:1275)\n\tat org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:1258)\n\tat org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1219)\n\tat org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1200)\n\tat org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1120)\n\tat org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:935)\n\tat org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:751)\n\tat org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:700)\n\tat java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)\n\tat java.util.concurrent.FutureTask.run(FutureTask.java:266)\n\tat java.lang.Thread.run(Thread.java:748)\nCaused by: java.lang.IllegalStateException: data.fromLocationUuid must not be null\n\tat com.oboz.order.po_changes_processing.services.MessageService.handleMessage(MessageService.kt:32)\n\tat com.oboz.order.po_changes_processing.Application.processMessage(application.kt:33)\n\tat sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)\n\tat sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)\n\tat sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)\n\tat java.lang.reflect.Method.invoke(Method.java:498)\n\tat org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171)\n\tat org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120)\n\tat org.springframework.cloud.stream.binding.StreamListenerMessageHandler.handleRequestMessage(StreamListenerMessageHandler.java:55)\n\t... 33 more\n","logger_name":"org.springframework.integration.handler.LoggingHandler","thread_name":"[Ljava.lang.String;@54e3cba2.container-0-C-1","level":"ERROR","level_value":40000,"app-name":"order-po-changes-processing","app-version":"ccf25e8"}
{"@timestamp":"2020-02-14T13:33:20.296+00:00","@version":1,"message":"Error while processing: ConsumerRecord(topic = order.orders, partition = 0, offset = 4, CreateTime = 1581687197115, serialized key size = 36, serialized value size = 577, headers = RecordHeaders(headers = [], isReadOnly = false), key = 49f8097a-9bf4-43cc-99e7-98c17b3f4648, value = {\"info\":{\"version\":\"1.0\",\"uuid\":\"a923de42-2ab8-4e5d-bbec-9b077d4238ca\",\"started_at\":\"2020-02-14T13:33:15.910881Z\"},\"data\":{\"type\":\"order-changed\",\"uuid\":\"55b1b616-ee8f-484a-b48c-68e182a258db\",\"creatorUuid\":\"519b6516-32ed-4144-b915-c266f4072bf2\",\"authorUuid\":\"07356515-3286-4cd3-b170-079aabe78e97\",\"clientUuid\":\"519b6516-32ed-4144-b915-c266f4072bf2\",\"number\":\"PO20 632 6329\",\"externalNumber\":\"PO20 632 6329\",\"status\":\"FORMED\",\"isArriveDatetime\":true,\"arriveOrDepartureDt\":\"2020-02-13T08:00:00.000Z\",\"fromLocationUuid\":\"\",\"toLocationUuid\":\"\",\"tariffRur\":129800,\"archived\":false}})","logger_name":"org.springframework.kafka.listener.LoggingErrorHandler","thread_name":"[Ljava.lang.String;@54e3cba2.container-0-C-1","level":"ERROR","level_value":40000,"stack_trace":"org.springframework.messaging.MessagingException: Exception thrown while invoking com.oboz.order.po_changes_processing.Application#processMessage[1 args]; nested exception is java.lang.IllegalStateException: data.fromLocationUuid must not be null\n\tat org.springframework.cloud.stream.binding.StreamListenerMessageHandler.handleRequestMessage(StreamListenerMessageHandler.java:63)\n\tat org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:123)\n\tat org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:169)\n\tat org.springframework.integration.dispatcher.AbstractDispatcher.tryOptimizedDispatch(AbstractDispatcher.java:115)\n\tat org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:132)\n\tat org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:105)\n\tat org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:73)\n\tat org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:453)\n\tat org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:401)\n\tat org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:187)\n\tat org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:166)\n\tat org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:47)\n\tat org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:109)\n\tat org.springframework.integration.endpoint.MessageProducerSupport.sendMessage(MessageProducerSupport.java:205)\n\tat org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter.sendMessageIfAny(KafkaMessageDrivenChannelAdapter.java:369)\n\tat org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter.access$400(KafkaMessageDrivenChannelAdapter.java:74)\n\tat org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter$IntegrationRecordMessageListener.onMessage(KafkaMessageDrivenChannelAdapter.java:431)\n\tat org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter$IntegrationRecordMessageListener.onMessage(KafkaMessageDrivenChannelAdapter.java:402)\n\tat org.springframework.kafka.listener.adapter.RetryingMessageListenerAdapter.lambda$onMessage$0(RetryingMessageListenerAdapter.java:120)\n\tat org.springframework.retry.support.RetryTemplate.doExecute(RetryTemplate.java:287)\n\tat org.springframework.retry.support.RetryTemplate.execute(RetryTemplate.java:211)\n\tat org.springframework.kafka.listener.adapter.RetryingMessageListenerAdapter.onMessage(RetryingMessageListenerAdapter.java:114)\n\tat org.springframework.kafka.listener.adapter.RetryingMessageListenerAdapter.onMessage(RetryingMessageListenerAdapter.java:40)\n\tat org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:1275)\n\tat org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:1258)\n\tat org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1219)\n\tat org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1200)\n\tat org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1120)\n\tat org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:935)\n\tat org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:751)\n\tat org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:700)\n\tat java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)\n\tat java.util.concurrent.FutureTask.run(FutureTask.java:266)\n\tat java.lang.Thread.run(Thread.java:748)\nCaused by: java.lang.IllegalStateException: data.fromLocationUuid must not be null\n\tat com.oboz.order.po_changes_processing.services.MessageService.handleMessage(MessageService.kt:32)\n\tat com.oboz.order.po_changes_processing.Application.processMessage(application.kt:33)\n\tat sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)\n\tat sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)\n\tat sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)\n\tat java.lang.reflect.Method.invoke(Method.java:498)\n\tat org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171)\n\tat org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120)\n\tat org.springframework.cloud.stream.binding.StreamListenerMessageHandler.handleRequestMessage(StreamListenerMessageHandler.java:55)\n\t... 33 common frames omitted\n","app-name":"order-po-changes-processing","app-version":"ccf25e8"}