Advertisement
Guest User

Untitled

a guest
Apr 13th, 2019
147
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 21.47 KB | None | 0 0
  1. 2019-04-13 04:40:20.805 INFO 9783 --- [ntainer#1-0-C-1] .c.k.r.KafkaConnectRedisMessagesReceiver : Received Product Media Status Service message: [GenericMessage [payload={"key":"cHJvZHVjdF9tZWRpYV9zdGF0dXNlczplMTRlYzg1NS04YzIxLTQwMTctOGVmMi05ZjE1YWUwMzk3OTY=","field":"ZnJfQ0E=","value":"TkVX"}, headers={kafka_offset=3014, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@3d60c61f, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=com.moilioncircle.redis.replicator.cmd.impl.HSetNxCommand, kafka_receivedPartitionId=0, kafka_receivedTopic=product-media-status-service, kafka_receivedTimestamp=1555144820819}]]
  2. 2019-04-13 04:40:20.806 INFO 9783 --- [ntainer#1-0-C-1] .c.k.r.KafkaConnectRedisMessagesReceiver : Received Product Media Status Service message: [GenericMessage [payload={"key":"cHJvZHVjdF9tZWRpYV9zdGF0dXNlczplMTRlYzg1NS04YzIxLTQwMTctOGVmMi05ZjE1YWUwMzk3OTY=","field":"ZW5fQ0E=","value":"TkVX"}, headers={kafka_offset=3015, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@3d60c61f, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=com.moilioncircle.redis.replicator.cmd.impl.HSetNxCommand, kafka_receivedPartitionId=0, kafka_receivedTopic=product-media-status-service, kafka_receivedTimestamp=1555144820824}]]
  3. 2019-04-13 04:40:20.965 INFO 9783 --- [ntainer#2-0-C-1] .c.k.r.KafkaConnectRedisMessagesReceiver : Received Product Specifications Status Message: [GenericMessage [payload={"key":"cHJvZHVjdF9zdGF0dXNlczplMTRlYzg1NS04YzIxLTQwMTctOGVmMi05ZjE1YWUwMzk3OTY=","field":"ZnJfQ0E=","value":"TkVX"}, headers={kafka_offset=4087, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@30387c3d, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=com.moilioncircle.redis.replicator.cmd.impl.HSetNxCommand, kafka_receivedPartitionId=0, kafka_receivedTopic=product-specifications-status-service, kafka_receivedTimestamp=1555144820981}]]
  4. 2019-04-13 04:40:20.967 WARN 9783 --- [ntainer#2-0-C-1] com.zaxxer.hikari.pool.PoolBase : HikariPool-1 - Failed to validate connection com.mysql.jdbc.JDBC4Connection@66855bc3 (No operations allowed after connection closed.)
  5. 2019-04-13 04:40:20.971 WARN 9783 --- [ntainer#2-0-C-1] com.zaxxer.hikari.pool.PoolBase : HikariPool-1 - Failed to validate connection com.mysql.jdbc.JDBC4Connection@66ab2ba8 (No operations allowed after connection closed.)
  6. 2019-04-13 04:40:20.973 WARN 9783 --- [ntainer#2-0-C-1] com.zaxxer.hikari.pool.PoolBase : HikariPool-1 - Failed to validate connection com.mysql.jdbc.JDBC4Connection@5428e1bc (No operations allowed after connection closed.)
  7. 2019-04-13 04:40:20.976 WARN 9783 --- [ntainer#2-0-C-1] com.zaxxer.hikari.pool.PoolBase : HikariPool-1 - Failed to validate connection com.mysql.jdbc.JDBC4Connection@18bfe3b9 (No operations allowed after connection closed.)
  8. 2019-04-13 04:40:20.978 WARN 9783 --- [ntainer#2-0-C-1] com.zaxxer.hikari.pool.PoolBase : HikariPool-1 - Failed to validate connection com.mysql.jdbc.JDBC4Connection@1fe9d248 (No operations allowed after connection closed.)
  9. 2019-04-13 04:40:20.980 WARN 9783 --- [ntainer#2-0-C-1] com.zaxxer.hikari.pool.PoolBase : HikariPool-1 - Failed to validate connection com.mysql.jdbc.JDBC4Connection@20205c76 (No operations allowed after connection closed.)
  10. 2019-04-13 04:40:20.981 WARN 9783 --- [ntainer#2-0-C-1] com.zaxxer.hikari.pool.PoolBase : HikariPool-1 - Failed to validate connection com.mysql.jdbc.JDBC4Connection@33966ccf (No operations allowed after connection closed.)
  11. 2019-04-13 04:40:20.983 WARN 9783 --- [ntainer#2-0-C-1] com.zaxxer.hikari.pool.PoolBase : HikariPool-1 - Failed to validate connection com.mysql.jdbc.JDBC4Connection@54d3e32f (No operations allowed after connection closed.)
  12. 2019-04-13 04:40:20.984 WARN 9783 --- [ntainer#2-0-C-1] com.zaxxer.hikari.pool.PoolBase : HikariPool-1 - Failed to validate connection com.mysql.jdbc.JDBC4Connection@27183f5a (No operations allowed after connection closed.)
  13. 2019-04-13 04:40:20.986 WARN 9783 --- [ntainer#2-0-C-1] com.zaxxer.hikari.pool.PoolBase : HikariPool-1 - Failed to validate connection com.mysql.jdbc.JDBC4Connection@2768cf62 (No operations allowed after connection closed.)
  14. 2019-04-13 04:40:21.223 INFO 9783 --- [ntainer#2-0-C-1] .c.k.r.KafkaConnectRedisMessagesReceiver : Received Product Specifications Status Message: [GenericMessage [payload={"key":"cHJvZHVjdF9zdGF0dXNlczplMTRlYzg1NS04YzIxLTQwMTctOGVmMi05ZjE1YWUwMzk3OTY=","field":"ZW5fQ0E=","value":"TkVX"}, headers={kafka_offset=4088, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@30387c3d, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=com.moilioncircle.redis.replicator.cmd.impl.HSetNxCommand, kafka_receivedPartitionId=0, kafka_receivedTopic=product-specifications-status-service, kafka_receivedTimestamp=1555144820984}]]
  15. 2019-04-13 04:40:21.256 INFO 9783 --- [ntainer#3-0-C-1] k.d.KafkaConnectDebeziumMessagesReceiver : Recieved Add Product Specification Locale Message:[{"after": null, "patch": "{\"$v\" : 1,\"$set\" : {\"fr_CA\" : { }}}", "source": {"version": "0.8.3.Final", "name": "burraq", "rs": "rs0", "ns": "product-specifications-service.specifications", "sec": 1555144820, "ord": 2, "h": 692496727743164909, "initsync": false}, "op": "u", "ts_ms": 1555144820808}]
  16. 2019-04-13 04:40:21.256 INFO 9783 --- [ntainer#3-0-C-1] k.d.KafkaConnectDebeziumMessagesReceiver : Received Debezium's Add Product Locale Command from pspecs for key: [e14ec855-8c21-4017-8ef2-9f15ae039796] with data: [{"after": null, "patch": "{\"$v\" : 1,\"$set\" : {\"fr_CA\" : { }}}", "source": {"version": "0.8.3.Final", "name": "burraq", "rs": "rs0", "ns": "product-specifications-service.specifications", "sec": 1555144820, "ord": 2, "h": 692496727743164909, "initsync": false}, "op": "u", "ts_ms": 1555144820808}]
  17. 2019-04-13 04:40:21.264 INFO 9783 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : findCmsProduct e14ec855-8c21-4017-8ef2-9f15ae039796 cmsProducts: [com.etilize.burraq.cda.specification.CmsProduct@57004344[ProductId=1247366793,CategoryId=10992], com.etilize.burraq.cda.specification.CmsProduct@4df1246[ProductId=1247366792,CategoryId=10992], com.etilize.burraq.cda.specification.CmsProduct@11b42f72[ProductId=1247366792,CategoryId=10992]]
  18. 2019-04-13 04:40:21.265 INFO 9783 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : manufacturerId: 1046998
  19. 2019-04-13 04:40:21.265 INFO 9783 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : manufacturer: ID:1046998
  20. 2019-04-13 04:40:21.265 INFO 9783 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : partNumber: TestProduct-5002623
  21. 2019-04-13 04:40:21.265 INFO 9783 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : cmsCategoryId: 10992
  22. 2019-04-13 04:40:21.265 INFO 9783 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : cmsExistingProductId: 1247366793
  23. 2019-04-13 04:40:21.265 INFO 9783 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : productExistInMarket: false
  24. 2019-04-13 04:40:21.265 INFO 9783 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : productExitInMarketGroup: true
  25. 2019-04-13 04:40:21.267 INFO 9783 --- [ntainer#3-0-C-1] k.d.KafkaConnectDebeziumMessagesReceiver : Successfully saved received following Debezium's message: [{"after": null, "patch": "{\"$v\" : 1,\"$set\" : {\"fr_CA\" : { }}}", "source": {"version": "0.8.3.Final", "name": "burraq", "rs": "rs0", "ns": "product-specifications-service.specifications", "sec": 1555144820, "ord": 2, "h": 692496727743164909, "initsync": false}, "op": "u", "ts_ms": 1555144820808}].
  26. 2019-04-13 04:40:21.268 INFO 9783 --- [ntainer#3-0-C-1] k.d.KafkaConnectDebeziumMessagesReceiver : Recieved Add Product Specification Locale Message:[{"after": null, "patch": "{\"$v\" : 1,\"$set\" : {\"en_CA\" : { }}}", "source": {"version": "0.8.3.Final", "name": "burraq", "rs": "rs0", "ns": "product-specifications-service.specifications", "sec": 1555144820, "ord": 6, "h": -751764302211747081, "initsync": false}, "op": "u", "ts_ms": 1555144820813}]
  27. 2019-04-13 04:40:21.268 INFO 9783 --- [ntainer#3-0-C-1] k.d.KafkaConnectDebeziumMessagesReceiver : Received Debezium's Add Product Locale Command from pspecs for key: [e14ec855-8c21-4017-8ef2-9f15ae039796] with data: [{"after": null, "patch": "{\"$v\" : 1,\"$set\" : {\"en_CA\" : { }}}", "source": {"version": "0.8.3.Final", "name": "burraq", "rs": "rs0", "ns": "product-specifications-service.specifications", "sec": 1555144820, "ord": 6, "h": -751764302211747081, "initsync": false}, "op": "u", "ts_ms": 1555144820813}]
  28. 2019-04-13 04:40:21.275 INFO 9783 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : findCmsProduct e14ec855-8c21-4017-8ef2-9f15ae039796 cmsProducts: [com.etilize.burraq.cda.specification.CmsProduct@685b8780[ProductId=1247366793,CategoryId=10992], com.etilize.burraq.cda.specification.CmsProduct@4afa5cf8[ProductId=1247366792,CategoryId=10992], com.etilize.burraq.cda.specification.CmsProduct@3f7ac22d[ProductId=1247366792,CategoryId=10992], com.etilize.burraq.cda.specification.CmsProduct@3fcc6f76[ProductId=1247366793,CategoryId=10992]]
  29. 2019-04-13 04:40:21.276 INFO 9783 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : manufacturerId: 1046998
  30. 2019-04-13 04:40:21.276 INFO 9783 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : manufacturer: ID:1046998
  31. 2019-04-13 04:40:21.276 INFO 9783 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : partNumber: TestProduct-5002623
  32. 2019-04-13 04:40:21.276 INFO 9783 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : cmsCategoryId: 10992
  33. 2019-04-13 04:40:21.277 INFO 9783 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : cmsExistingProductId: 1247366793
  34. 2019-04-13 04:40:21.277 INFO 9783 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : productExistInMarket: false
  35. 2019-04-13 04:40:21.277 INFO 9783 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : productExitInMarketGroup: true
  36. 2019-04-13 04:40:21.279 INFO 9783 --- [ntainer#3-0-C-1] k.d.KafkaConnectDebeziumMessagesReceiver : Successfully saved received following Debezium's message: [{"after": null, "patch": "{\"$v\" : 1,\"$set\" : {\"en_CA\" : { }}}", "source": {"version": "0.8.3.Final", "name": "burraq", "rs": "rs0", "ns": "product-specifications-service.specifications", "sec": 1555144820, "ord": 6, "h": -751764302211747081, "initsync": false}, "op": "u", "ts_ms": 1555144820813}].
  37. 2019-04-13 04:40:21.280 INFO 9783 --- [ntainer#3-0-C-1] k.d.KafkaConnectDebeziumMessagesReceiver : Recieved Update Product Specification Message:[{"after": null, "patch": "{\"$v\" : 1,\"$set\" : {\"en.5cab65f2fcd96b4b222489ea\" : {\"value\" : \"TestProduct-5002623\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555144820786},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"},\"en.5cab65f3fcd96b4b222489f6\" : {\"value\" : \"Greatland\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555144820786},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}}}", "source": {"version": "0.8.3.Final", "name": "burraq", "rs": "rs0", "ns": "product-specifications-service.specifications", "sec": 1555144820, "ord": 9, "h": -7970264045011148999, "initsync": false}, "op": "u", "ts_ms": 1555144820823}]
  38. 2019-04-13 04:40:21.280 INFO 9783 --- [ntainer#3-0-C-1] k.d.KafkaConnectDebeziumMessagesReceiver : Received Debezium's Update Producut Specifications Command from pspecs [{"after": null, "patch": "{\"$v\" : 1,\"$set\" : {\"en.5cab65f2fcd96b4b222489ea\" : {\"value\" : \"TestProduct-5002623\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555144820786},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"},\"en.5cab65f3fcd96b4b222489f6\" : {\"value\" : \"Greatland\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555144820786},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}}}", "source": {"version": "0.8.3.Final", "name": "burraq", "rs": "rs0", "ns": "product-specifications-service.specifications", "sec": 1555144820, "ord": 9, "h": -7970264045011148999, "initsync": false}, "op": "u", "ts_ms": 1555144820823}]
  39. 2019-04-13 04:40:21.289 INFO 9783 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : 5cab65f2fcd96b4b222489ea
  40. 2019-04-13 04:40:21.289 INFO 9783 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : com.etilize.burraq.cda.taxonomy.mapping.BurraqCategoryTaxonomies@33a1b4c6
  41. 2019-04-13 04:40:21.289 INFO 9783 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : 11798
  42. 2019-04-13 04:40:21.311 INFO 9783 --- [ntainer#3-0-C-1] e.b.c.s.BasicSpecificationRepositoryImpl : selectProductId: BurraqProductIde14ec855-8c21-4017-8ef2-9f15ae039796 MarketId:16 LanguageId:17
  43. 2019-04-13 04:40:21.316 INFO 9783 --- [ntainer#3-0-C-1] e.b.c.s.BasicSpecificationRepositoryImpl : selectProductId: BurraqProductIde14ec855-8c21-4017-8ef2-9f15ae039796 MarketId:12 LanguageId:1
  44. 2019-04-13 04:40:21.319 ERROR 9783 --- [ntainer#3-0-C-1] o.s.kafka.listener.LoggingErrorHandler : Error while processing: ConsumerRecord(topic = burraq.product-specifications-service.specifications, partition = 0, offset = 4031, CreateTime = 1555144821273, serialized key size = 44, serialized value size = 599, headers = RecordHeaders(headers = [], isReadOnly = false), key = {"id": "\"e14ec855-8c21-4017-8ef2-9f15ae039796\""}, value = {"after": null, "patch": "{\"$v\" : 1,\"$set\" : {\"en.5cab65f2fcd96b4b222489ea\" : {\"value\" : \"TestProduct-5002623\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555144820786},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"},\"en.5cab65f3fcd96b4b222489f6\" : {\"value\" : \"Greatland\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555144820786},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}}}", "source": {"version": "0.8.3.Final", "name": "burraq", "rs": "rs0", "ns": "product-specifications-service.specifications", "sec": 1555144820, "ord": 9, "h": -7970264045011148999, "initsync": false}, "op": "u", "ts_ms": 1555144820823})
  45.  
  46. org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public synchronized void com.etilize.burraq.cda.kafka.debezium.KafkaConnectDebeziumMessagesReceiver.processProductSpecificationUpdates(org.apache.avro.generic.GenericData$Record,org.apache.kafka.clients.consumer.ConsumerRecord<java.lang.Object, java.lang.String>)' threw exception; nested exception is java.lang.IndexOutOfBoundsException: Index: 0, Size: 0
  47. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:267) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  48. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:80) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  49. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  50. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1066) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  51. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1046) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  52. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:997) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  53. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:866) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  54. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:724) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  55. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_91]
  56. at java.util.concurrent.FutureTask.run(FutureTask.java:266) [na:1.8.0_91]
  57. at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]
  58. Caused by: java.lang.IndexOutOfBoundsException: Index: 0, Size: 0
  59. at java.util.ArrayList.rangeCheck(ArrayList.java:653) ~[na:1.8.0_91]
  60. at java.util.ArrayList.get(ArrayList.java:429) ~[na:1.8.0_91]
  61. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl.selectProductId(BasicSpecificationRepositoryImpl.java:582) ~[classes!/:1.0.0-SNAPSHOT]
  62. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl.saveProductParameter(BasicSpecificationRepositoryImpl.java:558) ~[classes!/:1.0.0-SNAPSHOT]
  63. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl$$FastClassBySpringCGLIB$$f53e9f0a.invoke(<generated>) ~[classes!/:1.0.0-SNAPSHOT]
  64. at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204) ~[spring-core-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  65. at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:747) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  66. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  67. at org.springframework.dao.support.PersistenceExceptionTranslationInterceptor.invoke(PersistenceExceptionTranslationInterceptor.java:139) ~[spring-tx-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  68. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:185) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  69. at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:689) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  70. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl$$EnhancerBySpringCGLIB$$14213b5.saveProductParameter(<generated>) ~[classes!/:1.0.0-SNAPSHOT]
  71. at com.etilize.burraq.cda.specification.SpecificationServiceImpl.saveSpecsToCMS(SpecificationServiceImpl.java:508) ~[classes!/:1.0.0-SNAPSHOT]
  72. at com.etilize.burraq.cda.specification.SpecificationServiceImpl.populateInternationalParameterToEnglishLocale(SpecificationServiceImpl.java:473) ~[classes!/:1.0.0-SNAPSHOT]
  73. at com.etilize.burraq.cda.specification.SpecificationServiceImpl.lambda$updateSpecifications$0(SpecificationServiceImpl.java:368) ~[classes!/:1.0.0-SNAPSHOT]
  74. at java.util.HashMap$EntrySet.forEach(HashMap.java:1035) ~[na:1.8.0_91]
  75. at com.etilize.burraq.cda.specification.SpecificationServiceImpl.updateSpecifications(SpecificationServiceImpl.java:342) ~[classes!/:1.0.0-SNAPSHOT]
  76. at com.etilize.burraq.cda.kafka.debezium.KafkaConnectDebeziumMessagesReceiver.processUpdateSpecificationAttributeCommand(KafkaConnectDebeziumMessagesReceiver.java:169) ~[classes!/:1.0.0-SNAPSHOT]
  77. at com.etilize.burraq.cda.kafka.debezium.KafkaConnectDebeziumMessagesReceiver.callStaticMethod(KafkaConnectDebeziumMessagesReceiver.java:125) ~[classes!/:1.0.0-SNAPSHOT]
  78. at com.etilize.burraq.cda.kafka.debezium.KafkaConnectDebeziumMessagesReceiver.processProductSpecificationUpdates(KafkaConnectDebeziumMessagesReceiver.java:97) ~[classes!/:1.0.0-SNAPSHOT]
  79. at sun.reflect.GeneratedMethodAccessor146.invoke(Unknown Source) ~[na:na]
  80. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_91]
  81. at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_91]
  82. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:181) ~[spring-messaging-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  83. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:114) ~[spring-messaging-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  84. at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  85. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:248) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  86. ... 10 common frames omitted
  87.  
  88. 2019-04-13 04:40:21.595 INFO 9783 --- [ntainer#6-0-C-1] .c.k.n.KafkaConnectNeo4jMessagesReceiver : Received message from product-code-service [GenericMessage [payload={"payload":{"id":"1623345","start":{"id":"2323650","labels":["Product"]},"end":{"id":"2324038","labels":["CustomerCode"]},"before":null,"after":{"properties":{"market":"CA","code":"TestProductCode5001541","productId":"e14ec855-8c21-4017-8ef2-9f15ae039796","customerId":"5c7e0598fe19fe3ad727baff"}},"label":"IDENTIFIED_BY","type":"relationship"},"meta":{"timestamp":1555144821583,"username":"neo4j","txId":976710,"txEventId":1,"txEventsCount":2,"operation":"created","source":{"hostname":"vmnode0018"}},"schema":{"properties":[],"constraints":null}}, headers={kafka_offset=1131, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@1c5ad04a, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=976711-1, kafka_receivedPartitionId=0, kafka_receivedTopic=product-code-service, kafka_receivedTimestamp=1555144821587}]]
  89. 2019-04-13 04:40:21.595 INFO 9783 --- [ntainer#6-0-C-1] .c.k.n.KafkaConnectNeo4jMessagesReceiver : Received product-code-service for burraq product id [e14ec855-8c21-4017-8ef2-9f15ae039796]
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement