Ohara: the status of connector is lazy and it mislead pipeline to generate incorrect abstraction

[DavidMi-1]

Describe the bug
On manager UI , after start a pipeline with one ftp source connector and one topic, the graph cannot display states icon.
Response kind value should be 'source', but got 'connector'

To Reproduce
Steps to reproduce the behavior:

1. Go to 'Pipeline page'
2. Click on 'Add a source connector'
3. Add a 'FtpSourceConnector'
4. Click on 'Add a topic'
5. Add a 'Topic'
6. Click on 'FtpSource'
7. Field every columns at right side under tag 'COMMON'
8. Click on tag 'CORE'
9. Select topic
10. Click on 'Start pipeline'
11. Display 'Pipeline Has Been Successfully Start' info
12. But the 'FtpSource' dose not change it style, still show nothing

Expected behavior
After start pipeline, 'FtpSource' should display red fail icon

Screenshots

Operation System (please complete the following information):

• Backend OS & Version: CentOS 7.2
• Frontend OS & Version: CentOS 7.2
• Browser & Version: Chrome 76.0.3809.132

Additional context
Request header :

Accept: application/json, text/plain, */*
Accept-Encoding: gzip, deflate, br
Accept-Language: zh-TW,zh;q=0.9,en-US;q=0.8,en;q=0.7
Connection: keep-alive
Cookie: SESSION=a6f80299-4a66-4010-a96c-7071e85c80af; __lfcc=1
Host: localhost:3000
Referer: http://localhost:3000/pipelines/edit/wk00/xxxx/source/asdfasdfsf
Sec-Fetch-Mode: cors
Sec-Fetch-Site: same-origin
User-Agent: Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/76.0.3809.132 Safari/537.36

Reponse body :

{"name":"xxxx","lastModified":1568184818632,"tags":{"workerClusterName":"wk00"},"flows":[{"from":{"group":"wk00-xxxx","name":"asdfasdfsf"},"to":[{"group":"wk00-xxxx","name":"test-topic"}]},{"from":{"group":"wk00-topic","name":"test-topic"},"to":[]}],"objects":[{"name":"asdfasdfsf","lastModified":1568184831944,"tags":{},"error":"No status found for connector wk00-xxxx-asdfasdfsf","className":"com.island.ohara.connector.ftp.FtpSource","metrics":{"meters":[]},"kind":"connector","group":"wk00-xxxx"},{"name":"test-topic","state":"RUNNING","lastModified":1568173097198,"tags":{},"metrics":{"meters":[]},"kind":"topic","group":"wk00-topic"}],"group":"wk00-xxxx"}`

[chia7712]

seems kafka have inconsistent response of "exist" and "state" ... Let me take over this issue :)