Skip to content

Commit

Permalink
Add new CruiseControlTaskOperation to represent Status Cruise Control…
Browse files Browse the repository at this point in the history
… Operation

When the request on /state endpoint of CC takes longer than webserver.request.maxBlockTimeMs,
then CC will convert the request into an async task and will respond with the taskID instead
of the result. The Koperator should handle this case by waiting for CC to complete the task.
  • Loading branch information
aguzovatii committed May 16, 2023
1 parent 27bfa47 commit 6a8d8f9
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions api/v1alpha1/common_types.go
Original file line number Diff line number Diff line change
Expand Up @@ -46,6 +46,8 @@ const (
OperationRemoveBroker CruiseControlTaskOperation = "remove_broker"
// OperationRebalance means a Cruise Control rebalance operation
OperationRebalance CruiseControlTaskOperation = "rebalance"
// OperationStatus means a Cruise Control status operation
OperationStatus CruiseControlTaskOperation = "status"
// KafkaAccessTypeRead states that a user wants consume access to a topic
KafkaAccessTypeRead KafkaAccessType = "read"
// KafkaAccessTypeWrite states that a user wants produce access to a topic
Expand Down

0 comments on commit 6a8d8f9

Please sign in to comment.