-
Notifications
You must be signed in to change notification settings - Fork 56
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
Describe cluster API Support #1250
Conversation
struct ClusterBroker | ||
{ |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
struct ClusterBroker | |
{ | |
struct ClusterBroker | |
{ |
string16 host; | ||
int32 port; | ||
string16 rack = null; | ||
} |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Let's move this structure down between DescribeClusterResponse
and DescribeClusterResponsePart2
as it is part of the response and logically belongs between these structures.
case 60: kafka::stream::KafkaDescribeClusterRequestBeginEx describeCluster; | ||
case 33: kafka::stream::KafkaAlterConfigsRequestBeginEx alterConfigs; | ||
case 20: kafka::stream::KafkaDeleteTopicsRequestBeginEx deleteTopics; | ||
case 19: kafka::stream::KafkaCreateTopicsRequestBeginEx createTopics; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Let's put these in the order of their api key, increasing.
.brokerId(0) | ||
.host("localhost0") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Let's use more meaningful broker ids and host names, like 0xb1
and broker-1.internal.net
or similar.
I think we might have some examples of that in other scripts.
Description
See 1058