Kafka communication fault caused cmHandle registration error

Current behavior

Kafka communication error causing cmHandle registration error
Kafka was unreachable when cmHandle registration was ongoing, got the following error:

500 Server Error: "{"failedCreatedCmHandles":[

{"cmHandle":"92470BAE77D70EB66734BEDA1670D59B","errorCode":"00","errorText":"Send failed; nested exception is org.apache.kafka.common.errors.TimeoutException: Topic ncmp-events not present in metadata after 60000 ms."}

,{"cmHandle":"04C35B8EB3994333C66AE76A2D668FF3","errorCode":"00","errorText":"Send failed; nested exception is org.apache.kafka.common.errors.TimeoutException: Topic ncmp-events not present in metadata after 60000 ms."},{"cmHandle":"7287898E7F560C5E29719D24CA7D7D0D","errorCode":"00","errorText":"Send failed; nested exception is org.apache.kafka.common.errors.TimeoutException: Topic ncmp-events not present in metadata after 60000 ms."},{"cmHandle":"17530C77CCC10E625E100A8AABB17DE1","errorCode":"00","errorText":"Send failed; nested exception is org.apache.kafka.common.errors.TimeoutException: Topic ncmp-events not present in metadata after 60000 ms."},{"cmHandle":"3A08022A97A6BA26F386B087B38F4357","errorCode":"00","errorText":"Send failed; nested exception is org.apache.kafka.common.errors.TimeoutException: Topic ncmp-events not present in metadata after 60000 ms."},{"cmHandle":"A7D1B4758C30EC14C8976AA328D0502F","errorCode":"00","errorText":"Send failed; nested exception is org.apache.kafka.common.errors.TimeoutException: Topic ncmp-events not present in metadata after 60000 ms."},{"cmHandle":"A551D4D5BF6971283BC45033C5FF8635","errorCode":"00","errorText":"Send failed; nested exception is org.apache.kafka.common.errors.TimeoutException: Topic ncmp-events not present in metadata after 60000 ms."},{"cmHandle":"0A435F55DFAA0CA3E2A858D9FBAFD11D","errorCode":"00","errorText":"Send failed; nested exception is org.apache.kafka.common.errors.TimeoutException: Topic ncmp-events not present in metadata after 60000 ms."}

 

Expected behavior

I think that the cmHandle registration should not fail if NCMP can not send ADVISED state event to kafka during the registration

 

Reproduction

• Stop kafka instance
• Register a cmHandle
• CmHandle got registered and went to ready state, but got 500 INTERNAL_SERVER_ERROR on the request

 

Logs:

kafka-error-discovery.log       

kafka-error-ncmp.log

Workaround

Deregister and register cmHandles again after kafka connection established again

 

CPS version

https://gerrit.onap.org/r/gitweb?p=cps.git;a=commit;h=a59c24e665e30d5d47341b2c77cb65ae7118d849