API tools faq
paste
Guest User

Untitled

a guest
Apr 11th, 2019
50
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 71.57 KB | None | 0 0
raw download clone embed print report
  1. 2019-04-11 08:34:48.626 INFO 6052 --- [ntainer#4-0-C-1] .c.k.r.KafkaConnectRedisMessagesReceiver : Received Product Specifications Status Message: [GenericMessage [payload={"key":"cHJvZHVjdF9zdGF0dXNlczoyOTJjNDMxYy01Mjc5LTQ2YTAtYWQ5NC1hNmQ1MzM0NDUzMDY=","field":"ZW4=","value":"TkVX"}, headers={kafka_offset=3691, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@71e19f65, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=com.moilioncircle.redis.replicator.cmd.impl.HSetNxCommand, kafka_receivedPartitionId=0, kafka_receivedTopic=product-specifications-status-service, kafka_receivedTimestamp=1554986088639}]]
  2. 2019-04-11 08:34:48.630 INFO 6052 --- [ntainer#5-0-C-1] .c.k.r.KafkaConnectRedisMessagesReceiver : Received Product Media Status Service message: [GenericMessage [payload={"key":"cHJvZHVjdF9tZWRpYV9zdGF0dXNlczoyOTJjNDMxYy01Mjc5LTQ2YTAtYWQ5NC1hNmQ1MzM0NDUzMDY=","field":"ZW4=","value":"TkVX"}, headers={kafka_offset=2720, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@197d557b, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=com.moilioncircle.redis.replicator.cmd.impl.HSetNxCommand, kafka_receivedPartitionId=0, kafka_receivedTopic=product-media-status-service, kafka_receivedTimestamp=1554986088642}]]
  3. 2019-04-11 08:34:48.642 INFO 6052 --- [ntainer#4-0-C-1] .c.k.r.KafkaConnectRedisMessagesReceiver : Received Product Specifications Status Message: [GenericMessage [payload={"key":"cHJvZHVjdF9zdGF0dXNlczoyOTJjNDMxYy01Mjc5LTQ2YTAtYWQ5NC1hNmQ1MzM0NDUzMDY=","field":"ZW5fVVM=","value":"TkVX"}, headers={kafka_offset=3692, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@71e19f65, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=com.moilioncircle.redis.replicator.cmd.impl.HSetNxCommand, kafka_receivedPartitionId=0, kafka_receivedTopic=product-specifications-status-service, kafka_receivedTimestamp=1554986088654}]]
  4. 2019-04-11 08:34:48.649 INFO 6052 --- [ntainer#5-0-C-1] .c.k.r.KafkaConnectRedisMessagesReceiver : Received Product Media Status Service message: [GenericMessage [payload={"key":"cHJvZHVjdF9tZWRpYV9zdGF0dXNlczoyOTJjNDMxYy01Mjc5LTQ2YTAtYWQ5NC1hNmQ1MzM0NDUzMDY=","field":"ZXNfVVM=","value":"TkVX"}, headers={kafka_offset=2721, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@197d557b, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=com.moilioncircle.redis.replicator.cmd.impl.HSetNxCommand, kafka_receivedPartitionId=0, kafka_receivedTopic=product-media-status-service, kafka_receivedTimestamp=1554986088660}]]
  5. 2019-04-11 08:34:48.654 INFO 6052 --- [ntainer#4-0-C-1] .c.k.r.KafkaConnectRedisMessagesReceiver : Received Product Specifications Status Message: [GenericMessage [payload={"key":"cHJvZHVjdF9zdGF0dXNlczoyOTJjNDMxYy01Mjc5LTQ2YTAtYWQ5NC1hNmQ1MzM0NDUzMDY=","field":"ZXNfVVM=","value":"TkVX"}, headers={kafka_offset=3693, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@71e19f65, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=com.moilioncircle.redis.replicator.cmd.impl.HSetNxCommand, kafka_receivedPartitionId=0, kafka_receivedTopic=product-specifications-status-service, kafka_receivedTimestamp=1554986088656}]]
  6. 2019-04-11 08:34:48.758 INFO 6052 --- [ntainer#0-0-C-1] k.d.KafkaConnectDebeziumMessagesReceiver : Received Debezium's AssociateCategoryCommand pspecs for key: [ConsumerRecord(topic = burraq.product-specifications-service.specifications, partition = 0, offset = 3270, CreateTime = 1554986088770, serialized key size = 44, serialized value size = 307, headers = RecordHeaders(headers = [], isReadOnly = false), key = {"id": "\"292c431c-5279-46a0-ad94-a6d533445306\""}, value = {"after": "{\"_id\" : \"292c431c-5279-46a0-ad94-a6d533445306\",\"categoryId\" : \"5cab65f3fcd96b27087ff336\",\"industryId\" : \"5cab65effcd96b2747ddd554\",\"_class\" : \"com.etilize.burraq.pspecs.specification.Specification\"}", "patch": null, "source": {"version": "0.8.3.Final", "name": "burraq", "rs": "rs0", "ns": "product-specifications-service.specifications", "sec": 1554986088, "ord": 6, "h": 7884836835701837121, "initsync": false}, "op": "c", "ts_ms": 1554986088649})] with data: [{"after": "{\"_id\" : \"292c431c-5279-46a0-ad94-a6d533445306\",\"categoryId\" : \"5cab65f3fcd96b27087ff336\",\"industryId\" : \"5cab65effcd96b2747ddd554\",\"_class\" : \"com.etilize.burraq.pspecs.specification.Specification\"}", "patch": null, "source": {"version": "0.8.3.Final", "name": "burraq", "rs": "rs0", "ns": "product-specifications-service.specifications", "sec": 1554986088, "ord": 6, "h": 7884836835701837121, "initsync": false}, "op": "c", "ts_ms": 1554986088649}]
  7. 2019-04-11 08:34:48.786 INFO 6052 --- [ntainer#0-0-C-1] o.s.b.f.xml.XmlBeanDefinitionReader : Loading XML bean definitions from class path resource [org/springframework/jdbc/support/sql-error-codes.xml]
  8. 2019-04-11 08:34:48.858 INFO 6052 --- [ntainer#0-0-C-1] o.s.jdbc.support.SQLErrorCodesFactory : SQLErrorCodes loaded: [DB2, Derby, H2, HDB, HSQL, Informix, MS-SQL, MySQL, Oracle, PostgreSQL, Sybase]
  9. 2019-04-11 08:34:48.862 ERROR 6052 --- [ntainer#0-0-C-1] o.s.kafka.listener.LoggingErrorHandler : Error while processing: ConsumerRecord(topic = burraq.product-specifications-service.specifications, partition = 0, offset = 3270, CreateTime = 1554986088770, serialized key size = 44, serialized value size = 307, headers = RecordHeaders(headers = [], isReadOnly = false), key = {"id": "\"292c431c-5279-46a0-ad94-a6d533445306\""}, value = {"after": "{\"_id\" : \"292c431c-5279-46a0-ad94-a6d533445306\",\"categoryId\" : \"5cab65f3fcd96b27087ff336\",\"industryId\" : \"5cab65effcd96b2747ddd554\",\"_class\" : \"com.etilize.burraq.pspecs.specification.Specification\"}", "patch": null, "source": {"version": "0.8.3.Final", "name": "burraq", "rs": "rs0", "ns": "product-specifications-service.specifications", "sec": 1554986088, "ord": 6, "h": 7884836835701837121, "initsync": false}, "op": "c", "ts_ms": 1554986088649})
  10.  
  11. org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public 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 org.springframework.dao.DuplicateKeyException: PreparedStatementCallback; SQL [ insert into DataSourceproduct (datasourceproductid, productid, datasourceid, datasourceproductcode,insertdate,updatedate,insertedbyid,updatedbyid, isactive) values (?,?,?,?,now(),now(),?,?,1) Duplicate entry '1392950385' for key 'PRIMARY'; nested exception is com.mysql.jdbc.exceptions.jdbc4.MySQLIntegrityConstraintViolationException: Duplicate entry '1392950385' for key 'PRIMARY'
  12. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:267) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  13. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:80) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  14. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  15. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1066) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  16. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1046) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  17. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:997) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  18. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:866) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  19. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:724) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  20. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_91]
  21. at java.util.concurrent.FutureTask.run(FutureTask.java:266) [na:1.8.0_91]
  22. at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]
  23. Caused by: org.springframework.dao.DuplicateKeyException: PreparedStatementCallback; SQL [ insert into DataSourceproduct (datasourceproductid, productid, datasourceid, datasourceproductcode,insertdate,updatedate,insertedbyid,updatedbyid, isactive) values (?,?,?,?,now(),now(),?,?,1) Duplicate entry '1392950385' for key 'PRIMARY'; nested exception is com.mysql.jdbc.exceptions.jdbc4.MySQLIntegrityConstraintViolationException: Duplicate entry '1392950385' for key 'PRIMARY'
  24. at org.springframework.jdbc.support.SQLErrorCodeSQLExceptionTranslator.doTranslate(SQLErrorCodeSQLExceptionTranslator.java:242) ~[spring-jdbc-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  25. at org.springframework.jdbc.support.AbstractFallbackSQLExceptionTranslator.translate(AbstractFallbackSQLExceptionTranslator.java:72) ~[spring-jdbc-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  26. at org.springframework.jdbc.core.JdbcTemplate.translateException(JdbcTemplate.java:1402) ~[spring-jdbc-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  27. at org.springframework.jdbc.core.JdbcTemplate.execute(JdbcTemplate.java:620) ~[spring-jdbc-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  28. at org.springframework.jdbc.core.JdbcTemplate.update(JdbcTemplate.java:850) ~[spring-jdbc-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  29. at org.springframework.jdbc.core.JdbcTemplate.update(JdbcTemplate.java:905) ~[spring-jdbc-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  30. at org.springframework.jdbc.core.JdbcTemplate.update(JdbcTemplate.java:915) ~[spring-jdbc-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  31. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl.execute(BasicSpecificationRepositoryImpl.java:425) ~[classes!/:1.0.0-SNAPSHOT]
  32. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl.createDataSource(BasicSpecificationRepositoryImpl.java:343) ~[classes!/:1.0.0-SNAPSHOT]
  33. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl.createProduct(BasicSpecificationRepositoryImpl.java:318) ~[classes!/:1.0.0-SNAPSHOT]
  34. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl$$FastClassBySpringCGLIB$$f53e9f0a.invoke(<generated>) ~[classes!/:1.0.0-SNAPSHOT]
  35. at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204) ~[spring-core-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  36. at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:747) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  37. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  38. at org.springframework.dao.support.PersistenceExceptionTranslationInterceptor.invoke(PersistenceExceptionTranslationInterceptor.java:139) ~[spring-tx-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  39. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:185) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  40. at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:689) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  41. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl$$EnhancerBySpringCGLIB$$a65cf6c4.createProduct(<generated>) ~[classes!/:1.0.0-SNAPSHOT]
  42. at com.etilize.burraq.cda.specification.SpecificationServiceImpl.createProduct(SpecificationServiceImpl.java:156) ~[classes!/:1.0.0-SNAPSHOT]
  43. at com.etilize.burraq.cda.kafka.debezium.KafkaConnectDebeziumMessagesReceiver.processAssociateCategoryCommandFromPSPECS(KafkaConnectDebeziumMessagesReceiver.java:139) ~[classes!/:1.0.0-SNAPSHOT]
  44. at com.etilize.burraq.cda.kafka.debezium.KafkaConnectDebeziumMessagesReceiver.processProductSpecificationUpdates(KafkaConnectDebeziumMessagesReceiver.java:103) ~[classes!/:1.0.0-SNAPSHOT]
  45. at sun.reflect.GeneratedMethodAccessor142.invoke(Unknown Source) ~[na:na]
  46. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_91]
  47. at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_91]
  48. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:181) ~[spring-messaging-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  49. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:114) ~[spring-messaging-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  50. at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  51. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:248) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  52. ... 10 common frames omitted
  53. Caused by: com.mysql.jdbc.exceptions.jdbc4.MySQLIntegrityConstraintViolationException: Duplicate entry '1392950385' for key 'PRIMARY'
  54. at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) ~[na:1.8.0_91]
  55. at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) ~[na:1.8.0_91]
  56. at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) ~[na:1.8.0_91]
  57. at java.lang.reflect.Constructor.newInstance(Constructor.java:423) ~[na:1.8.0_91]
  58. at com.mysql.jdbc.Util.handleNewInstance(Util.java:425) ~[mysql-connector-java-5.1.46.jar!/:5.1.46]
  59. at com.mysql.jdbc.Util.getInstance(Util.java:408) ~[mysql-connector-java-5.1.46.jar!/:5.1.46]
  60. at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:936) ~[mysql-connector-java-5.1.46.jar!/:5.1.46]
  61. at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3976) ~[mysql-connector-java-5.1.46.jar!/:5.1.46]
  62. at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3912) ~[mysql-connector-java-5.1.46.jar!/:5.1.46]
  63. at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:2530) ~[mysql-connector-java-5.1.46.jar!/:5.1.46]
  64. at com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:2683) ~[mysql-connector-java-5.1.46.jar!/:5.1.46]
  65. at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2486) ~[mysql-connector-java-5.1.46.jar!/:5.1.46]
  66. at com.mysql.jdbc.PreparedStatement.executeInternal(PreparedStatement.java:1858) ~[mysql-connector-java-5.1.46.jar!/:5.1.46]
  67. at com.mysql.jdbc.PreparedStatement.executeUpdateInternal(PreparedStatement.java:2079) ~[mysql-connector-java-5.1.46.jar!/:5.1.46]
  68. at com.mysql.jdbc.PreparedStatement.executeUpdateInternal(PreparedStatement.java:2013) ~[mysql-connector-java-5.1.46.jar!/:5.1.46]
  69. at com.mysql.jdbc.PreparedStatement.executeLargeUpdate(PreparedStatement.java:5104) ~[mysql-connector-java-5.1.46.jar!/:5.1.46]
  70. at com.mysql.jdbc.PreparedStatement.executeUpdate(PreparedStatement.java:1998) ~[mysql-connector-java-5.1.46.jar!/:5.1.46]
  71. at com.zaxxer.hikari.pool.ProxyPreparedStatement.executeUpdate(ProxyPreparedStatement.java:61) ~[HikariCP-2.7.8.jar!/:na]
  72. at com.zaxxer.hikari.pool.HikariProxyPreparedStatement.executeUpdate(HikariProxyPreparedStatement.java) ~[HikariCP-2.7.8.jar!/:na]
  73. at org.springframework.jdbc.core.JdbcTemplate.lambda$update$0(JdbcTemplate.java:855) ~[spring-jdbc-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  74. at org.springframework.jdbc.core.JdbcTemplate.execute(JdbcTemplate.java:605) ~[spring-jdbc-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  75. ... 34 common frames omitted
  76.  
  77. 2019-04-11 08:34:48.863 INFO 6052 --- [ntainer#0-0-C-1] k.d.KafkaConnectDebeziumMessagesReceiver : Recieved Add Product Specification Locale Message:[{"after": null, "patch": "{\"$v\" : 1,\"$set\" : {\"en\" : { }}}", "source": {"version": "0.8.3.Final", "name": "burraq", "rs": "rs0", "ns": "product-specifications-service.specifications", "sec": 1554986088, "ord": 7, "h": -3532257099457466170, "initsync": false}, "op": "u", "ts_ms": 1554986088653}]
  78. 2019-04-11 08:34:48.863 INFO 6052 --- [ntainer#0-0-C-1] k.d.KafkaConnectDebeziumMessagesReceiver : Received Debezium's Add Product Locale Command from pspecs for key: [292c431c-5279-46a0-ad94-a6d533445306] with data: [{"after": null, "patch": "{\"$v\" : 1,\"$set\" : {\"en\" : { }}}", "source": {"version": "0.8.3.Final", "name": "burraq", "rs": "rs0", "ns": "product-specifications-service.specifications", "sec": 1554986088, "ord": 7, "h": -3532257099457466170, "initsync": false}, "op": "u", "ts_ms": 1554986088653}]
  79. 2019-04-11 08:34:48.863 INFO 6052 --- [ntainer#0-0-C-1] k.d.KafkaConnectDebeziumMessagesReceiver : Recieved Add Product Specification Locale Message:[{"after": null, "patch": "{\"$v\" : 1,\"$set\" : {\"en_US\" : { }}}", "source": {"version": "0.8.3.Final", "name": "burraq", "rs": "rs0", "ns": "product-specifications-service.specifications", "sec": 1554986088, "ord": 15, "h": -7771656644501516428, "initsync": false}, "op": "u", "ts_ms": 1554986088664}]
  80. 2019-04-11 08:34:48.864 INFO 6052 --- [ntainer#0-0-C-1] k.d.KafkaConnectDebeziumMessagesReceiver : Received Debezium's Add Product Locale Command from pspecs for key: [292c431c-5279-46a0-ad94-a6d533445306] with data: [{"after": null, "patch": "{\"$v\" : 1,\"$set\" : {\"en_US\" : { }}}", "source": {"version": "0.8.3.Final", "name": "burraq", "rs": "rs0", "ns": "product-specifications-service.specifications", "sec": 1554986088, "ord": 15, "h": -7771656644501516428, "initsync": false}, "op": "u", "ts_ms": 1554986088664}]
  81. 2019-04-11 08:34:48.868 ERROR 6052 --- [ntainer#0-0-C-1] o.s.kafka.listener.LoggingErrorHandler : Error while processing: ConsumerRecord(topic = burraq.product-specifications-service.specifications, partition = 0, offset = 3272, CreateTime = 1554986088770, serialized key size = 44, serialized value size = 142, headers = RecordHeaders(headers = [], isReadOnly = false), key = {"id": "\"292c431c-5279-46a0-ad94-a6d533445306\""}, value = {"after": null, "patch": "{\"$v\" : 1,\"$set\" : {\"en_US\" : { }}}", "source": {"version": "0.8.3.Final", "name": "burraq", "rs": "rs0", "ns": "product-specifications-service.specifications", "sec": 1554986088, "ord": 15, "h": -7771656644501516428, "initsync": false}, "op": "u", "ts_ms": 1554986088664})
  82.  
  83. org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public 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.NullPointerException
  84. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:267) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  85. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:80) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  86. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  87. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1066) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  88. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1046) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  89. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:997) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  90. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:866) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  91. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:724) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  92. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_91]
  93. at java.util.concurrent.FutureTask.run(FutureTask.java:266) [na:1.8.0_91]
  94. at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]
  95. Caused by: java.lang.NullPointerException: null
  96. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl.createProduct(BasicSpecificationRepositoryImpl.java:306) ~[classes!/:1.0.0-SNAPSHOT]
  97. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl$$FastClassBySpringCGLIB$$f53e9f0a.invoke(<generated>) ~[classes!/:1.0.0-SNAPSHOT]
  98. at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204) ~[spring-core-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  99. at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:747) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  100. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  101. at org.springframework.dao.support.PersistenceExceptionTranslationInterceptor.invoke(PersistenceExceptionTranslationInterceptor.java:139) ~[spring-tx-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  102. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:185) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  103. at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:689) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  104. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl$$EnhancerBySpringCGLIB$$a65cf6c4.createProduct(<generated>) ~[classes!/:1.0.0-SNAPSHOT]
  105. at com.etilize.burraq.cda.specification.SpecificationServiceImpl.addLocale(SpecificationServiceImpl.java:233) ~[classes!/:1.0.0-SNAPSHOT]
  106. at com.etilize.burraq.cda.kafka.debezium.KafkaConnectDebeziumMessagesReceiver.processUpdateSpecificationAttributeCommandForAddLocale(KafkaConnectDebeziumMessagesReceiver.java:154) ~[classes!/:1.0.0-SNAPSHOT]
  107. at com.etilize.burraq.cda.kafka.debezium.KafkaConnectDebeziumMessagesReceiver.processProductSpecificationUpdates(KafkaConnectDebeziumMessagesReceiver.java:112) ~[classes!/:1.0.0-SNAPSHOT]
  108. at sun.reflect.GeneratedMethodAccessor142.invoke(Unknown Source) ~[na:na]
  109. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_91]
  110. at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_91]
  111. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:181) ~[spring-messaging-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  112. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:114) ~[spring-messaging-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  113. at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  114. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:248) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  115. ... 10 common frames omitted
  116.  
  117. 2019-04-11 08:34:48.869 INFO 6052 --- [ntainer#0-0-C-1] k.d.KafkaConnectDebeziumMessagesReceiver : Recieved Add Product Specification Locale Message:[{"after": null, "patch": "{\"$v\" : 1,\"$set\" : {\"es_US\" : { }}}", "source": {"version": "0.8.3.Final", "name": "burraq", "rs": "rs0", "ns": "product-specifications-service.specifications", "sec": 1554986088, "ord": 16, "h": -6548588114826368654, "initsync": false}, "op": "u", "ts_ms": 1554986088676}]
  118. 2019-04-11 08:34:48.869 INFO 6052 --- [ntainer#0-0-C-1] k.d.KafkaConnectDebeziumMessagesReceiver : Received Debezium's Add Product Locale Command from pspecs for key: [292c431c-5279-46a0-ad94-a6d533445306] with data: [{"after": null, "patch": "{\"$v\" : 1,\"$set\" : {\"es_US\" : { }}}", "source": {"version": "0.8.3.Final", "name": "burraq", "rs": "rs0", "ns": "product-specifications-service.specifications", "sec": 1554986088, "ord": 16, "h": -6548588114826368654, "initsync": false}, "op": "u", "ts_ms": 1554986088676}]
  119. 2019-04-11 08:34:48.874 ERROR 6052 --- [ntainer#0-0-C-1] o.s.kafka.listener.LoggingErrorHandler : Error while processing: ConsumerRecord(topic = burraq.product-specifications-service.specifications, partition = 0, offset = 3273, CreateTime = 1554986088770, serialized key size = 44, serialized value size = 142, headers = RecordHeaders(headers = [], isReadOnly = false), key = {"id": "\"292c431c-5279-46a0-ad94-a6d533445306\""}, value = {"after": null, "patch": "{\"$v\" : 1,\"$set\" : {\"es_US\" : { }}}", "source": {"version": "0.8.3.Final", "name": "burraq", "rs": "rs0", "ns": "product-specifications-service.specifications", "sec": 1554986088, "ord": 16, "h": -6548588114826368654, "initsync": false}, "op": "u", "ts_ms": 1554986088676})
  120.  
  121. org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public 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.NullPointerException
  122. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:267) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  123. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:80) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  124. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  125. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1066) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  126. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1046) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  127. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:997) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  128. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:866) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  129. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:724) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  130. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_91]
  131. at java.util.concurrent.FutureTask.run(FutureTask.java:266) [na:1.8.0_91]
  132. at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]
  133. Caused by: java.lang.NullPointerException: null
  134. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl.createProduct(BasicSpecificationRepositoryImpl.java:306) ~[classes!/:1.0.0-SNAPSHOT]
  135. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl$$FastClassBySpringCGLIB$$f53e9f0a.invoke(<generated>) ~[classes!/:1.0.0-SNAPSHOT]
  136. at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204) ~[spring-core-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  137. at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:747) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  138. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  139. at org.springframework.dao.support.PersistenceExceptionTranslationInterceptor.invoke(PersistenceExceptionTranslationInterceptor.java:139) ~[spring-tx-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  140. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:185) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  141. at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:689) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  142. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl$$EnhancerBySpringCGLIB$$a65cf6c4.createProduct(<generated>) ~[classes!/:1.0.0-SNAPSHOT]
  143. at com.etilize.burraq.cda.specification.SpecificationServiceImpl.addLocale(SpecificationServiceImpl.java:233) ~[classes!/:1.0.0-SNAPSHOT]
  144. at com.etilize.burraq.cda.kafka.debezium.KafkaConnectDebeziumMessagesReceiver.processUpdateSpecificationAttributeCommandForAddLocale(KafkaConnectDebeziumMessagesReceiver.java:154) ~[classes!/:1.0.0-SNAPSHOT]
  145. at com.etilize.burraq.cda.kafka.debezium.KafkaConnectDebeziumMessagesReceiver.processProductSpecificationUpdates(KafkaConnectDebeziumMessagesReceiver.java:112) ~[classes!/:1.0.0-SNAPSHOT]
  146. at sun.reflect.GeneratedMethodAccessor142.invoke(Unknown Source) ~[na:na]
  147. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_91]
  148. at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_91]
  149. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:181) ~[spring-messaging-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  150. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:114) ~[spring-messaging-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  151. at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  152. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:248) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  153. ... 10 common frames omitted
  154.  
  155. 2019-04-11 08:34:48.875 INFO 6052 --- [ntainer#0-0-C-1] k.d.KafkaConnectDebeziumMessagesReceiver : Recieved Update Product Specification Message:[{"after": null, "patch": "{\"$v\" : 1,\"$set\" : {\"en.5cab65f2fcd96b4b222489ea\" : {\"value\" : \"TestProduct-50015\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088632},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"},\"en.5cab65f3fcd96b4b222489f6\" : {\"value\" : \"Greatland\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088632},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}}}", "source": {"version": "0.8.3.Final", "name": "burraq", "rs": "rs0", "ns": "product-specifications-service.specifications", "sec": 1554986088, "ord": 17, "h": -8373354690844494553, "initsync": false}, "op": "u", "ts_ms": 1554986088688}]
  156. 2019-04-11 08:34:48.875 INFO 6052 --- [ntainer#0-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-50015\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088632},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"},\"en.5cab65f3fcd96b4b222489f6\" : {\"value\" : \"Greatland\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088632},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}}}", "source": {"version": "0.8.3.Final", "name": "burraq", "rs": "rs0", "ns": "product-specifications-service.specifications", "sec": 1554986088, "ord": 17, "h": -8373354690844494553, "initsync": false}, "op": "u", "ts_ms": 1554986088688}]
  157. 2019-04-11 08:34:48.888 INFO 6052 --- [ntainer#0-0-C-1] c.e.b.c.s.SpecificationServiceImpl : 5cab65f2fcd96b4b222489ea
  158. 2019-04-11 08:34:48.888 INFO 6052 --- [ntainer#0-0-C-1] c.e.b.c.s.SpecificationServiceImpl : com.etilize.burraq.cda.taxonomy.mapping.BurraqCategoryTaxonomies@30d6b587
  159. 2019-04-11 08:34:48.888 INFO 6052 --- [ntainer#0-0-C-1] c.e.b.c.s.SpecificationServiceImpl : 11798
  160. 2019-04-11 08:34:48.893 INFO 6052 --- [ntainer#0-0-C-1] e.b.c.s.BasicSpecificationRepositoryImpl : selectProductId: BurraqProductId292c431c-5279-46a0-ad94-a6d533445306 MarketId:16 LanguageId:17
  161. 2019-04-11 08:34:48.896 ERROR 6052 --- [ntainer#0-0-C-1] o.s.kafka.listener.LoggingErrorHandler : Error while processing: ConsumerRecord(topic = burraq.product-specifications-service.specifications, partition = 0, offset = 3274, CreateTime = 1554986088770, serialized key size = 44, serialized value size = 597, headers = RecordHeaders(headers = [], isReadOnly = false), key = {"id": "\"292c431c-5279-46a0-ad94-a6d533445306\""}, value = {"after": null, "patch": "{\"$v\" : 1,\"$set\" : {\"en.5cab65f2fcd96b4b222489ea\" : {\"value\" : \"TestProduct-50015\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088632},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"},\"en.5cab65f3fcd96b4b222489f6\" : {\"value\" : \"Greatland\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088632},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}}}", "source": {"version": "0.8.3.Final", "name": "burraq", "rs": "rs0", "ns": "product-specifications-service.specifications", "sec": 1554986088, "ord": 17, "h": -8373354690844494553, "initsync": false}, "op": "u", "ts_ms": 1554986088688})
  162.  
  163. org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public 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
  164. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:267) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  165. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:80) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  166. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  167. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1066) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  168. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1046) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  169. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:997) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  170. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:866) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  171. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:724) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  172. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_91]
  173. at java.util.concurrent.FutureTask.run(FutureTask.java:266) [na:1.8.0_91]
  174. at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]
  175. Caused by: java.lang.IndexOutOfBoundsException: Index: 0, Size: 0
  176. at java.util.ArrayList.rangeCheck(ArrayList.java:653) ~[na:1.8.0_91]
  177. at java.util.ArrayList.get(ArrayList.java:429) ~[na:1.8.0_91]
  178. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl.selectProductId(BasicSpecificationRepositoryImpl.java:597) ~[classes!/:1.0.0-SNAPSHOT]
  179. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl.saveProductParameter(BasicSpecificationRepositoryImpl.java:572) ~[classes!/:1.0.0-SNAPSHOT]
  180. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl$$FastClassBySpringCGLIB$$f53e9f0a.invoke(<generated>) ~[classes!/:1.0.0-SNAPSHOT]
  181. at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204) ~[spring-core-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  182. at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:747) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  183. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  184. at org.springframework.dao.support.PersistenceExceptionTranslationInterceptor.invoke(PersistenceExceptionTranslationInterceptor.java:139) ~[spring-tx-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  185. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:185) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  186. at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:689) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  187. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl$$EnhancerBySpringCGLIB$$a65cf6c4.saveProductParameter(<generated>) ~[classes!/:1.0.0-SNAPSHOT]
  188. at com.etilize.burraq.cda.specification.SpecificationServiceImpl.saveSpecsToCMS(SpecificationServiceImpl.java:487) ~[classes!/:1.0.0-SNAPSHOT]
  189. at com.etilize.burraq.cda.specification.SpecificationServiceImpl.lambda$updateSpecifications$0(SpecificationServiceImpl.java:344) ~[classes!/:1.0.0-SNAPSHOT]
  190. at java.util.HashMap$EntrySet.forEach(HashMap.java:1035) ~[na:1.8.0_91]
  191. at com.etilize.burraq.cda.specification.SpecificationServiceImpl.updateSpecifications(SpecificationServiceImpl.java:321) ~[classes!/:1.0.0-SNAPSHOT]
  192. at com.etilize.burraq.cda.kafka.debezium.KafkaConnectDebeziumMessagesReceiver.processUpdateSpecificationAttributeCommand(KafkaConnectDebeziumMessagesReceiver.java:165) ~[classes!/:1.0.0-SNAPSHOT]
  193. at com.etilize.burraq.cda.kafka.debezium.KafkaConnectDebeziumMessagesReceiver.processProductSpecificationUpdates(KafkaConnectDebeziumMessagesReceiver.java:119) ~[classes!/:1.0.0-SNAPSHOT]
  194. at sun.reflect.GeneratedMethodAccessor142.invoke(Unknown Source) ~[na:na]
  195. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_91]
  196. at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_91]
  197. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:181) ~[spring-messaging-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  198. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:114) ~[spring-messaging-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  199. at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  200. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:248) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  201. ... 10 common frames omitted
  202.  
  203. 2019-04-11 08:34:48.896 INFO 6052 --- [ntainer#1-0-C-1] .c.k.n.KafkaConnectNeo4jMessagesReceiver : Received message from barcode-service [GenericMessage [payload=barcode-service400Barcode is not valid for Type=UPC,Code=88698332061,CustomerId=5c7e0598fe19fe3ad727baff, error:Invalid Barcode 88698332061, it's having length other than 8, 12, 13 or 14., Barcode is not valid for Type=EAN,Code=88698332061,CustomerId=5c7e0598fe19fe3ad727baff, error:Invalid Barcode 88698332061, it's having length other than 8, 12, 13 or 14., Barcode is not valid for Type=GTIN,Code=88698332061,CustomerId=5c7e0598fe19fe3ad727baff, error:Invalid Barcode 88698332061, it's having length other than 8, 12, 13 or 14.Pcms_data_integration_user@etilizepak.com����ZH292c431c-5279-46a0-ad94-a6d533445306token 99, headers={kafka_offset=1433, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@41de3367, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=null, kafka_receivedPartitionId=0, contentType=application/vnd.addbarcodefailedevent.v2+avro, kafka_receivedTopic=barcode-service, kafka_receivedTimestamp=1554986088894}]]
  204. 2019-04-11 08:34:48.897 ERROR 6052 --- [ntainer#1-0-C-1] o.s.kafka.listener.LoggingErrorHandler : Error while processing: ConsumerRecord(topic = barcode-service, partition = 0, offset = 1433, CreateTime = 1554986088894, serialized key size = -1, serialized value size = 627, headers = RecordHeaders(headers = [RecordHeader(key = contentType, value = [34, 97, 112, 112, 108, 105, 99, 97, 116, 105, 111, 110, 47, 118, 110, 100, 46, 97, 100, 100, 98, 97, 114, 99, 111, 100, 101, 102, 97, 105, 108, 101, 100, 101, 118, 101, 110, 116, 46, 118, 50, 43, 97, 118, 114, 111, 34]), RecordHeader(key = spring_json_header_types, value = [123, 34, 99, 111, 110, 116, 101, 110, 116, 84, 121, 112, 101, 34, 58, 34, 106, 97, 118, 97, 46, 108, 97, 110, 103, 46, 83, 116, 114, 105, 110, 103, 34, 125])], isReadOnly = false), key = null, value = barcode-service400Barcode is not valid for Type=UPC,Code=88698332061,CustomerId=5c7e0598fe19fe3ad727baff, error:Invalid Barcode 88698332061, it's having length other than 8, 12, 13 or 14., Barcode is not valid for Type=EAN,Code=88698332061,CustomerId=5c7e0598fe19fe3ad727baff, error:Invalid Barcode 88698332061, it's having length other than 8, 12, 13 or 14., Barcode is not valid for Type=GTIN,Code=88698332061,CustomerId=5c7e0598fe19fe3ad727baff, error:Invalid Barcode 88698332061, it's having length other than 8, 12, 13 or 14.Pcms_data_integration_user@etilizepak.com����ZH292c431c-5279-46a0-ad94-a6d533445306token 99)
  205.  
  206. org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public void com.etilize.burraq.cda.kafka.neo4j.KafkaConnectNeo4jMessagesReceiver.processBarcodeMessages(org.springframework.messaging.Message<java.lang.String>)' threw exception; nested exception is com.google.gson.JsonSyntaxException: com.google.gson.stream.MalformedJsonException: Use JsonReader.setLenient(true) to accept malformed JSON at line 1 column 32 path $
  207. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:267) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  208. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:80) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  209. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  210. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1066) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  211. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1046) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  212. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:997) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  213. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:866) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  214. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:724) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  215. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_91]
  216. at java.util.concurrent.FutureTask.run(FutureTask.java:266) [na:1.8.0_91]
  217. at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]
  218. Caused by: com.google.gson.JsonSyntaxException: com.google.gson.stream.MalformedJsonException: Use JsonReader.setLenient(true) to accept malformed JSON at line 1 column 32 path $
  219. at com.google.gson.JsonParser.parse(JsonParser.java:65) ~[gson-2.8.2.jar!/:na]
  220. at com.google.gson.JsonParser.parse(JsonParser.java:45) ~[gson-2.8.2.jar!/:na]
  221. at com.etilize.burraq.cda.kafka.neo4j.KafkaConnectNeo4jMessagesReceiver.processBarcodeMessages(KafkaConnectNeo4jMessagesReceiver.java:78) ~[classes!/:1.0.0-SNAPSHOT]
  222. at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.8.0_91]
  223. at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[na:1.8.0_91]
  224. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_91]
  225. at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_91]
  226. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:181) ~[spring-messaging-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  227. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:114) ~[spring-messaging-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  228. at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  229. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:248) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  230. ... 10 common frames omitted
  231. Caused by: com.google.gson.stream.MalformedJsonException: Use JsonReader.setLenient(true) to accept malformed JSON at line 1 column 32 path $
  232. at com.google.gson.stream.JsonReader.syntaxError(JsonReader.java:1568) ~[gson-2.8.2.jar!/:na]
  233. at com.google.gson.stream.JsonReader.checkLenient(JsonReader.java:1409) ~[gson-2.8.2.jar!/:na]
  234. at com.google.gson.stream.JsonReader.doPeek(JsonReader.java:542) ~[gson-2.8.2.jar!/:na]
  235. at com.google.gson.stream.JsonReader.peek(JsonReader.java:425) ~[gson-2.8.2.jar!/:na]
  236. at com.google.gson.JsonParser.parse(JsonParser.java:60) ~[gson-2.8.2.jar!/:na]
  237. ... 20 common frames omitted
  238.  
  239. 2019-04-11 08:34:49.260 INFO 6052 --- [ntainer#0-0-C-1] k.d.KafkaConnectDebeziumMessagesReceiver : Recieved Update Product Specification Message:[{"after": null, "patch": "{\"$v\" : 1,\"$set\" : {\"en.5cab65f3fcd96b4b222489f8\" : {\"value\" : {\"EXTRACTED\" : {\"unit\" : \"Hour\",\"value\" : 16.65},\"METRIC\" : {\"unit\" : \"Hour\",\"value\" : 16.65},\"BASE\" : {\"unit\" : \"Second\",\"value\" : 59940.0}},\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.UnitValue\"},\"en.5cab65f3fcd96b4b222489fb\" : [{\"value\" : \"Lithium Polymer (Li-Polymer)\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}, {\"value\" : \"Nickel Cadmium (NiCd)\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}, {\"value\" : \"Nickel\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}],\"en.5cab65f3fcd96b4b222489fc\" : {\"value\" : {\"EXTRACTED\" : {\"unit\" : \"Minute\",\"value\" : 120},\"METRIC\" : {\"unit\" : \"Hour\",\"value\" : 2.0},\"BASE\" : {\"unit\" : \"Second\",\"value\" : 7200.0}},\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.UnitValue\"},\"en.5cab65f5fcd96b4b222489ff\" : {\"value\" : \"Powered Shrub Shear\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"},\"en.5cab65f5fcd96b4b22248a00\" : [{\"value\" : \"Battery\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}, {\"value\" : \"AC Supply\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}],\"en.5cab65f5fcd96b4b22248a03\" : [{\"value\" : \"Malaysia\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}, {\"value\" : \"South America\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}],\"en.5cab65f6fcd96b4b22248a05\" : {\"value\" : {\"EXTRACTED\" : {\"unit\" : \"cm\",\"value\" : 65.25},\"IMPERIAL\" : {\"unit\" : \"\\\"\",\"value\" : 25.689},\"METRIC\" : {\"unit\" : \"cm\",\"value\" : 65.25},\"BASE\" : {\"unit\" : \"mm\",\"value\" : 652.5}},\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.UnitValue\"},\"en.5cab65f6fcd96b4b22248a07\" : {\"value\" : \"Yes\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"},\"en.5cab65f6fcd96b4b22248a08\" : {\"value\" : {\"EXTRACTED\" : {\"unit\" : \"cm\",\"value\" : 8.6},\"IMPERIAL\" : {\"unit\" : \"\\\"\",\"value\" : 3.386},\"METRIC\" : {\"unit\" : \"cm\",\"value\" : 8.6},\"BASE\" : {\"unit\" : \"mm\",\"value\" : 86.0}},\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.UnitValue\"},\"en.5cab65f6fcd96b4b22248a09\" : {\"value\" : {\"EXTRACTED\" : {\"unit\" : \"cm\",\"value\" : 18.2},\"IMPERIAL\" : {\"unit\" : \"\\\"\",\"value\" : 7.166},\"METRIC\" : {\"unit\" : \"cm\",\"value\" : 18.2},\"BASE\" : {\"unit\" : \"mm\",\"value\" : 182.0}},\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.UnitValue\"},\"en.5cab65f6fcd96b4b22248a0a\" : {\"value\" : \"<li>LED Lights™ and ®</li><li>Error Beeps</li><li>Tests Beeps</li><li>Test Lights</li>\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}}}", "source": {"version": "0.8.3.Final", "name": "burraq", "rs": "rs0", "ns": "product-specifications-service.specifications", "sec": 1554986088, "ord": 18, "h": -7386799354414719685, "initsync": false}, "op": "u", "ts_ms": 1554986088831}]
  240. 2019-04-11 08:34:49.261 INFO 6052 --- [ntainer#0-0-C-1] k.d.KafkaConnectDebeziumMessagesReceiver : Received Debezium's Update Producut Specifications Command from pspecs [{"after": null, "patch": "{\"$v\" : 1,\"$set\" : {\"en.5cab65f3fcd96b4b222489f8\" : {\"value\" : {\"EXTRACTED\" : {\"unit\" : \"Hour\",\"value\" : 16.65},\"METRIC\" : {\"unit\" : \"Hour\",\"value\" : 16.65},\"BASE\" : {\"unit\" : \"Second\",\"value\" : 59940.0}},\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.UnitValue\"},\"en.5cab65f3fcd96b4b222489fb\" : [{\"value\" : \"Lithium Polymer (Li-Polymer)\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}, {\"value\" : \"Nickel Cadmium (NiCd)\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}, {\"value\" : \"Nickel\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}],\"en.5cab65f3fcd96b4b222489fc\" : {\"value\" : {\"EXTRACTED\" : {\"unit\" : \"Minute\",\"value\" : 120},\"METRIC\" : {\"unit\" : \"Hour\",\"value\" : 2.0},\"BASE\" : {\"unit\" : \"Second\",\"value\" : 7200.0}},\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.UnitValue\"},\"en.5cab65f5fcd96b4b222489ff\" : {\"value\" : \"Powered Shrub Shear\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"},\"en.5cab65f5fcd96b4b22248a00\" : [{\"value\" : \"Battery\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}, {\"value\" : \"AC Supply\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}],\"en.5cab65f5fcd96b4b22248a03\" : [{\"value\" : \"Malaysia\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}, {\"value\" : \"South America\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}],\"en.5cab65f6fcd96b4b22248a05\" : {\"value\" : {\"EXTRACTED\" : {\"unit\" : \"cm\",\"value\" : 65.25},\"IMPERIAL\" : {\"unit\" : \"\\\"\",\"value\" : 25.689},\"METRIC\" : {\"unit\" : \"cm\",\"value\" : 65.25},\"BASE\" : {\"unit\" : \"mm\",\"value\" : 652.5}},\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.UnitValue\"},\"en.5cab65f6fcd96b4b22248a07\" : {\"value\" : \"Yes\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"},\"en.5cab65f6fcd96b4b22248a08\" : {\"value\" : {\"EXTRACTED\" : {\"unit\" : \"cm\",\"value\" : 8.6},\"IMPERIAL\" : {\"unit\" : \"\\\"\",\"value\" : 3.386},\"METRIC\" : {\"unit\" : \"cm\",\"value\" : 8.6},\"BASE\" : {\"unit\" : \"mm\",\"value\" : 86.0}},\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.UnitValue\"},\"en.5cab65f6fcd96b4b22248a09\" : {\"value\" : {\"EXTRACTED\" : {\"unit\" : \"cm\",\"value\" : 18.2},\"IMPERIAL\" : {\"unit\" : \"\\\"\",\"value\" : 7.166},\"METRIC\" : {\"unit\" : \"cm\",\"value\" : 18.2},\"BASE\" : {\"unit\" : \"mm\",\"value\" : 182.0}},\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.UnitValue\"},\"en.5cab65f6fcd96b4b22248a0a\" : {\"value\" : \"<li>LED Lights™ and ®</li><li>Error Beeps</li><li>Tests Beeps</li><li>Test Lights</li>\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}}}", "source": {"version": "0.8.3.Final", "name": "burraq", "rs": "rs0", "ns": "product-specifications-service.specifications", "sec": 1554986088, "ord": 18, "h": -7386799354414719685, "initsync": false}, "op": "u", "ts_ms": 1554986088831}]
  241. 2019-04-11 08:34:49.276 INFO 6052 --- [ntainer#0-0-C-1] c.e.b.c.s.SpecificationServiceImpl : 5cab65f5fcd96b4b22248a00
  242. 2019-04-11 08:34:49.276 INFO 6052 --- [ntainer#0-0-C-1] c.e.b.c.s.SpecificationServiceImpl : com.etilize.burraq.cda.taxonomy.mapping.BurraqCategoryTaxonomies@3d672ad3
  243. 2019-04-11 08:34:49.277 INFO 6052 --- [ntainer#0-0-C-1] c.e.b.c.s.SpecificationServiceImpl : 10992
  244. 2019-04-11 08:34:49.280 INFO 6052 --- [ntainer#0-0-C-1] e.b.c.s.BasicSpecificationRepositoryImpl : selectProductId: BurraqProductId292c431c-5279-46a0-ad94-a6d533445306 MarketId:16 LanguageId:17
  245. 2019-04-11 08:34:49.283 ERROR 6052 --- [ntainer#0-0-C-1] o.s.kafka.listener.LoggingErrorHandler : Error while processing: ConsumerRecord(topic = burraq.product-specifications-service.specifications, partition = 0, offset = 3275, CreateTime = 1554986089271, serialized key size = 44, serialized value size = 4340, headers = RecordHeaders(headers = [], isReadOnly = false), key = {"id": "\"292c431c-5279-46a0-ad94-a6d533445306\""}, value = {"after": null, "patch": "{\"$v\" : 1,\"$set\" : {\"en.5cab65f3fcd96b4b222489f8\" : {\"value\" : {\"EXTRACTED\" : {\"unit\" : \"Hour\",\"value\" : 16.65},\"METRIC\" : {\"unit\" : \"Hour\",\"value\" : 16.65},\"BASE\" : {\"unit\" : \"Second\",\"value\" : 59940.0}},\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.UnitValue\"},\"en.5cab65f3fcd96b4b222489fb\" : [{\"value\" : \"Lithium Polymer (Li-Polymer)\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}, {\"value\" : \"Nickel Cadmium (NiCd)\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}, {\"value\" : \"Nickel\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}],\"en.5cab65f3fcd96b4b222489fc\" : {\"value\" : {\"EXTRACTED\" : {\"unit\" : \"Minute\",\"value\" : 120},\"METRIC\" : {\"unit\" : \"Hour\",\"value\" : 2.0},\"BASE\" : {\"unit\" : \"Second\",\"value\" : 7200.0}},\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.UnitValue\"},\"en.5cab65f5fcd96b4b222489ff\" : {\"value\" : \"Powered Shrub Shear\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"},\"en.5cab65f5fcd96b4b22248a00\" : [{\"value\" : \"Battery\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}, {\"value\" : \"AC Supply\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}],\"en.5cab65f5fcd96b4b22248a03\" : [{\"value\" : \"Malaysia\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}, {\"value\" : \"South America\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}],\"en.5cab65f6fcd96b4b22248a05\" : {\"value\" : {\"EXTRACTED\" : {\"unit\" : \"cm\",\"value\" : 65.25},\"IMPERIAL\" : {\"unit\" : \"\\\"\",\"value\" : 25.689},\"METRIC\" : {\"unit\" : \"cm\",\"value\" : 65.25},\"BASE\" : {\"unit\" : \"mm\",\"value\" : 652.5}},\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.UnitValue\"},\"en.5cab65f6fcd96b4b22248a07\" : {\"value\" : \"Yes\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"},\"en.5cab65f6fcd96b4b22248a08\" : {\"value\" : {\"EXTRACTED\" : {\"unit\" : \"cm\",\"value\" : 8.6},\"IMPERIAL\" : {\"unit\" : \"\\\"\",\"value\" : 3.386},\"METRIC\" : {\"unit\" : \"cm\",\"value\" : 8.6},\"BASE\" : {\"unit\" : \"mm\",\"value\" : 86.0}},\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.UnitValue\"},\"en.5cab65f6fcd96b4b22248a09\" : {\"value\" : {\"EXTRACTED\" : {\"unit\" : \"cm\",\"value\" : 18.2},\"IMPERIAL\" : {\"unit\" : \"\\\"\",\"value\" : 7.166},\"METRIC\" : {\"unit\" : \"cm\",\"value\" : 18.2},\"BASE\" : {\"unit\" : \"mm\",\"value\" : 182.0}},\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.UnitValue\"},\"en.5cab65f6fcd96b4b22248a0a\" : {\"value\" : \"<li>LED Lights™ and ®</li><li>Error Beeps</li><li>Tests Beeps</li><li>Test Lights</li>\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1554986088782},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}}}", "source": {"version": "0.8.3.Final", "name": "burraq", "rs": "rs0", "ns": "product-specifications-service.specifications", "sec": 1554986088, "ord": 18, "h": -7386799354414719685, "initsync": false}, "op": "u", "ts_ms": 1554986088831})
  246.  
  247. org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public 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
  248. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:267) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  249. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:80) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  250. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  251. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1066) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  252. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1046) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  253. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:997) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  254. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:866) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  255. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:724) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  256. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_91]
  257. at java.util.concurrent.FutureTask.run(FutureTask.java:266) [na:1.8.0_91]
  258. at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]
  259. Caused by: java.lang.IndexOutOfBoundsException: Index: 0, Size: 0
  260. at java.util.ArrayList.rangeCheck(ArrayList.java:653) ~[na:1.8.0_91]
  261. at java.util.ArrayList.get(ArrayList.java:429) ~[na:1.8.0_91]
  262. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl.selectProductId(BasicSpecificationRepositoryImpl.java:597) ~[classes!/:1.0.0-SNAPSHOT]
  263. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl.saveProductParameter(BasicSpecificationRepositoryImpl.java:572) ~[classes!/:1.0.0-SNAPSHOT]
  264. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl$$FastClassBySpringCGLIB$$f53e9f0a.invoke(<generated>) ~[classes!/:1.0.0-SNAPSHOT]
  265. at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204) ~[spring-core-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  266. at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:747) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  267. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  268. at org.springframework.dao.support.PersistenceExceptionTranslationInterceptor.invoke(PersistenceExceptionTranslationInterceptor.java:139) ~[spring-tx-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  269. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:185) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  270. at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:689) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  271. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl$$EnhancerBySpringCGLIB$$a65cf6c4.saveProductParameter(<generated>) ~[classes!/:1.0.0-SNAPSHOT]
  272. at com.etilize.burraq.cda.specification.SpecificationServiceImpl.saveSpecsToCMS(SpecificationServiceImpl.java:487) ~[classes!/:1.0.0-SNAPSHOT]
  273. at com.etilize.burraq.cda.specification.SpecificationServiceImpl.lambda$updateSpecifications$0(SpecificationServiceImpl.java:344) ~[classes!/:1.0.0-SNAPSHOT]
  274. at java.util.HashMap$EntrySet.forEach(HashMap.java:1035) ~[na:1.8.0_91]
  275. at com.etilize.burraq.cda.specification.SpecificationServiceImpl.updateSpecifications(SpecificationServiceImpl.java:321) ~[classes!/:1.0.0-SNAPSHOT]
  276. at com.etilize.burraq.cda.kafka.debezium.KafkaConnectDebeziumMessagesReceiver.processUpdateSpecificationAttributeCommand(KafkaConnectDebeziumMessagesReceiver.java:165) ~[classes!/:1.0.0-SNAPSHOT]
  277. at com.etilize.burraq.cda.kafka.debezium.KafkaConnectDebeziumMessagesReceiver.processProductSpecificationUpdates(KafkaConnectDebeziumMessagesReceiver.java:119) ~[classes!/:1.0.0-SNAPSHOT]
  278. at sun.reflect.GeneratedMethodAccessor142.invoke(Unknown Source) ~[na:na]
  279. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_91]
  280. at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_91]
  281. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:181) ~[spring-messaging-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  282. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:114) ~[spring-messaging-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  283. at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  284. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:248) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  285. ... 10 common frames omitted
  286.  
  287. 2019-04-11 08:34:49.658 INFO 6052 --- [ntainer#2-0-C-1] .c.k.n.KafkaConnectNeo4jMessagesReceiver : Received message from product-code-service [GenericMessage [payload={"payload":{"id":"2322907","before":null,"after":{"properties":{"productId":"292c431c-5279-46a0-ad94-a6d533445306"},"labels":["Product"]},"type":"node"},"meta":{"timestamp":1554986089642,"username":"neo4j","txId":976458,"txEventId":1,"txEventsCount":3,"operation":"created","source":{"hostname":"vmnode0018"}},"schema":{"properties":[],"constraints":null}}, headers={kafka_offset=912, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@33ebe09f, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=976459-1, kafka_receivedPartitionId=0, kafka_receivedTopic=product-code-service, kafka_receivedTimestamp=1554986089643}]]
  288. 2019-04-11 08:34:49.659 INFO 6052 --- [ntainer#1-0-C-1] .c.k.n.KafkaConnectNeo4jMessagesReceiver : Received message from barcode-service [GenericMessage [payload={"payload":{"id":"2322907","before":null,"after":{"properties":{"productId":"292c431c-5279-46a0-ad94-a6d533445306"},"labels":["Product"]},"type":"node"},"meta":{"timestamp":1554986089642,"username":"neo4j","txId":976458,"txEventId":1,"txEventsCount":3,"operation":"created","source":{"hostname":"vmnode0018"}},"schema":{"properties":[],"constraints":null}}, headers={kafka_offset=1434, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@41de3367, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=976459-1, kafka_receivedPartitionId=0, kafka_receivedTopic=barcode-service, kafka_receivedTimestamp=1554986089644}]]
  289. 2019-04-11 08:34:49.660 INFO 6052 --- [ntainer#2-0-C-1] .c.k.n.KafkaConnectNeo4jMessagesReceiver : Received message from product-code-service [GenericMessage [payload={"payload":{"id":"1623403","start":{"id":"2322907","labels":["Product"]},"end":{"id":"2322906","labels":["CustomerCode"]},"before":null,"after":{"properties":{"market":"US","code":"TestProductCode50015","productId":"292c431c-5279-46a0-ad94-a6d533445306","customerId":"5c7e0598fe19fe3ad727baff"}},"label":"IDENTIFIED_BY","type":"relationship"},"meta":{"timestamp":1554986089642,"username":"neo4j","txId":976458,"txEventId":2,"txEventsCount":3,"operation":"created","source":{"hostname":"vmnode0018"}},"schema":{"properties":[],"constraints":null}}, headers={kafka_offset=913, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@33ebe09f, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=976460-2, kafka_receivedPartitionId=0, kafka_receivedTopic=product-code-service, kafka_receivedTimestamp=1554986089644}]]
  290. 2019-04-11 08:34:49.660 INFO 6052 --- [ntainer#3-0-C-1] .c.k.n.KafkaConnectNeo4jMessagesReceiver : Received message from product-accessories-service [GenericMessage [payload={"payload":{"id":"2322907","before":null,"after":{"properties":{"productId":"292c431c-5279-46a0-ad94-a6d533445306"},"labels":["Product"]},"type":"node"},"meta":{"timestamp":1554986089642,"username":"neo4j","txId":976458,"txEventId":1,"txEventsCount":3,"operation":"created","source":{"hostname":"vmnode0018"}},"schema":{"properties":[],"constraints":null}}, headers={kafka_offset=446, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@64039612, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=976459-1, kafka_receivedPartitionId=0, kafka_receivedTopic=product-accessory-service, kafka_receivedTimestamp=1554986089644}]]
  291. 2019-04-11 08:34:49.728 INFO 6052 --- [ntainer#4-0-C-1] .c.k.r.KafkaConnectRedisMessagesReceiver : Received Product Specifications Status Message: [GenericMessage [payload={"key":"cHJvZHVjdF9zdGF0dXNlczoyOTJjNDMxYy01Mjc5LTQ2YTAtYWQ5NC1hNmQ1MzM0NDUzMDY=","field":"ZXNfVVM=","value":"UFVCTElTSEVE"}, headers={kafka_offset=3694, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@71e19f65, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=com.moilioncircle.redis.replicator.cmd.impl.HSetCommand, kafka_receivedPartitionId=0, kafka_receivedTopic=product-specifications-status-service, kafka_receivedTimestamp=1554986089741}]]
Add Comment
Please, Sign In to add comment
Public Pastes
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!