package danube_admin
Get desktop application:
View/edit binary Protocol Buffers messages
service BrokerAdmin
DanubeAdmin.proto:24rpc ActivateBroker (, )
DanubeAdmin.proto:30message
DanubeAdmin.proto:361Activate Broker
string broker_id = 1
Target broker to activate (string id as published under /cluster/brokers/{broker_id})
string reason = 2
Optional reason for auditability
message
DanubeAdmin.proto:368bool success = 1
Load Balancing & Rebalancing RPCs (Phase 3)
message
DanubeAdmin.proto:375Request to get current cluster balance metrics
(message has no fields)
message
DanubeAdmin.proto:378Response containing cluster balance metrics
double coefficient_of_variation = 1
Coefficient of variation (0.0 = perfectly balanced, higher = more imbalanced)
double mean_load = 2
Mean load across all brokers (typically topic count)
double max_load = 3
Maximum load in the cluster
double min_load = 4
Minimum load in the cluster
double std_deviation = 5
Standard deviation of load
uint32 broker_count = 6
Number of active brokers
repeated brokers = 7
Detailed broker load information
string assignment_strategy = 8
Assignment strategy currently in use (fair, balanced, weighted_load)
rpc GetLeaderBroker (, )
DanubeAdmin.proto:27message
DanubeAdmin.proto:281string leader = 1
rpc ListBrokers (, )
DanubeAdmin.proto:26Broker related RPCs
message
DanubeAdmin.proto:268Response Messages
repeated brokers = 1
rpc ListNamespaces (, )
DanubeAdmin.proto:28message
DanubeAdmin.proto:285repeated string namespaces = 1
rpc TriggerRebalance (, )
DanubeAdmin.proto:34message
DanubeAdmin.proto:407Request to trigger manual rebalancing
bool dry_run = 1
If true, only calculate and return proposed moves without executing
optional uint32 max_moves = 2
Maximum number of topic moves to execute (default: from config)
message
DanubeAdmin.proto:415Response from rebalancing operation
bool success = 1
True if rebalancing was successful or dry-run completed
uint32 moves_executed = 2
Number of moves actually executed (0 for dry-run)
repeated proposed_moves = 3
Proposed or executed moves
string error_message = 4
Error message if success = false
rpc UnloadBroker (, )
DanubeAdmin.proto:29message
DanubeAdmin.proto:337Broker Unload
string broker_id = 1
Target broker to unload (string id as published under /cluster/brokers/{broker_id})
uint32 max_parallel = 2
Unload concurrency (default: 1)
repeated string namespaces_include = 3
Optional filters
repeated string namespaces_exclude = 4
bool dry_run = 5
Dry-run does not perform changes; returns the topics to be affected
uint32 timeout_seconds = 6
Per-topic timeout (seconds)
message
DanubeAdmin.proto:351bool started = 1
true if accepted/started
uint32 total = 2
uint32 succeeded = 3
uint32 failed = 4
uint32 pending = 5
repeated string failed_topics = 6
service ClusterAdmin
DanubeAdmin.proto:39Raft cluster membership management. These RPCs are forwarded to the Raft leader internally.
rpc AddNode (, )
DanubeAdmin.proto:44Add a node as a Raft learner (non-voting). It will receive snapshots + log.
message
DanubeAdmin.proto:454string addr = 1
Raft transport address of the new node, e.g. "broker4:7650"
uint64 node_id = 2
Optional: provide the node_id directly (discovered via transport if omitted)
message
DanubeAdmin.proto:461bool success = 1
uint64 node_id = 2
string message = 3
rpc ClusterStatus (, )
DanubeAdmin.proto:41Show Raft cluster state: leader, term, log index, voter/learner sets.
message
DanubeAdmin.proto:437uint64 leader_id = 1
Current Raft leader node_id (0 if no leader)
uint64 current_term = 2
Current Raft term
uint64 last_applied = 3
Last applied log index
repeated uint64 voters = 4
Node IDs of current voters
repeated uint64 learners = 5
Node IDs of current learners (non-voting)
uint64 self_node_id = 6
This node's own ID
string raft_addr = 7
This node's Raft transport address
rpc PromoteNode (, )
DanubeAdmin.proto:47Promote a learner to a full voting member.
message
DanubeAdmin.proto:467uint64 node_id = 1
message
DanubeAdmin.proto:471bool success = 1
string message = 2
rpc RemoveNode (, )
DanubeAdmin.proto:50Remove a node from the Raft voter/learner set.
message
DanubeAdmin.proto:476uint64 node_id = 1
message
DanubeAdmin.proto:480bool success = 1
string message = 2
rpc CreateNamespace (, )
DanubeAdmin.proto:57rpc DeleteNamespace (, )
DanubeAdmin.proto:58message
DanubeAdmin.proto:309string policies = 1
Namespace related RPCs
message
DanubeAdmin.proto:289repeated string topics = 1
rpc CreateBinding (, )
DanubeAdmin.proto:88Bindings
message
DanubeAdmin.proto:144optional binding = 1
message
DanubeAdmin.proto:148bool success = 1
rpc CreateRole (, )
DanubeAdmin.proto:82Roles
message
DanubeAdmin.proto:105optional role = 1
message
DanubeAdmin.proto:109bool success = 1
rpc DeleteBinding (, )
DanubeAdmin.proto:92message
DanubeAdmin.proto:171string scope = 1
string resource_name = 2
string binding_id = 3
message
DanubeAdmin.proto:177bool success = 1
rpc DeleteRole (, )
DanubeAdmin.proto:85message
DanubeAdmin.proto:125string name = 1
message
DanubeAdmin.proto:129bool success = 1
rpc GetBinding (, )
DanubeAdmin.proto:89message
DanubeAdmin.proto:152string scope = 1
string resource_name = 2
string binding_id = 3
message
DanubeAdmin.proto:158optional binding = 1
rpc GetRole (, )
DanubeAdmin.proto:83message
DanubeAdmin.proto:113string name = 1
message
DanubeAdmin.proto:117optional role = 1
rpc ListAllBindings (, )
DanubeAdmin.proto:91rpc ListBindings (, )
DanubeAdmin.proto:90message
DanubeAdmin.proto:162string scope = 1
"cluster", "namespace", "topic"
string resource_name = 2
"" for cluster scope
rpc ListRoles (, )
DanubeAdmin.proto:84message
DanubeAdmin.proto:121repeated roles = 1
service TopicAdmin
DanubeAdmin.proto:61message
DanubeAdmin.proto:206string base_name = 1
/namespace/topic
uint32 partitions = 2
number of partitions
optional string schema_subject = 3
Schema subject from Schema Registry (optional)
DispatchStrategy dispatch_strategy = 4
rpc CreateTopic (, )
DanubeAdmin.proto:65message
DanubeAdmin.proto:192string name = 1
optional string schema_subject = 2
Schema subject from Schema Registry (optional: topics can have no schema)
DispatchStrategy dispatch_strategy = 3
rpc DeleteTopic (, )
DanubeAdmin.proto:67rpc DescribeTopic (, )
DanubeAdmin.proto:73message
DanubeAdmin.proto:318Describe Topic (schema + subscriptions)
string name = 1
/namespace/topic
message
DanubeAdmin.proto:322string name = 1
repeated string subscriptions = 2
string broker_id = 3
string delivery = 4
delivery: Reliable | NonReliable
optional string schema_subject = 5
Schema Registry fields (all optional - topic may have no schema)
Schema subject name
optional uint64 schema_id = 6
Schema ID from registry
optional uint32 schema_version = 7
Schema version
optional string schema_type = 8
"json_schema", "avro", "protobuf", "string", "bytes"
optional string compatibility_mode = 9
"NONE", "BACKWARD", "FORWARD", "FULL"
message
DanubeAdmin.proto:258string topic = 1
string subscription = 2
message
DanubeAdmin.proto:263optional dispatch_config = 1
message
DanubeAdmin.proto:238string topic = 1
string subscription = 2
message
DanubeAdmin.proto:243optional failure_policy = 1
int32 subscription_type = 2
rpc ListBrokerTopics (, )
DanubeAdmin.proto:64message
DanubeAdmin.proto:305Request to address a specific broker
string broker_id = 1
Topic related RPCs
message
DanubeAdmin.proto:313repeated string subscriptions = 1
message
DanubeAdmin.proto:252string topic = 1
string subscription = 2
optional dispatch_config = 3
message
DanubeAdmin.proto:232string topic = 1
string subscription = 2
optional failure_policy = 3
rpc UnloadTopic (, )
DanubeAdmin.proto:68rpc Unsubscribe (, )
DanubeAdmin.proto:70message
DanubeAdmin.proto:213string topic = 1
string subscription = 2
message
DanubeAdmin.proto:135Used in: , ,
string id = 1
string principal_type = 2
"service_account", "user"
string principal_name = 3
repeated string role_names = 4
string scope = 5
"cluster", "namespace", "topic"
string resource_name = 6
"" for cluster, namespace name, or topic path
message
DanubeAdmin.proto:272Used in:
string broker_id = 1
string broker_addr = 2
string broker_role = 3
string admin_addr = 4
string metrics_addr = 5
string broker_status = 6
message
DanubeAdmin.proto:398Load information for a single broker
Used in:
uint64 broker_id = 1
double load = 2
uint32 topic_count = 3
bool is_overloaded = 4
bool is_underloaded = 5
Keep enums/messages consistent with danube/DanubeApi.proto
Used in: ,
NonReliable = 0
Reliable = 1
message
DanubeAdmin.proto:182Common Messages
Used as request type in: BrokerAdmin.GetLeaderBroker, BrokerAdmin.ListBrokers, BrokerAdmin.ListNamespaces, ClusterAdmin.ClusterStatus, SecurityAdmin.ListAllBindings, SecurityAdmin.ListRoles
(message has no fields)
message
DanubeAdmin.proto:167Used as response type in: SecurityAdmin.ListAllBindings, SecurityAdmin.ListBindings
repeated bindings = 1
message
DanubeAdmin.proto:184Used as request type in: NamespaceAdmin.CreateNamespace, NamespaceAdmin.DeleteNamespace, NamespaceAdmin.GetNamespacePolicies, NamespaceAdmin.GetNamespaceTopics, TopicAdmin.ListNamespaceTopics
string name = 1
message
DanubeAdmin.proto:188Used as response type in: NamespaceAdmin.CreateNamespace, NamespaceAdmin.DeleteNamespace
bool success = 1
message
DanubeAdmin.proto:427A proposed or executed topic move
Used in:
string topic_name = 1
uint64 from_broker = 2
uint64 to_broker = 3
double estimated_load = 4
string reason = 5
message
DanubeAdmin.proto:99Used in: , ,
string name = 1
repeated string permissions = 2
e.g. ["Produce", "Consume", "Lookup"]
bool system = 3
Used in:
Fixed = 0
Exponential = 1
message
DanubeAdmin.proto:248Used in: ,
uint32 max_unacked_messages = 1
message
DanubeAdmin.proto:222Used in: ,
uint32 max_redelivery_count = 1
uint64 ack_timeout_ms = 2
uint64 base_redelivery_delay_ms = 3
uint64 max_redelivery_delay_ms = 4
SubscriptionBackoffStrategy backoff_strategy = 5
optional string dead_letter_topic = 6
SubscriptionPoisonPolicy poison_policy = 7
Used in:
DeadLetter = 0
Block = 1
Drop = 2
message
DanubeAdmin.proto:218Used as response type in: TopicAdmin.SetSubscriptionDispatchConfig, TopicAdmin.SetSubscriptionFailurePolicy, TopicAdmin.Unsubscribe
bool success = 1
message
DanubeAdmin.proto:294Detailed topic entry including hosting broker id
Used in:
string name = 1
/namespace/topic (leading slash)
string broker_id = 2
hosting broker id; empty if unknown/unassigned
string delivery = 3
delivery: Reliable | NonReliable
message
DanubeAdmin.proto:300Used as response type in: TopicAdmin.ListBrokerTopics, TopicAdmin.ListNamespaceTopics
repeated topics = 1
message
DanubeAdmin.proto:198Used as request type in: TopicAdmin.DeleteTopic, TopicAdmin.ListSubscriptions, TopicAdmin.UnloadTopic
string name = 1
message
DanubeAdmin.proto:202Used as response type in: TopicAdmin.CreatePartitionedTopic, TopicAdmin.CreateTopic, TopicAdmin.DeleteTopic, TopicAdmin.UnloadTopic
bool success = 1