-
Notifications
You must be signed in to change notification settings - Fork 868
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
KIP 396 ListOffsets #2086
KIP 396 ListOffsets #2086
Conversation
1cb8861
to
6592b2d
Compare
6592b2d
to
7c049ac
Compare
ee6da94
to
dcf4499
Compare
23c898a
to
b5ba287
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.
Thanks for moving the API to the extensions class, completely forgot about that. Nitpick comments.
internal TimestampSpec(long timestamp) | ||
{ | ||
Timestamp = timestamp; | ||
} |
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.
We can probably keep private set;
accessor replacing this.
|
||
namespace Confluent.Kafka.Admin | ||
{ | ||
/// <summary> | ||
/// Represents the result of a list offsets operation. | ||
/// Represents an error that occurred during a ListOffsets request. |
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.
The result of ListOffsets request (including error status).
} | ||
}; | ||
|
||
var listOffsetsResult = await adminClient.ListOffsetsAsync(topicPartitionOffsetSpecs,options); |
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.
Spacing
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.
LGTM!
No description provided.