search

spring-cloud / spring-cloud-stream

Framework for building Event-Driven Microservices
http://cloud.spring.io/spring-cloud-stream
Apache License 2.0
1.01k stars 614 forks source link

This Spring cloud application which attempts to send a Kafka message using StreamBridge. The process involves AWS Glue Schema Registry for message validation and serialization using GlueSchemaRegistryKafkaSerializer. While the service establishes a connection with Glue for validation, it fails with the error: Cannot invoke "Object.getClass()" because "result" is null. #3045

Open Sunils1456 opened 1 day ago

Sunils1456 commented 1 day ago

working on aws glue schema registry using cloud stream with latest version and getting issue- Channel 'dcs-outbound-annotation-svc.output-out-0' has 1 subscriber(s). 2024-11-21 11:07:54.555Z ERROR 1 --- [dcs-outbound-annotation-svc] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-16-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : Cannot invoke "Object.getClass()" because "result" is null

We have a scenario involving two AWS accounts: Account A hosts the Glue Schema Registry, and Account B contains an EKS cluster where a microservice, built using Spring Cloud Stream 4.1.1, is running. The microservice successfully accesses the Glue Schema Registry across accounts. However, while attempting to write data to the Glue Schema Registry, it encounters the aforementioned error. Please let me know if anyone has any suggestion regarding this issue.

Sunils1456 commented 1 day ago

Here is the configuration being used:
stream: kafka: bindings: output-out-0: destination: ${DCS_OUTBOUND_ANNOTATION_OUTPUT_TOPIC:topicname} content-type: application/avro binder: ddpKafkaBinder producer: useNativeEncoding: true sync: true configuration: registry.name: ${AWS_REGISTRY_NAME:schema-name} key.serializer: ${DDP_KAFKA_VALUE_SERIALIZER:com.amazonaws.services.schemaregistry.serializers.GlueSchemaRegistryKafkaSerializer} value.serializer: ${DDP_KAFKA_KEY_SERIALIZER:com.amazonaws.services.schemaregistry.serializers.GlueSchemaRegistryKafkaSerializer} region: ${AWS_REGION:xxx} client.id: cross-account-glue-schemaregistry-obsout schemaNameGenerationClass: com.ge.dcs.outboundannotation.config.CustomSchemaNamingStrategy avroRecordType: SPECIFIC_RECORD dataFormat: AVRO schemaName: DataremeValue

olegz commented 1 day ago

Can you please post a stack trace? What you posted above contains no relevant information

Sunils1456 commented 1 day ago 
id":"9018b1dc-c5e6-44ee-8880-f6d53cfd1615","identifier":[{"system":"http://www.xxx.com/fhir/StructureDefinition/observation-source","value":"xxxx"}],"name":[{"use":"usual","text":"Device"}]}}]}
2024-11-21 11:07:52.867Z INFO 1 --- [dcs-outbound-annotation-svc] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-16-C-1] org.springframework.cloud.stream.binder.DefaultBinderFactory : Creating binder: ddpKafkaBinder
2024-11-21 11:07:52.867Z INFO 1 --- [dcs-outbound-annotation-svc] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-16-C-1] org.springframework.cloud.stream.binder.DefaultBinderFactory : Constructing binder child context for ddpKafkaBinder
2024-11-21 11:07:53.576Z INFO 1 --- [dcs-outbound-annotation-svc] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-16-C-1] org.springframework.cloud.stream.binder.DefaultBinderFactory : Caching the binder: ddpKafkaBinder
2024-11-21 11:07:53.577Z INFO 1 --- [dcs-outbound-annotation-svc] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-16-C-1] org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner : Using kafka topic for outbound: ddp-emr-fhirobsout-ld-gehc-blr1
2024-11-21 11:07:54.548Z INFO 1 --- [dcs-outbound-annotation-svc] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-16-C-1] org.springframework.cloud.stream.messaging.DirectWithAttributesChannel : Channel 'dcs-outbound-annotation-svc.output-out-0' has 1 subscriber(s).
2024-11-21 11:07:54.555Z ERROR 1 --- [dcs-outbound-annotation-svc] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-16-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : Cannot invoke "Object.getClass()" because "result" is null
2024-11-21 11:07:54.557Z INFO 1 --- [dcs-outbound-annotation-svc] Tenant: simba-ngps [task-3] com.ge.dcs.audit.service.AuditServiceImpl : Successfully added audit to queue: com.ge.dcs.audit.model.Audit@3c41dc69
olegz commented 1 day ago

It is not a stack trace, it is a log

olegz commented 1 day ago

I have no idea what Glue is. I have asked you for a stack trace and you sent me some code. . . .

Sunils1456 commented 1 day ago

This Spring cloud application which attempts to send a Kafka message using StreamBridge. The process involves AWS Glue Schema Registry for message validation and serialization using GlueSchemaRegistryKafkaSerializer. While the service establishes a connection with Glue for validation, it fails with the error: Cannot invoke "Object.getClass()" because "result" is null.

olegz commented 1 day ago

I am asking you one more time to provide a stack trace so we can diagnose the issue

Sunils1456 commented 1 day ago

this is logs:

