API tools faq
paste
Guest User

Untitled

a guest
Apr 12th, 2019
81
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 75.69 KB | None | 0 0
raw download clone embed print report
  1. 2019-04-12 06:17:56.323 INFO 8868 --- [ntainer#0-0-C-1] .c.k.r.KafkaConnectRedisMessagesReceiver : Received Product Media Status Service message: [GenericMessage [payload={"key":"cHJvZHVjdF9tZWRpYV9zdGF0dXNlczo0ZTdjYjA0Ni0yZjA3LTQzOTUtYTQ5YS0xMTYwMTEwZDJmYzI=","field":"ZW4=","value":"TkVX"}, headers={kafka_offset=2929, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@6cc85950, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=com.moilioncircle.redis.replicator.cmd.impl.HSetNxCommand, kafka_receivedPartitionId=0, kafka_receivedTopic=product-media-status-service, kafka_receivedTimestamp=1555064276339}]]
  2. 2019-04-12 06:17:56.327 INFO 8868 --- [ntainer#1-0-C-1] .c.k.r.KafkaConnectRedisMessagesReceiver : Received Product Specifications Status Message: [GenericMessage [payload={"key":"cHJvZHVjdF9zdGF0dXNlczo0ZTdjYjA0Ni0yZjA3LTQzOTUtYTQ5YS0xMTYwMTEwZDJmYzI=","field":"ZW4=","value":"TkVX"}, headers={kafka_offset=3998, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@1a6738ef, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=com.moilioncircle.redis.replicator.cmd.impl.HSetNxCommand, kafka_receivedPartitionId=0, kafka_receivedTopic=product-specifications-status-service, kafka_receivedTimestamp=1555064276342}]]
  3. 2019-04-12 06:17:56.331 INFO 8868 --- [ntainer#0-0-C-1] .c.k.r.KafkaConnectRedisMessagesReceiver : Received Product Media Status Service message: [GenericMessage [payload={"key":"cHJvZHVjdF9tZWRpYV9zdGF0dXNlczo0ZTdjYjA0Ni0yZjA3LTQzOTUtYTQ5YS0xMTYwMTEwZDJmYzI=","field":"ZW5fVVM=","value":"TkVX"}, headers={kafka_offset=2930, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@6cc85950, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=com.moilioncircle.redis.replicator.cmd.impl.HSetNxCommand, kafka_receivedPartitionId=0, kafka_receivedTopic=product-media-status-service, kafka_receivedTimestamp=1555064276346}]]
  4. 2019-04-12 06:17:56.334 INFO 8868 --- [ntainer#0-0-C-1] .c.k.r.KafkaConnectRedisMessagesReceiver : Received Product Media Status Service message: [GenericMessage [payload={"key":"cHJvZHVjdF9tZWRpYV9zdGF0dXNlczo0ZTdjYjA0Ni0yZjA3LTQzOTUtYTQ5YS0xMTYwMTEwZDJmYzI=","field":"ZXNfVVM=","value":"TkVX"}, headers={kafka_offset=2931, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@6cc85950, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=com.moilioncircle.redis.replicator.cmd.impl.HSetNxCommand, kafka_receivedPartitionId=0, kafka_receivedTopic=product-media-status-service, kafka_receivedTimestamp=1555064276351}]]
  5. 2019-04-12 06:17:56.339 INFO 8868 --- [ntainer#1-0-C-1] .c.k.r.KafkaConnectRedisMessagesReceiver : Received Product Specifications Status Message: [GenericMessage [payload={"key":"cHJvZHVjdF9zdGF0dXNlczo0ZTdjYjA0Ni0yZjA3LTQzOTUtYTQ5YS0xMTYwMTEwZDJmYzI=","field":"ZW5fVVM=","value":"TkVX"}, headers={kafka_offset=3999, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@1a6738ef, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=com.moilioncircle.redis.replicator.cmd.impl.HSetNxCommand, kafka_receivedPartitionId=0, kafka_receivedTopic=product-specifications-status-service, kafka_receivedTimestamp=1555064276353}]]
  6. 2019-04-12 06:17:56.344 INFO 8868 --- [ntainer#1-0-C-1] .c.k.r.KafkaConnectRedisMessagesReceiver : Received Product Specifications Status Message: [GenericMessage [payload={"key":"cHJvZHVjdF9zdGF0dXNlczo0ZTdjYjA0Ni0yZjA3LTQzOTUtYTQ5YS0xMTYwMTEwZDJmYzI=","field":"ZXNfVVM=","value":"TkVX"}, headers={kafka_offset=4000, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@1a6738ef, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=com.moilioncircle.redis.replicator.cmd.impl.HSetNxCommand, kafka_receivedPartitionId=0, kafka_receivedTopic=product-specifications-status-service, kafka_receivedTimestamp=1555064276358}]]
  7. 2019-04-12 06:17:56.753 INFO 8868 --- [ntainer#3-0-C-1] k.d.KafkaConnectDebeziumMessagesReceiver : Received Debezium's AssociateCategoryCommand pspecs for key: [ConsumerRecord(topic = burraq.product-specifications-service.specifications, partition = 0, offset = 3809, CreateTime = 1555064276770, serialized key size = 44, serialized value size = 306, headers = RecordHeaders(headers = [], isReadOnly = false), key = {"id": "\"4e7cb046-2f07-4395-a49a-1160110d2fc2\""}, value = {"after": "{\"_id\" : \"4e7cb046-2f07-4395-a49a-1160110d2fc2\",\"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": 1555064276, "ord": 3, "h": -1329542159202266557, "initsync": false}, "op": "c", "ts_ms": 1555064276273})] with data: [{"after": "{\"_id\" : \"4e7cb046-2f07-4395-a49a-1160110d2fc2\",\"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": 1555064276, "ord": 3, "h": -1329542159202266557, "initsync": false}, "op": "c", "ts_ms": 1555064276273}]
  8. 2019-04-12 06:17:56.773 INFO 8868 --- [ntainer#3-0-C-1] e.b.c.s.BasicSpecificationRepositoryImpl : >> createDataSource generated Id = 1392950545
  9. 2019-04-12 06:17:56.786 INFO 8868 --- [ntainer#3-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]
  10. 2019-04-12 06:17:56.885 INFO 8868 --- [ntainer#3-0-C-1] o.s.jdbc.support.SQLErrorCodesFactory : SQLErrorCodes loaded: [DB2, Derby, H2, HDB, HSQL, Informix, MS-SQL, MySQL, Oracle, PostgreSQL, Sybase]
  11. 2019-04-12 06:17:56.891 ERROR 8868 --- [ntainer#3-0-C-1] o.s.kafka.listener.LoggingErrorHandler : Error while processing: ConsumerRecord(topic = burraq.product-specifications-service.specifications, partition = 0, offset = 3809, CreateTime = 1555064276770, serialized key size = 44, serialized value size = 306, headers = RecordHeaders(headers = [], isReadOnly = false), key = {"id": "\"4e7cb046-2f07-4395-a49a-1160110d2fc2\""}, value = {"after": "{\"_id\" : \"4e7cb046-2f07-4395-a49a-1160110d2fc2\",\"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": 1555064276, "ord": 3, "h": -1329542159202266557, "initsync": false}, "op": "c", "ts_ms": 1555064276273})
  12.  
  13. 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 org.springframework.dao.DuplicateKeyException: PreparedStatementCallback; SQL [ insert into DataSourceproduct (datasourceproductid, productid, datasourceid, datasourceproductcode,insertdate,updatedate,insertedbyid,updatedbyid, isactive) values (?,?,?,?,now(),now(),?,?,1) Duplicate entry '1392950545' for key 'PRIMARY'; nested exception is com.mysql.jdbc.exceptions.jdbc4.MySQLIntegrityConstraintViolationException: Duplicate entry '1392950545' for key 'PRIMARY'
  14. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:267) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  15. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:80) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  16. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  17. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1066) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  18. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1046) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  19. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:997) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  20. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:866) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  21. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:724) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  22. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_91]
  23. at java.util.concurrent.FutureTask.run(FutureTask.java:266) [na:1.8.0_91]
  24. at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]
  25. 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 '1392950545' for key 'PRIMARY'; nested exception is com.mysql.jdbc.exceptions.jdbc4.MySQLIntegrityConstraintViolationException: Duplicate entry '1392950545' for key 'PRIMARY'
  26. at org.springframework.jdbc.support.SQLErrorCodeSQLExceptionTranslator.doTranslate(SQLErrorCodeSQLExceptionTranslator.java:242) ~[spring-jdbc-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  27. at org.springframework.jdbc.support.AbstractFallbackSQLExceptionTranslator.translate(AbstractFallbackSQLExceptionTranslator.java:72) ~[spring-jdbc-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  28. at org.springframework.jdbc.core.JdbcTemplate.translateException(JdbcTemplate.java:1402) ~[spring-jdbc-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  29. at org.springframework.jdbc.core.JdbcTemplate.execute(JdbcTemplate.java:620) ~[spring-jdbc-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  30. at org.springframework.jdbc.core.JdbcTemplate.update(JdbcTemplate.java:850) ~[spring-jdbc-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  31. at org.springframework.jdbc.core.JdbcTemplate.update(JdbcTemplate.java:905) ~[spring-jdbc-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  32. at org.springframework.jdbc.core.JdbcTemplate.update(JdbcTemplate.java:915) ~[spring-jdbc-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  33. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl.execute(BasicSpecificationRepositoryImpl.java:430) ~[classes!/:1.0.0-SNAPSHOT]
  34. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl.createDataSource(BasicSpecificationRepositoryImpl.java:347) ~[classes!/:1.0.0-SNAPSHOT]
  35. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl.createProduct(BasicSpecificationRepositoryImpl.java:323) ~[classes!/:1.0.0-SNAPSHOT]
  36. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl$$FastClassBySpringCGLIB$$f53e9f0a.invoke(<generated>) ~[classes!/:1.0.0-SNAPSHOT]
  37. at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204) ~[spring-core-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  38. at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:747) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  39. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  40. at org.springframework.dao.support.PersistenceExceptionTranslationInterceptor.invoke(PersistenceExceptionTranslationInterceptor.java:139) ~[spring-tx-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  41. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:185) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  42. at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:689) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  43. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl$$EnhancerBySpringCGLIB$$85cc6cbb.createProduct(<generated>) ~[classes!/:1.0.0-SNAPSHOT]
  44. at com.etilize.burraq.cda.specification.SpecificationServiceImpl.createProduct(SpecificationServiceImpl.java:156) ~[classes!/:1.0.0-SNAPSHOT]
  45. at com.etilize.burraq.cda.kafka.debezium.KafkaConnectDebeziumMessagesReceiver.processAssociateCategoryCommandFromPSPECS(KafkaConnectDebeziumMessagesReceiver.java:143) ~[classes!/:1.0.0-SNAPSHOT]
  46. at com.etilize.burraq.cda.kafka.debezium.KafkaConnectDebeziumMessagesReceiver.callStaticMethod(KafkaConnectDebeziumMessagesReceiver.java:109) ~[classes!/:1.0.0-SNAPSHOT]
  47. at com.etilize.burraq.cda.kafka.debezium.KafkaConnectDebeziumMessagesReceiver.processProductSpecificationUpdates(KafkaConnectDebeziumMessagesReceiver.java:97) ~[classes!/:1.0.0-SNAPSHOT]
  48. at sun.reflect.GeneratedMethodAccessor146.invoke(Unknown Source) ~[na:na]
  49. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_91]
  50. at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_91]
  51. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:181) ~[spring-messaging-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  52. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:114) ~[spring-messaging-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  53. at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  54. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:248) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  55. ... 10 common frames omitted
  56. Caused by: com.mysql.jdbc.exceptions.jdbc4.MySQLIntegrityConstraintViolationException: Duplicate entry '1392950545' for key 'PRIMARY'
  57. at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) ~[na:1.8.0_91]
  58. at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) ~[na:1.8.0_91]
  59. at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) ~[na:1.8.0_91]
  60. at java.lang.reflect.Constructor.newInstance(Constructor.java:423) ~[na:1.8.0_91]
  61. at com.mysql.jdbc.Util.handleNewInstance(Util.java:425) ~[mysql-connector-java-5.1.46.jar!/:5.1.46]
  62. at com.mysql.jdbc.Util.getInstance(Util.java:408) ~[mysql-connector-java-5.1.46.jar!/:5.1.46]
  63. at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:936) ~[mysql-connector-java-5.1.46.jar!/:5.1.46]
  64. at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3976) ~[mysql-connector-java-5.1.46.jar!/:5.1.46]
  65. at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3912) ~[mysql-connector-java-5.1.46.jar!/:5.1.46]
  66. at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:2530) ~[mysql-connector-java-5.1.46.jar!/:5.1.46]
  67. at com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:2683) ~[mysql-connector-java-5.1.46.jar!/:5.1.46]
  68. at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2486) ~[mysql-connector-java-5.1.46.jar!/:5.1.46]
  69. at com.mysql.jdbc.PreparedStatement.executeInternal(PreparedStatement.java:1858) ~[mysql-connector-java-5.1.46.jar!/:5.1.46]
  70. at com.mysql.jdbc.PreparedStatement.executeUpdateInternal(PreparedStatement.java:2079) ~[mysql-connector-java-5.1.46.jar!/:5.1.46]
  71. at com.mysql.jdbc.PreparedStatement.executeUpdateInternal(PreparedStatement.java:2013) ~[mysql-connector-java-5.1.46.jar!/:5.1.46]
  72. at com.mysql.jdbc.PreparedStatement.executeLargeUpdate(PreparedStatement.java:5104) ~[mysql-connector-java-5.1.46.jar!/:5.1.46]
  73. at com.mysql.jdbc.PreparedStatement.executeUpdate(PreparedStatement.java:1998) ~[mysql-connector-java-5.1.46.jar!/:5.1.46]
  74. at com.zaxxer.hikari.pool.ProxyPreparedStatement.executeUpdate(ProxyPreparedStatement.java:61) ~[HikariCP-2.7.8.jar!/:na]
  75. at com.zaxxer.hikari.pool.HikariProxyPreparedStatement.executeUpdate(HikariProxyPreparedStatement.java) ~[HikariCP-2.7.8.jar!/:na]
  76. at org.springframework.jdbc.core.JdbcTemplate.lambda$update$0(JdbcTemplate.java:855) ~[spring-jdbc-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  77. at org.springframework.jdbc.core.JdbcTemplate.execute(JdbcTemplate.java:605) ~[spring-jdbc-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  78. ... 35 common frames omitted
  79.  
  80. 2019-04-12 06:17:56.892 INFO 8868 --- [ntainer#3-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": 1555064276, "ord": 7, "h": -3655864838442427165, "initsync": false}, "op": "u", "ts_ms": 1555064276341}]
  81. 2019-04-12 06:17:56.892 INFO 8868 --- [ntainer#3-0-C-1] k.d.KafkaConnectDebeziumMessagesReceiver : Received Debezium's Add Product Locale Command from pspecs for key: [4e7cb046-2f07-4395-a49a-1160110d2fc2] 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": 1555064276, "ord": 7, "h": -3655864838442427165, "initsync": false}, "op": "u", "ts_ms": 1555064276341}]
  82. 2019-04-12 06:17:56.893 INFO 8868 --- [ntainer#3-0-C-1] k.d.KafkaConnectDebeziumMessagesReceiver : Successfully saved received following Debezium's message: [{"after": null, "patch": "{\"$v\" : 1,\"$set\" : {\"en\" : { }}}", "source": {"version": "0.8.3.Final", "name": "burraq", "rs": "rs0", "ns": "product-specifications-service.specifications", "sec": 1555064276, "ord": 7, "h": -3655864838442427165, "initsync": false}, "op": "u", "ts_ms": 1555064276341}].
  83. 2019-04-12 06:17:56.893 INFO 8868 --- [ntainer#3-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": 1555064276, "ord": 15, "h": 8201012213560533928, "initsync": false}, "op": "u", "ts_ms": 1555064276363}]
  84. 2019-04-12 06:17:56.893 INFO 8868 --- [ntainer#3-0-C-1] k.d.KafkaConnectDebeziumMessagesReceiver : Received Debezium's Add Product Locale Command from pspecs for key: [4e7cb046-2f07-4395-a49a-1160110d2fc2] 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": 1555064276, "ord": 15, "h": 8201012213560533928, "initsync": false}, "op": "u", "ts_ms": 1555064276363}]
  85. 2019-04-12 06:17:56.900 INFO 8868 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : findCmsProduct 4e7cb046-2f07-4395-a49a-1160110d2fc2 cmsProducts: []
  86. 2019-04-12 06:17:56.900 INFO 8868 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : manufacturerId: -1
  87. 2019-04-12 06:17:56.900 INFO 8868 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : manufacturer: null
  88. 2019-04-12 06:17:56.900 INFO 8868 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : partNumber: null
  89. 2019-04-12 06:17:56.900 INFO 8868 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : cmsCategoryId: -1
  90. 2019-04-12 06:17:56.900 INFO 8868 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : cmsExistingProductId: 0
  91. 2019-04-12 06:17:56.900 INFO 8868 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : productExistInMarket: false
  92. 2019-04-12 06:17:56.900 INFO 8868 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : productExitInMarketGroup: false
  93. 2019-04-12 06:17:56.903 ERROR 8868 --- [ntainer#3-0-C-1] o.s.kafka.listener.LoggingErrorHandler : Error while processing: ConsumerRecord(topic = burraq.product-specifications-service.specifications, partition = 0, offset = 3811, CreateTime = 1555064276771, serialized key size = 44, serialized value size = 142, headers = RecordHeaders(headers = [], isReadOnly = false), key = {"id": "\"4e7cb046-2f07-4395-a49a-1160110d2fc2\""}, 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": 1555064276, "ord": 15, "h": 8201012213560533928, "initsync": false}, "op": "u", "ts_ms": 1555064276363})
  94.  
  95. 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.NullPointerException
  96. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:267) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  97. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:80) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  98. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  99. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1066) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  100. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1046) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  101. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:997) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  102. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:866) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  103. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:724) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  104. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_91]
  105. at java.util.concurrent.FutureTask.run(FutureTask.java:266) [na:1.8.0_91]
  106. at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]
  107. Caused by: java.lang.NullPointerException: null
  108. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl.createProduct(BasicSpecificationRepositoryImpl.java:307) ~[classes!/:1.0.0-SNAPSHOT]
  109. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl$$FastClassBySpringCGLIB$$f53e9f0a.invoke(<generated>) ~[classes!/:1.0.0-SNAPSHOT]
  110. at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204) ~[spring-core-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  111. at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:747) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  112. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  113. at org.springframework.dao.support.PersistenceExceptionTranslationInterceptor.invoke(PersistenceExceptionTranslationInterceptor.java:139) ~[spring-tx-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  114. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:185) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  115. at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:689) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  116. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl$$EnhancerBySpringCGLIB$$85cc6cbb.createProduct(<generated>) ~[classes!/:1.0.0-SNAPSHOT]
  117. at com.etilize.burraq.cda.specification.SpecificationServiceImpl.addLocale(SpecificationServiceImpl.java:242) ~[classes!/:1.0.0-SNAPSHOT]
  118. at com.etilize.burraq.cda.kafka.debezium.KafkaConnectDebeziumMessagesReceiver.processUpdateSpecificationAttributeCommandForAddLocale(KafkaConnectDebeziumMessagesReceiver.java:158) ~[classes!/:1.0.0-SNAPSHOT]
  119. at com.etilize.burraq.cda.kafka.debezium.KafkaConnectDebeziumMessagesReceiver.callStaticMethod(KafkaConnectDebeziumMessagesReceiver.java:118) ~[classes!/:1.0.0-SNAPSHOT]
  120. at com.etilize.burraq.cda.kafka.debezium.KafkaConnectDebeziumMessagesReceiver.processProductSpecificationUpdates(KafkaConnectDebeziumMessagesReceiver.java:97) ~[classes!/:1.0.0-SNAPSHOT]
  121. at sun.reflect.GeneratedMethodAccessor146.invoke(Unknown Source) ~[na:na]
  122. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_91]
  123. at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_91]
  124. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:181) ~[spring-messaging-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  125. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:114) ~[spring-messaging-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  126. at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  127. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:248) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  128. ... 10 common frames omitted
  129.  
  130. 2019-04-12 06:17:56.907 INFO 8868 --- [ntainer#3-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": 1555064276, "ord": 16, "h": 3630156824942206289, "initsync": false}, "op": "u", "ts_ms": 1555064276369}]
  131. 2019-04-12 06:17:56.907 INFO 8868 --- [ntainer#3-0-C-1] k.d.KafkaConnectDebeziumMessagesReceiver : Received Debezium's Add Product Locale Command from pspecs for key: [4e7cb046-2f07-4395-a49a-1160110d2fc2] 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": 1555064276, "ord": 16, "h": 3630156824942206289, "initsync": false}, "op": "u", "ts_ms": 1555064276369}]
  132. 2019-04-12 06:17:56.913 INFO 8868 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : findCmsProduct 4e7cb046-2f07-4395-a49a-1160110d2fc2 cmsProducts: []
  133. 2019-04-12 06:17:56.913 INFO 8868 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : manufacturerId: -1
  134. 2019-04-12 06:17:56.913 INFO 8868 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : manufacturer: null
  135. 2019-04-12 06:17:56.913 INFO 8868 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : partNumber: null
  136. 2019-04-12 06:17:56.913 INFO 8868 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : cmsCategoryId: -1
  137. 2019-04-12 06:17:56.914 INFO 8868 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : cmsExistingProductId: 0
  138. 2019-04-12 06:17:56.914 INFO 8868 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : productExistInMarket: false
  139. 2019-04-12 06:17:56.914 INFO 8868 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : productExitInMarketGroup: false
  140. 2019-04-12 06:17:56.920 ERROR 8868 --- [ntainer#3-0-C-1] o.s.kafka.listener.LoggingErrorHandler : Error while processing: ConsumerRecord(topic = burraq.product-specifications-service.specifications, partition = 0, offset = 3812, CreateTime = 1555064276771, serialized key size = 44, serialized value size = 141, headers = RecordHeaders(headers = [], isReadOnly = false), key = {"id": "\"4e7cb046-2f07-4395-a49a-1160110d2fc2\""}, 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": 1555064276, "ord": 16, "h": 3630156824942206289, "initsync": false}, "op": "u", "ts_ms": 1555064276369})
  141.  
  142. 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.NullPointerException
  143. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:267) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  144. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:80) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  145. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  146. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1066) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  147. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1046) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  148. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:997) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  149. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:866) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  150. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:724) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  151. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_91]
  152. at java.util.concurrent.FutureTask.run(FutureTask.java:266) [na:1.8.0_91]
  153. at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]
  154. Caused by: java.lang.NullPointerException: null
  155. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl.createProduct(BasicSpecificationRepositoryImpl.java:307) ~[classes!/:1.0.0-SNAPSHOT]
  156. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl$$FastClassBySpringCGLIB$$f53e9f0a.invoke(<generated>) ~[classes!/:1.0.0-SNAPSHOT]
  157. at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204) ~[spring-core-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  158. at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:747) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  159. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  160. at org.springframework.dao.support.PersistenceExceptionTranslationInterceptor.invoke(PersistenceExceptionTranslationInterceptor.java:139) ~[spring-tx-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  161. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:185) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  162. at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:689) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  163. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl$$EnhancerBySpringCGLIB$$85cc6cbb.createProduct(<generated>) ~[classes!/:1.0.0-SNAPSHOT]
  164. at com.etilize.burraq.cda.specification.SpecificationServiceImpl.addLocale(SpecificationServiceImpl.java:242) ~[classes!/:1.0.0-SNAPSHOT]
  165. at com.etilize.burraq.cda.kafka.debezium.KafkaConnectDebeziumMessagesReceiver.processUpdateSpecificationAttributeCommandForAddLocale(KafkaConnectDebeziumMessagesReceiver.java:158) ~[classes!/:1.0.0-SNAPSHOT]
  166. at com.etilize.burraq.cda.kafka.debezium.KafkaConnectDebeziumMessagesReceiver.callStaticMethod(KafkaConnectDebeziumMessagesReceiver.java:118) ~[classes!/:1.0.0-SNAPSHOT]
  167. at com.etilize.burraq.cda.kafka.debezium.KafkaConnectDebeziumMessagesReceiver.processProductSpecificationUpdates(KafkaConnectDebeziumMessagesReceiver.java:97) ~[classes!/:1.0.0-SNAPSHOT]
  168. at sun.reflect.GeneratedMethodAccessor146.invoke(Unknown Source) ~[na:na]
  169. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_91]
  170. at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_91]
  171. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:181) ~[spring-messaging-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  172. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:114) ~[spring-messaging-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  173. at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  174. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:248) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  175. ... 10 common frames omitted
  176.  
  177. 2019-04-12 06:17:56.922 INFO 8868 --- [ntainer#3-0-C-1] k.d.KafkaConnectDebeziumMessagesReceiver : Recieved Update Product Specification Message:[{"after": null, "patch": "{\"$v\" : 1,\"$set\" : {\"en.5cab65f2fcd96b4b222489ea\" : {\"value\" : \"TestProduct-50019\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555064276328},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"},\"en.5cab65f3fcd96b4b222489f6\" : {\"value\" : \"Greatland\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555064276328},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}}}", "source": {"version": "0.8.3.Final", "name": "burraq", "rs": "rs0", "ns": "product-specifications-service.specifications", "sec": 1555064276, "ord": 17, "h": 1344959267928905610, "initsync": false}, "op": "u", "ts_ms": 1555064276387}]
  178. 2019-04-12 06:17:56.922 INFO 8868 --- [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-50019\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555064276328},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"},\"en.5cab65f3fcd96b4b222489f6\" : {\"value\" : \"Greatland\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555064276328},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}}}", "source": {"version": "0.8.3.Final", "name": "burraq", "rs": "rs0", "ns": "product-specifications-service.specifications", "sec": 1555064276, "ord": 17, "h": 1344959267928905610, "initsync": false}, "op": "u", "ts_ms": 1555064276387}]
  179. 2019-04-12 06:17:56.929 INFO 8868 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : 5cab65f2fcd96b4b222489ea
  180. 2019-04-12 06:17:56.929 INFO 8868 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : com.etilize.burraq.cda.taxonomy.mapping.BurraqCategoryTaxonomies@34008703
  181. 2019-04-12 06:17:56.929 INFO 8868 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : 11798
  182. 2019-04-12 06:17:56.935 INFO 8868 --- [ntainer#3-0-C-1] e.b.c.s.BasicSpecificationRepositoryImpl : selectProductId: BurraqProductId4e7cb046-2f07-4395-a49a-1160110d2fc2 MarketId:16 LanguageId:17
  183. 2019-04-12 06:17:56.937 ERROR 8868 --- [ntainer#3-0-C-1] o.s.kafka.listener.LoggingErrorHandler : Error while processing: ConsumerRecord(topic = burraq.product-specifications-service.specifications, partition = 0, offset = 3813, CreateTime = 1555064276771, serialized key size = 44, serialized value size = 596, headers = RecordHeaders(headers = [], isReadOnly = false), key = {"id": "\"4e7cb046-2f07-4395-a49a-1160110d2fc2\""}, value = {"after": null, "patch": "{\"$v\" : 1,\"$set\" : {\"en.5cab65f2fcd96b4b222489ea\" : {\"value\" : \"TestProduct-50019\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555064276328},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"},\"en.5cab65f3fcd96b4b222489f6\" : {\"value\" : \"Greatland\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555064276328},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}}}", "source": {"version": "0.8.3.Final", "name": "burraq", "rs": "rs0", "ns": "product-specifications-service.specifications", "sec": 1555064276, "ord": 17, "h": 1344959267928905610, "initsync": false}, "op": "u", "ts_ms": 1555064276387})
  184.  
  185. 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
  186. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:267) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  187. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:80) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  188. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  189. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1066) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  190. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1046) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  191. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:997) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  192. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:866) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  193. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:724) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  194. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_91]
  195. at java.util.concurrent.FutureTask.run(FutureTask.java:266) [na:1.8.0_91]
  196. at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]
  197. Caused by: java.lang.IndexOutOfBoundsException: Index: 0, Size: 0
  198. at java.util.ArrayList.rangeCheck(ArrayList.java:653) ~[na:1.8.0_91]
  199. at java.util.ArrayList.get(ArrayList.java:429) ~[na:1.8.0_91]
  200. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl.selectProductId(BasicSpecificationRepositoryImpl.java:601) ~[classes!/:1.0.0-SNAPSHOT]
  201. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl.saveProductParameter(BasicSpecificationRepositoryImpl.java:577) ~[classes!/:1.0.0-SNAPSHOT]
  202. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl$$FastClassBySpringCGLIB$$f53e9f0a.invoke(<generated>) ~[classes!/:1.0.0-SNAPSHOT]
  203. at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204) ~[spring-core-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  204. at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:747) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  205. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  206. at org.springframework.dao.support.PersistenceExceptionTranslationInterceptor.invoke(PersistenceExceptionTranslationInterceptor.java:139) ~[spring-tx-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  207. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:185) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  208. at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:689) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  209. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl$$EnhancerBySpringCGLIB$$85cc6cbb.saveProductParameter(<generated>) ~[classes!/:1.0.0-SNAPSHOT]
  210. at com.etilize.burraq.cda.specification.SpecificationServiceImpl.saveSpecsToCMS(SpecificationServiceImpl.java:496) ~[classes!/:1.0.0-SNAPSHOT]
  211. at com.etilize.burraq.cda.specification.SpecificationServiceImpl.lambda$updateSpecifications$0(SpecificationServiceImpl.java:353) ~[classes!/:1.0.0-SNAPSHOT]
  212. at java.util.HashMap$EntrySet.forEach(HashMap.java:1035) ~[na:1.8.0_91]
  213. at com.etilize.burraq.cda.specification.SpecificationServiceImpl.updateSpecifications(SpecificationServiceImpl.java:330) ~[classes!/:1.0.0-SNAPSHOT]
  214. at com.etilize.burraq.cda.kafka.debezium.KafkaConnectDebeziumMessagesReceiver.processUpdateSpecificationAttributeCommand(KafkaConnectDebeziumMessagesReceiver.java:169) ~[classes!/:1.0.0-SNAPSHOT]
  215. at com.etilize.burraq.cda.kafka.debezium.KafkaConnectDebeziumMessagesReceiver.callStaticMethod(KafkaConnectDebeziumMessagesReceiver.java:125) ~[classes!/:1.0.0-SNAPSHOT]
  216. at com.etilize.burraq.cda.kafka.debezium.KafkaConnectDebeziumMessagesReceiver.processProductSpecificationUpdates(KafkaConnectDebeziumMessagesReceiver.java:97) ~[classes!/:1.0.0-SNAPSHOT]
  217. at sun.reflect.GeneratedMethodAccessor146.invoke(Unknown Source) ~[na:na]
  218. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_91]
  219. at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_91]
  220. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:181) ~[spring-messaging-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  221. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:114) ~[spring-messaging-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  222. at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  223. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:248) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  224. ... 10 common frames omitted
  225.  
  226. 2019-04-12 06:17:56.939 INFO 8868 --- [ntainer#3-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\" : 1555064276429},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.UnitValue\"},\"en.5cab65f3fcd96b4b222489fb\" : [{\"value\" : \"Lithium Polymer (Li-Polymer)\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555064276429},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}, {\"value\" : \"Nickel Cadmium (NiCd)\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555064276429},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}, {\"value\" : \"Nickel\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555064276429},\"_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\" : 1555064276429},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.UnitValue\"},\"en.5cab65f5fcd96b4b222489ff\" : {\"value\" : \"Powered Shrub Shear\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555064276429},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"},\"en.5cab65f5fcd96b4b22248a00\" : [{\"value\" : \"Battery\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555064276429},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}, {\"value\" : \"AC Supply\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555064276429},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}],\"en.5cab65f5fcd96b4b22248a03\" : [{\"value\" : \"Malaysia\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555064276429},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}, {\"value\" : \"South America\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555064276429},\"_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\" : 1555064276429},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.UnitValue\"},\"en.5cab65f6fcd96b4b22248a07\" : {\"value\" : \"Yes\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555064276429},\"_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\" : 1555064276429},\"_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\" : 1555064276429},\"_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\" : 1555064276429},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}}}", "source": {"version": "0.8.3.Final", "name": "burraq", "rs": "rs0", "ns": "product-specifications-service.specifications", "sec": 1555064276, "ord": 18, "h": 4563111227808118418, "initsync": false}, "op": "u", "ts_ms": 1555064276464}]
  227. 2019-04-12 06:17:56.939 INFO 8868 --- [ntainer#3-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\" : 1555064276429},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.UnitValue\"},\"en.5cab65f3fcd96b4b222489fb\" : [{\"value\" : \"Lithium Polymer (Li-Polymer)\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555064276429},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}, {\"value\" : \"Nickel Cadmium (NiCd)\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555064276429},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}, {\"value\" : \"Nickel\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555064276429},\"_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\" : 1555064276429},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.UnitValue\"},\"en.5cab65f5fcd96b4b222489ff\" : {\"value\" : \"Powered Shrub Shear\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555064276429},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"},\"en.5cab65f5fcd96b4b22248a00\" : [{\"value\" : \"Battery\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555064276429},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}, {\"value\" : \"AC Supply\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555064276429},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}],\"en.5cab65f5fcd96b4b22248a03\" : [{\"value\" : \"Malaysia\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555064276429},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}, {\"value\" : \"South America\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555064276429},\"_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\" : 1555064276429},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.UnitValue\"},\"en.5cab65f6fcd96b4b22248a07\" : {\"value\" : \"Yes\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555064276429},\"_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\" : 1555064276429},\"_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\" : 1555064276429},\"_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\" : 1555064276429},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}}}", "source": {"version": "0.8.3.Final", "name": "burraq", "rs": "rs0", "ns": "product-specifications-service.specifications", "sec": 1555064276, "ord": 18, "h": 4563111227808118418, "initsync": false}, "op": "u", "ts_ms": 1555064276464}]
  228. 2019-04-12 06:17:56.953 INFO 8868 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : 5cab65f5fcd96b4b22248a00
  229. 2019-04-12 06:17:56.955 INFO 8868 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : com.etilize.burraq.cda.taxonomy.mapping.BurraqCategoryTaxonomies@35c4b47c
  230. 2019-04-12 06:17:56.955 INFO 8868 --- [ntainer#3-0-C-1] c.e.b.c.s.SpecificationServiceImpl : 10992
  231. 2019-04-12 06:17:56.958 INFO 8868 --- [ntainer#3-0-C-1] e.b.c.s.BasicSpecificationRepositoryImpl : selectProductId: BurraqProductId4e7cb046-2f07-4395-a49a-1160110d2fc2 MarketId:16 LanguageId:17
  232. 2019-04-12 06:17:56.961 ERROR 8868 --- [ntainer#3-0-C-1] o.s.kafka.listener.LoggingErrorHandler : Error while processing: ConsumerRecord(topic = burraq.product-specifications-service.specifications, partition = 0, offset = 3814, CreateTime = 1555064276771, serialized key size = 44, serialized value size = 4339, headers = RecordHeaders(headers = [], isReadOnly = false), key = {"id": "\"4e7cb046-2f07-4395-a49a-1160110d2fc2\""}, 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\" : 1555064276429},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.UnitValue\"},\"en.5cab65f3fcd96b4b222489fb\" : [{\"value\" : \"Lithium Polymer (Li-Polymer)\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555064276429},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}, {\"value\" : \"Nickel Cadmium (NiCd)\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555064276429},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}, {\"value\" : \"Nickel\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555064276429},\"_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\" : 1555064276429},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.UnitValue\"},\"en.5cab65f5fcd96b4b222489ff\" : {\"value\" : \"Powered Shrub Shear\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555064276429},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"},\"en.5cab65f5fcd96b4b22248a00\" : [{\"value\" : \"Battery\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555064276429},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}, {\"value\" : \"AC Supply\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555064276429},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}],\"en.5cab65f5fcd96b4b22248a03\" : [{\"value\" : \"Malaysia\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555064276429},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}, {\"value\" : \"South America\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555064276429},\"_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\" : 1555064276429},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.UnitValue\"},\"en.5cab65f6fcd96b4b22248a07\" : {\"value\" : \"Yes\",\"lastModifiedBy\" : \"cms_data_integration_user@etilizepak.com\",\"lastModifiedDate\" : {\"$date\" : 1555064276429},\"_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\" : 1555064276429},\"_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\" : 1555064276429},\"_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\" : 1555064276429},\"_class\" : \"com.etilize.burraq.pspecs.specification.value.Value\"}}}", "source": {"version": "0.8.3.Final", "name": "burraq", "rs": "rs0", "ns": "product-specifications-service.specifications", "sec": 1555064276, "ord": 18, "h": 4563111227808118418, "initsync": false}, "op": "u", "ts_ms": 1555064276464})
  233.  
  234. 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
  235. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:267) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  236. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:80) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  237. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  238. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1066) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  239. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1046) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  240. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:997) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  241. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:866) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  242. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:724) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  243. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_91]
  244. at java.util.concurrent.FutureTask.run(FutureTask.java:266) [na:1.8.0_91]
  245. at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]
  246. Caused by: java.lang.IndexOutOfBoundsException: Index: 0, Size: 0
  247. at java.util.ArrayList.rangeCheck(ArrayList.java:653) ~[na:1.8.0_91]
  248. at java.util.ArrayList.get(ArrayList.java:429) ~[na:1.8.0_91]
  249. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl.selectProductId(BasicSpecificationRepositoryImpl.java:601) ~[classes!/:1.0.0-SNAPSHOT]
  250. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl.saveProductParameter(BasicSpecificationRepositoryImpl.java:577) ~[classes!/:1.0.0-SNAPSHOT]
  251. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl$$FastClassBySpringCGLIB$$f53e9f0a.invoke(<generated>) ~[classes!/:1.0.0-SNAPSHOT]
  252. at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204) ~[spring-core-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  253. at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:747) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  254. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  255. at org.springframework.dao.support.PersistenceExceptionTranslationInterceptor.invoke(PersistenceExceptionTranslationInterceptor.java:139) ~[spring-tx-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  256. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:185) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  257. at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:689) ~[spring-aop-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  258. at com.etilize.burraq.cda.specification.BasicSpecificationRepositoryImpl$$EnhancerBySpringCGLIB$$85cc6cbb.saveProductParameter(<generated>) ~[classes!/:1.0.0-SNAPSHOT]
  259. at com.etilize.burraq.cda.specification.SpecificationServiceImpl.saveSpecsToCMS(SpecificationServiceImpl.java:496) ~[classes!/:1.0.0-SNAPSHOT]
  260. at com.etilize.burraq.cda.specification.SpecificationServiceImpl.lambda$updateSpecifications$0(SpecificationServiceImpl.java:353) ~[classes!/:1.0.0-SNAPSHOT]
  261. at java.util.HashMap$EntrySet.forEach(HashMap.java:1035) ~[na:1.8.0_91]
  262. at com.etilize.burraq.cda.specification.SpecificationServiceImpl.updateSpecifications(SpecificationServiceImpl.java:330) ~[classes!/:1.0.0-SNAPSHOT]
  263. at com.etilize.burraq.cda.kafka.debezium.KafkaConnectDebeziumMessagesReceiver.processUpdateSpecificationAttributeCommand(KafkaConnectDebeziumMessagesReceiver.java:169) ~[classes!/:1.0.0-SNAPSHOT]
  264. at com.etilize.burraq.cda.kafka.debezium.KafkaConnectDebeziumMessagesReceiver.callStaticMethod(KafkaConnectDebeziumMessagesReceiver.java:125) ~[classes!/:1.0.0-SNAPSHOT]
  265. at com.etilize.burraq.cda.kafka.debezium.KafkaConnectDebeziumMessagesReceiver.processProductSpecificationUpdates(KafkaConnectDebeziumMessagesReceiver.java:97) ~[classes!/:1.0.0-SNAPSHOT]
  266. at sun.reflect.GeneratedMethodAccessor146.invoke(Unknown Source) ~[na:na]
  267. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_91]
  268. at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_91]
  269. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:181) ~[spring-messaging-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  270. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:114) ~[spring-messaging-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  271. at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  272. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:248) ~[spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  273. ... 10 common frames omitted
  274.  
  275. 2019-04-12 06:17:57.106 INFO 8868 --- [ntainer#4-0-C-1] .c.k.n.KafkaConnectNeo4jMessagesReceiver : Received message from product-code-service [GenericMessage [payload=(product-code-service409�CustomerCode: [CustomerId=5c7e0598fe19fe3ad727baff,Code=TestProductCode5001524,Market=US] already exists.Pcms_data_integration_user@etilizepak.com̕��ZH4e7cb046-2f07-4395-a49a-1160110d2fc2token 99, headers={kafka_offset=997, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@525099aa, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=null, kafka_receivedPartitionId=0, contentType=application/vnd.addproductcodefailedevent.v2+avro, kafka_receivedTopic=product-code-service, kafka_receivedTimestamp=1555064277104}]]
  276. 2019-04-12 06:17:57.107 ERROR 8868 --- [ntainer#4-0-C-1] .c.k.n.KafkaConnectNeo4jMessagesReceiver : ******** Error on received message from product-code-service [GenericMessage [payload=(product-code-service409�CustomerCode: [CustomerId=5c7e0598fe19fe3ad727baff,Code=TestProductCode5001524,Market=US] already exists.Pcms_data_integration_user@etilizepak.com̕��ZH4e7cb046-2f07-4395-a49a-1160110d2fc2token 99, headers={kafka_offset=997, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@525099aa, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=null, kafka_receivedPartitionId=0, contentType=application/vnd.addproductcodefailedevent.v2+avro, kafka_receivedTopic=product-code-service, kafka_receivedTimestamp=1555064277104}]] [com.google.gson.stream.MalformedJsonException: Use JsonReader.setLenient(true) to accept malformed JSON at line 1 column 41 path $] [{}]
  277.  
  278. com.google.gson.stream.MalformedJsonException: Use JsonReader.setLenient(true) to accept malformed JSON at line 1 column 41 path $
  279. at com.google.gson.stream.JsonReader.syntaxError(JsonReader.java:1568) ~[gson-2.8.2.jar!/:na]
  280. at com.google.gson.stream.JsonReader.checkLenient(JsonReader.java:1409) ~[gson-2.8.2.jar!/:na]
  281. at com.google.gson.stream.JsonReader.doPeek(JsonReader.java:542) ~[gson-2.8.2.jar!/:na]
  282. at com.google.gson.stream.JsonReader.peek(JsonReader.java:425) ~[gson-2.8.2.jar!/:na]
  283. at com.google.gson.JsonParser.parse(JsonParser.java:60) ~[gson-2.8.2.jar!/:na]
  284. at com.google.gson.JsonParser.parse(JsonParser.java:45) ~[gson-2.8.2.jar!/:na]
  285. at com.etilize.burraq.cda.kafka.neo4j.KafkaConnectNeo4jMessagesReceiver.processProductCodeServiceMessages(KafkaConnectNeo4jMessagesReceiver.java:110) ~[classes!/:1.0.0-SNAPSHOT]
  286. at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.8.0_91]
  287. at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[na:1.8.0_91]
  288. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_91]
  289. at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_91]
  290. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:181) [spring-messaging-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  291. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:114) [spring-messaging-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]
  292. at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  293. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:248) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  294. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:80) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  295. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  296. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1066) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  297. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1046) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  298. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:997) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  299. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:866) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  300. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:724) [spring-kafka-2.1.5.RELEASE.jar!/:2.1.5.RELEASE]
  301. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_91]
  302. at java.util.concurrent.FutureTask.run(FutureTask.java:266) [na:1.8.0_91]
  303. at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]
  304.  
  305. 2019-04-12 06:17:57.386 INFO 8868 --- [ntainer#1-0-C-1] .c.k.r.KafkaConnectRedisMessagesReceiver : Received Product Specifications Status Message: [GenericMessage [payload={"key":"cHJvZHVjdF9zdGF0dXNlczo0ZTdjYjA0Ni0yZjA3LTQzOTUtYTQ5YS0xMTYwMTEwZDJmYzI=","field":"ZXNfVVM=","value":"UFVCTElTSEVE"}, headers={kafka_offset=4001, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@1a6738ef, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=com.moilioncircle.redis.replicator.cmd.impl.HSetCommand, kafka_receivedPartitionId=0, kafka_receivedTopic=product-specifications-status-service, kafka_receivedTimestamp=1555064277403}]]
  306. 2019-04-12 06:17:58.999 INFO 8868 --- [ntainer#4-0-C-1] .c.k.n.KafkaConnectNeo4jMessagesReceiver : Received message from product-code-service [GenericMessage [payload={"payload":{"id":"2323565","before":null,"after":{"properties":{"productId":"4e7cb046-2f07-4395-a49a-1160110d2fc2"},"labels":["Product"]},"type":"node"},"meta":{"timestamp":1555064278991,"username":"neo4j","txId":976590,"txEventId":1,"txEventsCount":7,"operation":"created","source":{"hostname":"vmnode0018"}},"schema":{"properties":[],"constraints":null}}, headers={kafka_offset=998, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@525099aa, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=976591-1, kafka_receivedPartitionId=0, kafka_receivedTopic=product-code-service, kafka_receivedTimestamp=1555064278993}]]
  307. 2019-04-12 06:17:59.000 INFO 8868 --- [ntainer#5-0-C-1] .c.k.n.KafkaConnectNeo4jMessagesReceiver : Received message from product-accessories-service [GenericMessage [payload={"payload":{"id":"2323565","before":null,"after":{"properties":{"productId":"4e7cb046-2f07-4395-a49a-1160110d2fc2"},"labels":["Product"]},"type":"node"},"meta":{"timestamp":1555064278991,"username":"neo4j","txId":976590,"txEventId":1,"txEventsCount":7,"operation":"created","source":{"hostname":"vmnode0018"}},"schema":{"properties":[],"constraints":null}}, headers={kafka_offset=480, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@11dbece5, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=976591-1, kafka_receivedPartitionId=0, kafka_receivedTopic=product-accessory-service, kafka_receivedTimestamp=1555064278994}]]
  308. 2019-04-12 06:17:59.000 INFO 8868 --- [ntainer#6-0-C-1] .c.k.n.KafkaConnectNeo4jMessagesReceiver : Received message from barcode-service [GenericMessage [payload={"payload":{"id":"2323565","before":null,"after":{"properties":{"productId":"4e7cb046-2f07-4395-a49a-1160110d2fc2"},"labels":["Product"]},"type":"node"},"meta":{"timestamp":1555064278991,"username":"neo4j","txId":976590,"txEventId":1,"txEventsCount":7,"operation":"created","source":{"hostname":"vmnode0018"}},"schema":{"properties":[],"constraints":null}}, headers={kafka_offset=1560, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@34876742, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=976591-1, kafka_receivedPartitionId=0, kafka_receivedTopic=barcode-service, kafka_receivedTimestamp=1555064278993}]]
  309. 2019-04-12 06:17:59.003 INFO 8868 --- [ntainer#6-0-C-1] .c.k.n.KafkaConnectNeo4jMessagesReceiver : Received message from barcode-service [GenericMessage [payload={"payload":{"id":"1623683","start":{"id":"2323565","labels":["Product"]},"end":{"id":"2323563","labels":["Barcode"]},"before":null,"after":{"properties":{"code":"00648177031955","productId":"4e7cb046-2f07-4395-a49a-1160110d2fc2","customerId":"5c7e0598fe19fe3ad727baff","type":"GTIN"}},"label":"RELATED_TO","type":"relationship"},"meta":{"timestamp":1555064278991,"username":"neo4j","txId":976590,"txEventId":4,"txEventsCount":7,"operation":"created","source":{"hostname":"vmnode0018"}},"schema":{"properties":[],"constraints":null}}, headers={kafka_offset=1561, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@34876742, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=976594-4, kafka_receivedPartitionId=0, kafka_receivedTopic=barcode-service, kafka_receivedTimestamp=1555064278993}]]
  310. 2019-04-12 06:17:59.006 INFO 8868 --- [ntainer#6-0-C-1] .c.k.n.KafkaConnectNeo4jMessagesReceiver : Received message from barcode-service [GenericMessage [payload={"payload":{"id":"1623685","start":{"id":"2323565","labels":["Product"]},"end":{"id":"2323562","labels":["Barcode"]},"before":null,"after":{"properties":{"code":"0648177031955","productId":"4e7cb046-2f07-4395-a49a-1160110d2fc2","customerId":"5c7e0598fe19fe3ad727baff","type":"EAN"}},"label":"RELATED_TO","type":"relationship"},"meta":{"timestamp":1555064278991,"username":"neo4j","txId":976590,"txEventId":5,"txEventsCount":7,"operation":"created","source":{"hostname":"vmnode0018"}},"schema":{"properties":[],"constraints":null}}, headers={kafka_offset=1562, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@34876742, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=976595-5, kafka_receivedPartitionId=0, kafka_receivedTopic=barcode-service, kafka_receivedTimestamp=1555064278994}]]
  311. 2019-04-12 06:17:59.008 INFO 8868 --- [ntainer#6-0-C-1] .c.k.n.KafkaConnectNeo4jMessagesReceiver : Received message from barcode-service [GenericMessage [payload={"payload":{"id":"1623684","start":{"id":"2323565","labels":["Product"]},"end":{"id":"2323564","labels":["Barcode"]},"before":null,"after":{"properties":{"code":"648177031955","productId":"4e7cb046-2f07-4395-a49a-1160110d2fc2","customerId":"5c7e0598fe19fe3ad727baff","type":"UPC"}},"label":"RELATED_TO","type":"relationship"},"meta":{"timestamp":1555064278991,"username":"neo4j","txId":976590,"txEventId":6,"txEventsCount":7,"operation":"created","source":{"hostname":"vmnode0018"}},"schema":{"properties":[],"constraints":null}}, headers={kafka_offset=1563, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@34876742, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=976596-6, kafka_receivedPartitionId=0, kafka_receivedTopic=barcode-service, kafka_receivedTimestamp=1555064278994}]]
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!