-
Notifications
You must be signed in to change notification settings - Fork 662
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
Added topic id to describeTopics Response #1068
Added topic id to describeTopics Response #1068
Conversation
|
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.
mostly just minor stuff
kafka/testconf-example.json
Outdated
@@ -1,5 +1,5 @@ | |||
{ | |||
"Brokers": "mybroker or $BROKERS env", | |||
"Brokers": "localhost:9092", |
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.
change isn't needed
kafka/generated_errors.go
Outdated
@@ -1,7 +1,7 @@ | |||
package kafka | |||
|
|||
// Copyright 2016-2023 Confluent Inc. | |||
// AUTOMATICALLY GENERATED ON 2023-07-12 11:45:05.970954589 +0200 CEST m=+0.000441527 USING librdkafka 2.2.0 | |||
// AUTOMATICALLY GENERATED ON 2023-09-29 04:54:21.039467052 +0530 IST m=+0.006323752 USING librdkafka 2.2.0 |
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.
don't add this file to the change, we'll do it with the release
e7de1b1
to
34f496c
Compare
452f402
to
d7dc5af
Compare
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.
Approved with one minor comment - also need to merge the latest changes to the kip-430 branch.
c97ee8b
to
755bc19
Compare
kafka/integration_test.go
Outdated
@@ -1420,6 +1420,7 @@ func (its *IntegrationTestSuite) TestAdminClient_DescribeTopics() { | |||
"Expected correct error for nonexistent topic") | |||
|
|||
topicDesc := topicDescs[0] | |||
assert.NotNil(topicDesc.TopicID) |
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.
assert.NotNil asways returns true for structs according to this issue stretchr/testify#570
Suggest:
assert.NotNil(topicDesc.TopicID) | |
assert.NotZero(topicDesc.TopicID.GetLeastSignificantBits()) | |
assert.NotZero(topicDesc.TopicID.GetMostSignificantBits()) | |
assert.NotEmpty(topicDesc.TopicID.String()) |
No description provided.