11:06:58,242 |-INFO in ch.qos.logback.classic.util.ContextInitializer@6531a794 - Trying to configure with ch.qos.logback.classic.util.DefaultJoranConfigurator 11:06:58,243 |-INFO in ch.qos.logback.classic.util.ContextInitializer@6531a794 - Constructed configurator of type class ch.qos.logback.classic.util.DefaultJoranConfigurator 11:06:58,245 |-INFO in ch.qos.logback.classic.LoggerContext[default] - Could NOT find resource [logback-test.xml] 11:06:58,246 |-INFO in ch.qos.logback.classic.LoggerContext[default] - Found resource [logback.xml] at [jar:nested:/app.jar/!BOOT-INF/lib/ngps-common-utilities-lib-5.0.12-SNAPSHOT.jar!/logback.xml] 11:06:58,266 |-INFO in ch.qos.logback.core.joran.spi.ConfigurationWatchList@3b5fad2d - URL [jar:nested:/app.jar/!BOOT-INF/lib/ngps-common-utilities-lib-5.0.12-SNAPSHOT.jar!/logback.xml] is not of type file 11:06:58,596 |-INFO in ch.qos.logback.classic.model.processor.ConfigurationModelHandlerFull - Registering a new ReconfigureOnChangeTask ReconfigureOnChangeTask(born:1732187218595) 11:06:58,596 |-INFO in ch.qos.logback.classic.model.processor.ConfigurationModelHandlerFull - No 'scanPeriod' specified. Defaulting to 1 minutes 11:06:58,596 |-INFO in ch.qos.logback.classic.model.processor.ConfigurationModelHandlerFull - Will scan for changes in [jar:nested:/app.jar/!BOOT-INF/lib/ngps-common-utilities-lib-5.0.12-SNAPSHOT.jar!/logback.xml] 11:06:58,596 |-INFO in ch.qos.logback.classic.model.processor.ConfigurationModelHandlerFull - Setting ReconfigureOnChangeTask scanning period to 1 minutes 11:06:58,642 |-WARN in ch.qos.logback.core.model.processor.ImplicitModelHandler - Ignoring unknown property [springProperty] in [ch.qos.logback.classic.LoggerContext] 11:06:58,642 |-WARN in ch.qos.logback.core.model.processor.ImplicitModelHandler - Ignoring unknown property [springProperty] in [ch.qos.logback.classic.LoggerContext] 11:06:58,642 |-WARN in ch.qos.logback.core.model.processor.ImplicitModelHandler - Ignoring unknown property [springProperty] in [ch.qos.logback.classic.LoggerContext] 11:06:58,649 |-INFO in ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [STDOUT] 11:06:58,649 |-INFO in ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [ch.qos.logback.core.ConsoleAppender] 11:06:58,658 |-INFO in ch.qos.logback.core.model.processor.ImplicitModelHandler - Assuming default type [ch.qos.logback.classic.encoder.PatternLayoutEncoder] for [encoder] property 11:06:58,748 |-INFO in ch.qos.logback.classic.model.processor.RootLoggerModelHandler - Setting level of ROOT logger to INFO 11:06:58,748 |-INFO in ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [STDOUT] to Logger[ROOT] 11:06:58,749 |-INFO in ch.qos.logback.core.model.processor.DefaultProcessor@5e17553a - End of configuration. 11:06:58,750 |-INFO in ch.qos.logback.classic.joran.JoranConfigurator@3eb91815 - Registering current configuration as safe fallback point 11:06:58,750 |-INFO in ch.qos.logback.classic.util.ContextInitializer@6531a794 - ch.qos.logback.classic.util.DefaultJoranConfigurator.configure() call lasted 507 milliseconds. ExecutionStatus=DO_NOT_INVOKE_NEXT_IF_ANY

 _                 _                                 _                  _        _ _ _
