-
Notifications
You must be signed in to change notification settings - Fork 1.3k
Feature/topology visualizer contract #205 #639
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
SonarCloud Quality Gate failed.
|
…on cluster and application level
Simplified the data model for now - it contains information about the topology of only one application and without kafka connectors. {
"processorsNumber": null,
"topicsNumber": null,
"topology": {
"adjacency": {
"sub-topology 0": [
"count-resolved-repartition"
],
"count-resolved-repartition": [
"sub-topology 1"
],
"sub-topology 1": []
},
"nodes": {
"sub-topology 0": {
"name": "sub-topology 0",
"type": "SUB_TOPOLOGY",
"subTopology": {
"adjacency": {
"KSTREAM-SOURCE-0000000000": [
"KSTREAM-TRANSFORM-0000000001"
],
"KSTREAM-TRANSFORM-0000000001": [
"KSTREAM-SINK-000000002"
],
"KSTREAM-SINK-000000002": []
},
"nodes": {
"KSTREAM-SOURCE-0000000000": {
"name": "KSTREAM-SOURCE-0000000000",
"type": "SOURCE_PROCESSOR",
"topics": [
"inputTopic"
]
},
"KSTREAM-TRANSFORM-0000000001": {
"name": "KSTREAM-TRANSFORM-0000000001",
"type": "PROCESSOR",
"stores": [
"store 1"
]
},
"KSTREAM-SINK-000000002": {
"name": "KSTREAM-SINK-000000002",
"type": "SINK_PROCESSOR",
"topic": "count-resolved-repartition"
}
}
}
},
"count-resolved-repartition": {
"name": "count-resolved-repartition",
"type": "TOPIC",
"inputMessagesNumber": null,
"outputMessagesNumber": null,
"lag": null
},
"sub-topology 1": {
"name": "sub-topology 1",
"type": "SUB_TOPOLOGY",
"subTopology": {
"adjacency": {
"KSTREAM-SOURCE-000000003": [
"KSTREAM-TRANSFORM-000000004"
],
"KSTREAM-TRANSFORM-000000004": [
"KSTREAM-SINK-000000005"
],
"KSTREAM-SINK-000000005": []
},
"nodes": {
"KSTREAM-SOURCE-000000003": {
"name": "KSTREAM-SOURCE-000000003",
"type": "SOURCE_PROCESSOR",
"topics": [
"count-resolved-repartition"
]
},
"KSTREAM-TRANSFORM-000000004": {
"name": "KSTREAM-TRANSFORM-000000004",
"type": "PROCESSOR",
"stores": [
"store 2"
]
},
"KSTREAM-SINK-000000005": {
"name": "KSTREAM-SINK-000000005",
"type": "SINK_PROCESSOR",
"topic": "streams-count-resolved"
}
}
}
}
}
}
} |
# Conflicts: # kafka-ui-contract/src/main/resources/swagger/kafka-ui-api.yaml
Kudos, SonarCloud Quality Gate passed! |
Kudos, SonarCloud Quality Gate passed!
|
LGTM for contract, let's implement reading / parsing part |
@germanosin should we merge it to unblock frontend? |
# Conflicts: # kafka-ui-api/src/main/java/com/provectus/kafka/ui/config/ClustersProperties.java # kafka-ui-api/src/main/java/com/provectus/kafka/ui/exception/ErrorCode.java # kafka-ui-contract/src/main/resources/swagger/kafka-ui-api.yaml
Kudos, SonarCloud Quality Gate passed! |
Kudos, SonarCloud Quality Gate passed!
|
# Conflicts: # kafka-ui-api/src/main/java/com/provectus/kafka/ui/config/ClustersProperties.java
Kudos, SonarCloud Quality Gate passed! |
Kudos, SonarCloud Quality Gate passed!
|
API contract for the stream topology visualization feature.
Please, review the data model for the API.
How Has This Been Tested? (put an "X" next to an item)
Checklist (put an "X" next to an item, otherwise PR will fail)
Check out Contributing and Code of Conduct