| |               | |                               | |                | |      | (_) |
__ __ ____ _ ___ __ _ _ / ` / / __ '_ \ ' _____ '_ \ '_/ \ _/ \ / _/ \ __ '_ \ (_ (\ \ _) _) (_) (_) (_ (_) _) _, ___ ___/ _ _ .__/ .__/ _ _/ _\/ __/ _ _ _ _.__/
_ _

2024-11-21 11:07:00.856Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [main] com.ge.dcs.outboundannotation.OutboundAnnotationSvcApplication : Starting OutboundAnnotationSvcApplication v3.0.0-SNAPSHOT using Java 17.0.12 with PID 1 (/app.jar started by undertow in /) 2024-11-21 11:07:00.865Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [main] com.ge.dcs.outboundannotation.OutboundAnnotationSvcApplication : The following 1 profile is active: "production" 2024-11-21 11:07:04.451Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [main] org.springframework.integration.config.DefaultConfiguringBeanFactoryPostProcessor : No bean named 'errorChannel' has been explicitly defined. Therefore, a default PublishSubscribeChannel will be created. 2024-11-21 11:07:04.459Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [main] org.springframework.integration.config.DefaultConfiguringBeanFactoryPostProcessor : No bean named 'integrationHeaderChannelRegistry' has been explicitly defined. Therefore, a default DefaultHeaderChannelRegistry will be created. 2024-11-21 11:07:07.563Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [main] com.ge.dcs.outboundannotation.config.ProducerKafkaConfig : awsRegion: us-east-2, crossAccountRole: arn:aws:iam::975050309133:role/CrossAccountGlueRole, crossAccountSession: cross-account-glue-schemaregistry-obsout-ngps-simba, crossAccountExternalId: glue71001 2024-11-21 11:07:07.565Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [main] com.ge.dcs.outboundannotation.config.ProducerKafkaConfig : Enabled AWS Glue Schema registry 2024-11-21 11:07:09.970Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [main] com.ge.dcs.outboundannotation.config.ProducerKafkaConfig : Got assumed role token, expiration: 2024-11-21T12:07:09Z 2024-11-21 11:07:19.359Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [main] org.springframework.cloud.stream.messaging.DirectWithAttributesChannel : Channel 'xxx-xxxxxxx-xxx-xxxxxxx.refreshItemConfigurationCacheData-in-0' has 1 subscriber(s). 2024-11-21 11:07:19.360Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [main] org.springframework.cloud.stream.messaging.DirectWithAttributesChannel : Channel 'xxx-xxxxxxx-xxx-xxxxxxx.transformToOutboundAnnotation-in-0' has 1 subscriber(s). 2024-11-21 11:07:20.200Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [main] org.springframework.integration.endpoint.EventDrivenConsumer : Adding {logging-channel-adapter:_org.springframework.integration.errorLogger} as a subscriber to the 'errorChannel' channel 2024-11-21 11:07:20.201Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [main] org.springframework.integration.channel.PublishSubscribeChannel : Channel 'xxx-xxxxxxx-xxx-xxxxxxx.errorChannel' has 1 subscriber(s). 2024-11-21 11:07:20.201Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [main] org.springframework.integration.endpoint.EventDrivenConsumer : started bean '_org.springframework.integration.errorLogger' 2024-11-21 11:07:20.452Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [main] org.springframework.cloud.stream.binder.DefaultBinderFactory : Creating binder: ngpsKafkaBinder 2024-11-21 11:07:20.452Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [main] org.springframework.cloud.stream.binder.DefaultBinderFactory : Constructing binder child context for ngpsKafkaBinder 2024-11-21 11:07:21.490Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [main] org.springframework.cloud.stream.binder.DefaultBinderFactory : Caching the binder: ngpsKafkaBinder 2024-11-21 11:07:25.480Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [main] org.springframework.cloud.stream.binder.BinderErrorChannel : Channel 'kafka-452827175.refreshItemConfigurationCacheData-in-0.errors' has 1 subscriber(s). 2024-11-21 11:07:25.481Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [main] org.springframework.cloud.stream.binder.BinderErrorChannel : Channel 'kafka-452827175.refreshItemConfigurationCacheData-in-0.errors' has 0 subscriber(s). 2024-11-21 11:07:25.481Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [main] org.springframework.cloud.stream.binder.BinderErrorChannel : Channel 'kafka-452827175.refreshItemConfigurationCacheData-in-0.errors' has 1 subscriber(s). 2024-11-21 11:07:25.481Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [main] org.springframework.cloud.stream.binder.BinderErrorChannel : Channel 'kafka-452827175.refreshItemConfigurationCacheData-in-0.errors' has 2 subscriber(s). 2024-11-21 11:07:25.562Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [main] org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter : started org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter@6e00a1ba 2024-11-21 11:07:26.627Z WARN 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [main] org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner : The number of expected partitions for topic annotation_internal_ngps_simba was: 30, but 15 have been found instead. There will be 15 idle consumers 2024-11-21 11:07:27.387Z WARN 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [main] org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner : The number of expected partitions for topic annotation_device_ngps_simba was: 30, but 15 have been found instead. There will be 15 idle consumers 2024-11-21 11:07:28.973Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='notification_event_ngps_simba', partitions=1, dlqName='null'}.container-0-C-1] org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder$2 : xxx-xxxxxxx-annotation_consumer_notification_event_ngps_simba: partitions assigned: [notification_event_ngps_simba-0] 2024-11-21 11:07:30.146Z WARN 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [main] org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner : The number of expected partitions for topic outbound_resend_ngps_simba was: 30, but 2 have been found instead. There will be 28 idle consumers 2024-11-21 11:07:30.296Z WARN 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [main] org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner : The number of expected partitions for topic annotation_internal_ngps_simba was: 30, but 15 have been found instead. There will be 15 idle consumers 2024-11-21 11:07:30.438Z WARN 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [main] org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner : The number of expected partitions for topic annotation_device_ngps_simba was: 30, but 15 have been found instead. There will be 15 idle consumers 2024-11-21 11:07:30.554Z WARN 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [main] org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner : The number of expected partitions for topic outbound_resend_ngps_simba was: 30, but 2 have been found instead. There will be 28 idle consumers 2024-11-21 11:07:30.556Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [main] org.springframework.cloud.stream.binder.BinderErrorChannel : Channel 'kafka-452827175.transformToOutboundAnnotation-in-0.errors' has 1 subscriber(s). 2024-11-21 11:07:30.557Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [main] org.springframework.cloud.stream.binder.BinderErrorChannel : Channel 'kafka-452827175.transformToOutboundAnnotation-in-0.errors' has 0 subscriber(s). 2024-11-21 11:07:30.557Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [main] org.springframework.cloud.stream.binder.BinderErrorChannel : Channel 'kafka-452827175.transformToOutboundAnnotation-in-0.errors' has 1 subscriber(s). 2024-11-21 11:07:30.557Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [main] org.springframework.cloud.stream.binder.BinderErrorChannel : Channel 'kafka-452827175.transformToOutboundAnnotation-in-0.errors' has 2 subscriber(s). 2024-11-21 11:07:32.642Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [main] org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter : started org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter@33d2e82 2024-11-21 11:07:32.644Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [main] org.springframework.cloud.stream.binder.kafka.KafkaBinderMetrics : Try to shutdown the old scheduler with 1 threads 2024-11-21 11:07:32.747Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [main] com.ge.dcs.outboundannotation.OutboundAnnotationSvcApplication : Started OutboundAnnotationSvcApplication in 33.678 seconds (process running for 35.627) 2024-11-21 11:07:33.911Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-21-C-1] org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder$2 : xxx-xxxxxxx-annotation_consumer_ngps_simba: partitions assigned: [] 2024-11-21 11:07:33.921Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-11-C-1] org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder$2 : xxx-xxxxxxx-annotation_consumer_ngps_simba: partitions assigned: [annotation_device_ngps_simba-8, annotation_internal_ngps_simba-8] 2024-11-21 11:07:33.931Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-12-C-1] org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder$2 : xxx-xxxxxxx-annotation_consumer_ngps_simba: partitions assigned: [annotation_device_ngps_simba-9, annotation_internal_ngps_simba-9] 2024-11-21 11:07:33.932Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-22-C-1] org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder$2 : xxx-xxxxxxx-annotation_consumer_ngps_simba: partitions assigned: [] 2024-11-21 11:07:33.933Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-18-C-1] org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder$2 : xxx-xxxxxxx-annotation_consumer_ngps_simba: partitions assigned: [] 2024-11-21 11:07:33.933Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-28-C-1] org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder$2 : xxx-xxxxxxx-annotation_consumer_ngps_simba: partitions assigned: [] 2024-11-21 11:07:33.912Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-1-C-1] org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder$2 : xxx-xxxxxxx-annotation_consumer_ngps_simba: partitions assigned: [] 2024-11-21 11:07:33.933Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-20-C-1] org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder$2 : xxx-xxxxxxx-annotation_consumer_ngps_simba: partitions assigned: [] 2024-11-21 11:07:33.934Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-24-C-1] org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder$2 : xxx-xxxxxxx-annotation_consumer_ngps_simba: partitions assigned: [] 2024-11-21 11:07:33.934Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-27-C-1] org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder$2 : xxx-xxxxxxx-annotation_consumer_ngps_simba: partitions assigned: [] 2024-11-21 11:07:33.934Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-26-C-1] org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder$2 : xxx-xxxxxxx-annotation_consumer_ngps_simba: partitions assigned: [] 2024-11-21 11:07:33.935Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-19-C-1] org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder$2 : xxx-xxxxxxx-annotation_consumer_ngps_simba: partitions assigned: [] 2024-11-21 11:07:33.935Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-23-C-1] org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder$2 : xxx-xxxxxxx-annotation_consumer_ngps_simba: partitions assigned: [] 2024-11-21 11:07:33.912Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-2-C-1] org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder$2 : xxx-xxxxxxx-annotation_consumer_ngps_simba: partitions assigned: [] 2024-11-21 11:07:33.935Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-25-C-1] org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder$2 : xxx-xxxxxxx-annotation_consumer_ngps_simba: partitions assigned: [] 2024-11-21 11:07:33.912Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-0-C-1] org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder$2 : xxx-xxxxxxx-annotation_consumer_ngps_simba: partitions assigned: [] 2024-11-21 11:07:33.936Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-29-C-1] org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder$2 : xxx-xxxxxxx-annotation_consumer_ngps_simba: partitions assigned: [] 2024-11-21 11:07:33.960Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-17-C-1] org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder$2 : xxx-xxxxxxx-annotation_consumer_ngps_simba: partitions assigned: [annotation_device_ngps_simba-14, annotation_internal_ngps_simba-14] 2024-11-21 11:07:33.965Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-15-C-1] org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder$2 : xxx-xxxxxxx-annotation_consumer_ngps_simba: partitions assigned: [annotation_device_ngps_simba-12, annotation_internal_ngps_simba-12] 2024-11-21 11:07:33.966Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-8-C-1] org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder$2 : xxx-xxxxxxx-annotation_consumer_ngps_simba: partitions assigned: [annotation_device_ngps_simba-5, annotation_internal_ngps_simba-5] 2024-11-21 11:07:33.966Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-14-C-1] org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder$2 : xxx-xxxxxxx-annotation_consumer_ngps_simba: partitions assigned: [annotation_device_ngps_simba-11, annotation_internal_ngps_simba-11] 2024-11-21 11:07:33.967Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-7-C-1] org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder$2 : xxx-xxxxxxx-annotation_consumer_ngps_simba: partitions assigned: [annotation_device_ngps_simba-4, annotation_internal_ngps_simba-4] 2024-11-21 11:07:33.970Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-4-C-1] org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder$2 : xxx-xxxxxxx-annotation_consumer_ngps_simba: partitions assigned: [annotation_device_ngps_simba-1, annotation_internal_ngps_simba-1, outbound_resend_ngps_simba-1] 2024-11-21 11:07:33.971Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-6-C-1] org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder$2 : xxx-xxxxxxx-annotation_consumer_ngps_simba: partitions assigned: [annotation_device_ngps_simba-3, annotation_internal_ngps_simba-3] 2024-11-21 11:07:34.032Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-10-C-1] org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder$2 : xxx-xxxxxxx-annotation_consumer_ngps_simba: partitions assigned: [annotation_device_ngps_simba-7, annotation_internal_ngps_simba-7] 2024-11-21 11:07:34.032Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-3-C-1] org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder$2 : xxx-xxxxxxx-annotation_consumer_ngps_simba: partitions assigned: [annotation_device_ngps_simba-0, annotation_internal_ngps_simba-0, outbound_resend_ngps_simba-0] 2024-11-21 11:07:34.032Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-9-C-1] org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder$2 : xxx-xxxxxxx-annotation_consumer_ngps_simba: partitions assigned: [annotation_device_ngps_simba-6, annotation_internal_ngps_simba-6] 2024-11-21 11:07:34.032Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-16-C-1] org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder$2 : xxx-xxxxxxx-annotation_consumer_ngps_simba: partitions assigned: [annotation_device_ngps_simba-13, annotation_internal_ngps_simba-13] 2024-11-21 11:07:34.032Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-13-C-1] org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder$2 : xxx-xxxxxxx-annotation_consumer_ngps_simba: partitions assigned: [annotation_device_ngps_simba-10, annotation_internal_ngps_simba-10] 2024-11-21 11:07:34.032Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-5-C-1] org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder$2 : xxx-xxxxxxx-annotation_consumer_ngps_simba: partitions assigned: [annotation_device_ngps_simba-2, annotation_internal_ngps_simba-2] 2024-11-21 11:07:34.281Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-11-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : Started parsing 2024-11-21 11:07:34.846Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-11-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : getOutputMessagePayload - started 2024-11-21 11:07:36.036Z ERROR 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-11-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : Invalid Configuration. FACILITY map-code not configured for bedLocationId:61f66bc1-12d8-4a2e-b2d5-f58424dfc984 Invalid Configuration. BED map-code not configured for bedLocationId:61f66bc1-12d8-4a2e-b2d5-f58424dfc984 for message control id 184fe4ea-ced9-4abe-922c-87ce33b659f7 and InternalID 9907274e-172a-43a4-aa33-1a9357e682c2 2024-11-21 11:07:36.038Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-11-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : Started parsing 2024-11-21 11:07:36.039Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-11-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : getOutputMessagePayload - started 2024-11-21 11:07:36.050Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [task-1] com.ge.dcs.audit.service.AuditServiceImpl : Successfully added audit to queue: com.ge.dcs.audit.model.Audit@62c2a1ca 2024-11-21 11:07:36.079Z ERROR 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-11-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : Invalid Configuration. FACILITY map-code not configured for bedLocationId:61f66bc1-12d8-4a2e-b2d5-f58424dfc984 Invalid Configuration. BED map-code not configured for bedLocationId:61f66bc1-12d8-4a2e-b2d5-f58424dfc984 for message control id 126ce3a6-6440-41f4-95b8-84c387dca846 and InternalID 9907274e-172a-43a4-aa33-1a9357e682c2 2024-11-21 11:07:36.080Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-11-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : Started parsing 2024-11-21 11:07:36.082Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [task-2] com.ge.dcs.audit.service.AuditServiceImpl : Successfully added audit to queue: com.ge.dcs.audit.model.Audit@5e918b46 2024-11-21 11:07:36.083Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-11-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : getOutputMessagePayload - started 2024-11-21 11:07:36.133Z ERROR 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-11-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : Invalid Configuration. FACILITY map-code not configured for bedLocationId:61f66bc1-12d8-4a2e-b2d5-f58424dfc984 Invalid Configuration. BED map-code not configured for bedLocationId:61f66bc1-12d8-4a2e-b2d5-f58424dfc984 for message control id c4441801-81cd-400f-8c1e-c94df0a9af8e and InternalID 9907274e-172a-43a4-aa33-1a9357e682c2 2024-11-21 11:07:36.134Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-11-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : Started parsing 2024-11-21 11:07:36.134Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-11-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : getOutputMessagePayload - started 2024-11-21 11:07:36.136Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [task-3] com.ge.dcs.audit.service.AuditServiceImpl : Successfully added audit to queue: com.ge.dcs.audit.model.Audit@60180c6b 2024-11-21 11:07:36.176Z ERROR 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-11-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : Invalid Configuration. FACILITY map-code not configured for bedLocationId:61f66bc1-12d8-4a2e-b2d5-f58424dfc984 Invalid Configuration. BED map-code not configured for bedLocationId:61f66bc1-12d8-4a2e-b2d5-f58424dfc984 for message control id 75e6c5e0-c99a-40cf-8dc8-6eb7ac478cf4 and InternalID 9907274e-172a-43a4-aa33-1a9357e682c2 2024-11-21 11:07:36.178Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [task-4] com.ge.dcs.audit.service.AuditServiceImpl : Successfully added audit to queue: com.ge.dcs.audit.model.Audit@3c1c78bc 2024-11-21 11:07:36.947Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [scheduling-1] org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner : Using kafka topic for outbound: audit_event_ngps_simba 2024-11-21 11:07:38.455Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [scheduling-1] org.springframework.cloud.stream.messaging.DirectWithAttributesChannel : Channel 'xxx-xxxxxxx-xxx-xxxxxxx.auditOutput-out-0' has 1 subscriber(s). 2024-11-21 11:07:38.456Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [scheduling-1] org.springframework.cloud.stream.binder.kafka.KafkaBinderMetrics : Try to shutdown the old scheduler with 4 threads 2024-11-21 11:07:42.202Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-11-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : Started parsing 2024-11-21 11:07:42.204Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-11-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : getOutputMessagePayload - started 2024-11-21 11:07:42.244Z ERROR 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-11-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : Invalid Configuration. FACILITY map-code not configured for bedLocationId:61f66bc1-12d8-4a2e-b2d5-f58424dfc984 Invalid Configuration. BED map-code not configured for bedLocationId:61f66bc1-12d8-4a2e-b2d5-f58424dfc984 for message control id 95f0514b-d844-4638-8809-41e5c36111ea and InternalID 9907274e-172a-43a4-aa33-1a9357e682c2 2024-11-21 11:07:42.246Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [task-5] com.ge.dcs.audit.service.AuditServiceImpl : Successfully added audit to queue: com.ge.dcs.audit.model.Audit@12cc46d5 2024-11-21 11:07:42.248Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-11-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : Started parsing 2024-11-21 11:07:42.248Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-11-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : getOutputMessagePayload - started 2024-11-21 11:07:42.284Z ERROR 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-11-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : Invalid Configuration. FACILITY map-code not configured for bedLocationId:61f66bc1-12d8-4a2e-b2d5-f58424dfc984 Invalid Configuration. BED map-code not configured for bedLocationId:61f66bc1-12d8-4a2e-b2d5-f58424dfc984 for message control id 31db7fab-0349-4a8c-852c-ed6bd6079c67 and InternalID 9907274e-172a-43a4-aa33-1a9357e682c2 2024-11-21 11:07:42.287Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [task-6] com.ge.dcs.audit.service.AuditServiceImpl : Successfully added audit to queue: com.ge.dcs.audit.model.Audit@880375b9 2024-11-21 11:07:42.288Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-11-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : Started parsing 2024-11-21 11:07:42.289Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-11-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : getOutputMessagePayload - started 2024-11-21 11:07:42.321Z ERROR 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-11-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : Invalid Configuration. FACILITY map-code not configured for bedLocationId:61f66bc1-12d8-4a2e-b2d5-f58424dfc984 Invalid Configuration. BED map-code not configured for bedLocationId:61f66bc1-12d8-4a2e-b2d5-f58424dfc984 for message control id 457a2025-0491-4b45-888a-55a2e01cc950 and InternalID 9907274e-172a-43a4-aa33-1a9357e682c2 2024-11-21 11:07:42.323Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-11-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : Started parsing 2024-11-21 11:07:42.323Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-11-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : getOutputMessagePayload - started 2024-11-21 11:07:42.323Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [task-7] com.ge.dcs.audit.service.AuditServiceImpl : Successfully added audit to queue: com.ge.dcs.audit.model.Audit@6a3683d9 2024-11-21 11:07:42.359Z ERROR 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-11-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : Invalid Configuration. FACILITY map-code not configured for bedLocationId:61f66bc1-12d8-4a2e-b2d5-f58424dfc984 Invalid Configuration. BED map-code not configured for bedLocationId:61f66bc1-12d8-4a2e-b2d5-f58424dfc984 for message control id 523a5815-955f-4473-8903-98f79bebd48c and InternalID 9907274e-172a-43a4-aa33-1a9357e682c2 2024-11-21 11:07:42.361Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [task-8] com.ge.dcs.audit.service.AuditServiceImpl : Successfully added audit to queue: com.ge.dcs.audit.model.Audit@b83df94 2024-11-21 11:07:51.920Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-16-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : Started parsing 2024-11-21 11:07:51.921Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-16-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : getOutputMessagePayload - started mapCodeRuleList---start wa ro bd si mapCodeRuleList---end mapCodeRuleList.size()---4 inputMapCode.length---4 2024-11-21 11:07:52.022Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-9-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : Started parsing 2024-11-21 11:07:52.023Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-9-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : getOutputMessagePayload - started mapCodeRuleList---start wa ro bd si mapCodeRuleList---end mapCodeRuleList.size()---4 inputMapCode.length---4 2024-11-21 11:07:52.671Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-9-C-1] com.ge.dcs.outboundannotation.service.ItemConfigurationDataServiceImpl : Cache item configurations::Success. for message control id 55967f22-81c3-463e-9a36-2ba6d2ea2bbd 2024-11-21 11:07:52.672Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-16-C-1] com.ge.dcs.outboundannotation.service.ItemConfigurationDataServiceImpl : Cache item configurations::Success. for message control id 4335458f-15e9-4567-b217-64eaabbc9286 2024-11-21 11:07:52.676Z ERROR 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-9-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : No HL7ExternalId mapping found for input observations for message control id 55967f22-81c3-463e-9a36-2ba6d2ea2bbd and InternalID 9171d1de-e9b4-4019-a6e6-b319f81ce3b3 2024-11-21 11:07:52.678Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [task-1] com.ge.dcs.audit.service.AuditServiceImpl : Successfully added audit to queue: com.ge.dcs.audit.model.Audit@1e902f0 2024-11-21 11:07:52.679Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-16-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : getOutBoundAnnotationBundle - 1 2024-11-21 11:07:52.685Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-9-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : Started parsing 2024-11-21 11:07:52.686Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-9-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : getOutputMessagePayload - started 2024-11-21 11:07:52.737Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-16-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : !!!!!!!!!!!!getOutputMessagePayload 2024-11-21 11:07:52.737Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-16-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : getOutputMessageHeaders!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!! 2024-11-21 11:07:52.738Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-16-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : End parsing 2024-11-21 11:07:52.738Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-16-C-1] com.ge.dcs.outboundannotation.bindings.StreamBridgeBinding : key: id, value: 5d3e322e-bd5f-0df2-e857-6fc64840d9e8 2024-11-21 11:07:52.738Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-16-C-1] com.ge.dcs.outboundannotation.bindings.StreamBridgeBinding : key: timestamp, value: 1732187272738 2024-11-21 11:07:52.739Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-16-C-1] com.ge.dcs.outboundannotation.bindings.StreamBridgeBinding : DataremeKey deviceSessionIdentifier: 5d3e322e-bd5f-0df2-e857-6fc64840d9e8 mapCodeRuleList---start wa ro bd si mapCodeRuleList---end mapCodeRuleList.size()---4 inputMapCode.length---4 2024-11-21 11:07:52.766Z ERROR 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-9-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : No HL7ExternalId mapping found for input observations for message control id ba8e6f4d-b3f0-4cc2-b9fe-73f96c11204f and InternalID 9171d1de-e9b4-4019-a6e6-b319f81ce3b3 2024-11-21 11:07:52.768Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [task-2] com.ge.dcs.audit.service.AuditServiceImpl : Successfully added audit to queue: com.ge.dcs.audit.model.Audit@f4fe7d95 2024-11-21 11:07:52.867Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-16-C-1] org.springframework.cloud.stream.binder.DefaultBinderFactory : Creating binder: ddpKafkaBinder 2024-11-21 11:07:52.867Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-16-C-1] org.springframework.cloud.stream.binder.DefaultBinderFactory : Constructing binder child context for ddpKafkaBinder 2024-11-21 11:07:53.576Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-16-C-1] org.springframework.cloud.stream.binder.DefaultBinderFactory : Caching the binder: ddpKafkaBinder 2024-11-21 11:07:53.577Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-16-C-1] org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner : Using kafka topic for outbound: ddp-emr-fhirobsout-ld-gehc-blr1 2024-11-21 11:07:54.548Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-16-C-1] org.springframework.cloud.stream.messaging.DirectWithAttributesChannel : Channel 'xxx-xxxxxxx-xxx-xxxxxxx.output-out-0' has 1 subscriber(s). 2024-11-21 11:07:54.555Z ERROR 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-16-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : Cannot invoke "Object.getClass()" because "result" is null 2024-11-21 11:07:54.557Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [task-3] com.ge.dcs.audit.service.AuditServiceImpl : Successfully added audit to queue: com.ge.dcs.audit2024-11-21 11:08:00.388Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-16-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : getOutputMessagePayload - started 2024-11-21 11:08:00.424Z ERROR 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-16-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : Invalid Configuration. FACILITY map-code not configured for bedLocationId:61f66bc1-12d8-4a2e-b2d5-f58424dfc984 Invalid Configuration. BED map-code not configured for bedLocationId:61f66bc1-12d8-4a2e-b2d5-f58424dfc984 for message control id 95d2a463-bf83-488b-88a7-185802d37176 and InternalID 9907274e-172a-43a4-aa33-1a9357e682c2 .model.Audit@747b0b62 2024-11-21 11:08:00.431Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-16-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : Started parsing 2024-11-21 11:08:00.432Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-16-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : getOutputMessagePayload - started 2024-11-21 11:08:00.465Z ERROR 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-16-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : Invalid Configuration. FACILITY map-code not configured for bedLocationId:61f66bc1-12d8-4a2e-b2d5-f58424dfc984 Invalid Configuration. BED map-code not configured for bedLocationId:61f66bc1-12d8-4a2e-b2d5-f58424dfc984 for message control id 9ef1891d-3dff-4bf6-8c86-11a880742f1d and InternalID 9907274e-172a-43a4-aa33-1a9357e682c2 2024-11-21 11:08:00.466Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-16-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : Started parsing 2024-11-21 11:08:00.466Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-16-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : getOutputMessagePayload - started 2024-11-21 11:08:00.466Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [task-5] com.ge.dcs.audit.service.AuditServiceImpl : Successfully added audit to queue: com.ge.dcs.audit.model.Audit@6a433dee 2024-11-21 11:08:00.496Z ERROR 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-16-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : Invalid Configuration. FACILITY map-code not configured for bedLocationId:61f66bc1-12d8-4a2e-b2d5-f58424dfc984 Invalid Configuration. BED map-code not configured for bedLocationId:61f66bc1-12d8-4a2e-b2d5-f58424dfc984 for message control id 299a99de-8dfc-4814-ac04-c7604cd51771 and InternalID 9907274e-172a-43a4-aa33-1a9357e682c2 2024-11-21 11:08:00.497Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-16-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : Started parsing 2024-11-21 11:08:00.498Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [task-6] com.ge.dcs.audit.service.AuditServiceImpl : Successfully added audit to queue: com.ge.dcs.audit.model.Audit@478e5f91 2024-11-21 11:08:00.498Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-16-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : getOutputMessagePayload - started 2024-11-21 11:08:00.531Z ERROR 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-16-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : Invalid Configuration. FACILITY map-code not configured for bedLocationId:61f66bc1-12d8-4a2e-b2d5-f58424dfc984 Invalid Configuration. BED map-code not configured for bedLocationId:61f66bc1-12d8-4a2e-b2d5-f58424dfc984 for message control id 381dfc3b-c560-466f-894b-737ba7ad2c0b and InternalID 9907274e-172a-43a4-aa33-1a9357e682c2 2024-11-21 11:08:00.532Z INFO 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [task-7] com.ge.dcs.audit.service.AuditServiceImpl : Successfully added audit to queue: com.ge.dcs.audit.model.Audit@a586a8c3

Sunils1456 commented 1 day ago

please let me know it is ok for you..

olegz commented 1 day ago

You seem to not know what stack trace is. . . In any event, loo0king at the log there seems to be some infrustructire issue on your end either with your code or Glue or . . .

2024-11-21 11:07:36.133Z ERROR 1 --- [xxx-xxxxxxx-xxx-xxxxxxx] Tenant: simba-ngps [KafkaConsumerDestination{consumerDestinationName='annotation_internal_ngps_simba,annotation_device_ngps_simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-11-C-1] com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer : Invalid Configuration. FACILITY map-code not configured for bedLocationId:61f66bc1-12d8-4a2e-b2d5-f58424dfc984 Invalid Configuration. BED map-code not configured for bedLocationId:61f66bc1-12d8-4a2e-b2d5-f58424dfc984 for message control id c4441801-81cd-400f-8c1e-c94df0a9af8e and InternalID 9907274e-172a-43a4-aa33-1a9357e682c2

In any event, it does not appear to be something on s-c-stream side

Sunils1456 commented 1 day ago

The stack trace is not being printed because the try-catch block where you have ex.printStackTrace(); is not being executed. Therefore, I do not have the trace log to share with you.

Sunils1456 commented 1 day ago

logs-

------
It would be help you to analysis this issue_
simba,outbound_resend_ngps_simba', partitions=0, dlqName='null'}.container-14-C-1] org.springframework.cloud.stream.messaging.DirectWithAttributesChannel : Channel 'dcs-outbound-annotation-svc.output-out-0' has 1 subscriber(s).
java.lang.NullPointerException: Cannot invoke "Object.getClass()" because "result" is null
        at org.springframework.cloud.function.cloudevent.CloudEventsFunctionInvocationHelper.doPostProcessResult(CloudEventsFunctionInvocationHelper.java:138)
        at org.springframework.cloud.function.cloudevent.CloudEventsFunctionInvocationHelper.postProcessResult(CloudEventsFunctionInvocationHelper.java:114)
        at org.springframework.cloud.function.cloudevent.CloudEventsFunctionInvocationHelper.postProcessResult(CloudEventsFunctionInvocationHelper.java:48)
        at org.springframework.cloud.stream.function.StreamBridge.send(StreamBridge.java:214)
        at org.springframework.cloud.stream.function.StreamBridge.send(StreamBridge.java:168)
        at org.springframework.cloud.stream.function.StreamBridge.send(StreamBridge.java:163)
        at com.ge.dcs.outboundannotation.bindings.StreamBridgeBinding.sendMessage(StreamBridgeBinding.java:89)
        at com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer.publishOutputMessage_aroundBody2(AnnotationsTransformer.java:157)
        at com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer$AjcClosure3.run(AnnotationsTransformer.java:1)
        at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:171)
        at com.ge.dcs.aspects.aspect.LogMetricsAspect.computeMethodExecutionTime(LogMetricsAspect.java:93)
        at com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer.publishOutputMessage(AnnotationsTransformer.java:156)
        at com.ge.dcs.outboundannotation.transformer.AnnotationsTransformer.lambda$0(AnnotationsTransformer.java:132)
        at org.springframework.cloud.function.context.catalog.SimpleFunctionRegistry$FunctionInvocationWrapper.invokeConsumer(SimpleFunctionRegistry.java:1039)
        at org.springframework.cloud.function.context.catalog.SimpleFunctionRegistry$FunctionInvocationWrapper.doApply(SimpleFunctionRegistry.java:737)
        at org.springframework.cloud.function.context.catalog.SimpleFunctionRegistry$FunctionInvocationWrapper.apply(SimpleFunctionRegistry.java:580)
        at org.springframework.cloud.function.observability.ObservationFunctionAroundWrapper.lambda$nonReactorStream$0(ObservationFunctionAroundWrapper.java:50)
        at io.micrometer.observation.Observation.observe(Observation.java:565)
        at org.springframework.cloud.function.observability.ObservationFunctionAroundWrapper.nonReactorStream(ObservationFunctionAroundWrapper.java:50)
        at org.springframework.cloud.function.observability.ObservationFunctionAroundWrapper.doApply(ObservationFunctionAroundWrapper.java:45)
        at org.springframework.cloud.function.context.catalog.FunctionAroundWrapper.apply(FunctionAroundWrapper.java:47)
        at org.springframework.cloud.function.context.catalog.SimpleFunctionRegistry$FunctionInvocationWrapper.apply(SimpleFunctionRegistry.java:577)
        at org.springframework.cloud.stream.function.PartitionAwareFunctionWrapper.apply(PartitionAwareFunctionWrapper.java:92)
        at org.springframework.cloud.stream.function.FunctionConfiguration$FunctionWrapper.apply(FunctionConfiguration.java:823)
        at org.springframework.cloud.stream.function.FunctionConfiguration$FunctionToDestinationBinder$1.handleMessageInternal(FunctionConfiguration.java:654)
        at org.springframework.integration.handler.AbstractMessageHandler.doHandleMessage(AbstractMessageHandler.java:105)
        at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:73)
        at org.springframework.integration.dispatcher.AbstractDispatcher.tryOptimizedDispatch(AbstractDispatcher.java:132)
        at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:148)
        at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:121)
        at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:72)
        at org.springframework.integration.channel.AbstractMessageChannel.sendInternal(AbstractMessageChannel.java:390)
        at org.springframework.integration.channel.AbstractMessageChannel.sendWithMetrics(AbstractMessageChannel.java:361)
        at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:331)
        at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:304)
        at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:187)
        at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:166)
        at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:47)
        at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:109)
        at org.springframework.integration.endpoint.MessageProducerSupport.lambda$sendMessage$1(MessageProducerSupport.java:262)
        at io.micrometer.observation.Observation.observe(Observation.java:499)
        at org.springframework.integration.endpoint.MessageProducerSupport.sendMessage(MessageProducerSupport.java:262)
        at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter.sendMessageIfAny(KafkaMessageDrivenChannelAdapter.java:391)
        at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter$IntegrationRecordMessageListener.onMessage(KafkaMessageDrivenChannelAdapter.java:465)
        at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter$IntegrationRecordMessageListener.onMessage(KafkaMessageDrivenChannelAdapter.java:422)
        at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2800)
        at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2778)
        at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.lambda$doInvokeRecordListener$53(KafkaMessageListenerContainer.java:2701)
        at io.micrometer.observation.Observation.observe(Observation.java:565)
        at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2699)
        at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2541)
        at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2430)
        at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:2085)
        at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1461)
        at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1426)
        at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1296)
        at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(Unknown Source)
        at java.base/java.lang.Thread.run(Unknown Source)
olegz commented 1 day ago

Actually this is not the log butt the stack trace i was asking for and i can see part of the issue in CloudEventsFunctionInvocationHelper, which may not help you since i can still see that your actual issue is in misconfigurarion of your environment and are not related to s-c-stream

olegz commented 1 day ago

Also, what version of s-c-stream you re using?

Sunils1456 commented 16 hours ago 
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-stream-binder-kafka</artifactId>
        <version>4.1.3</version>
    </dependency>

   <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-stream-schema-registry-client</artifactId>
        <version>4.1.3</version>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-function-context</artifactId>
        <version>4.1.3</version>
    </dependency>