Skip to content
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

all: fix spelling errors #1120

Merged
merged 1 commit into from
May 3, 2023
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions createtopics.go
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ type CreateTopicsRequest struct {
// When set to true, topics are not created but the configuration is
// validated as if they were.
//
// This field will be ignored if the kafka broker did no support the
// This field will be ignored if the kafka broker did not support the
// CreateTopics API in version 1 or above.
ValidateOnly bool
}
Expand All @@ -33,7 +33,7 @@ type CreateTopicsRequest struct {
type CreateTopicsResponse struct {
// The amount of time that the broker throttled the request.
//
// This field will be zero if the kafka broker did no support the
// This field will be zero if the kafka broker did not support the
// CreateTopics API in version 2 or above.
Throttle time.Duration

Expand Down
2 changes: 1 addition & 1 deletion deletetopics.go
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ type DeleteTopicsRequest struct {
type DeleteTopicsResponse struct {
// The amount of time that the broker throttled the request.
//
// This field will be zero if the kafka broker did no support the
// This field will be zero if the kafka broker did not support the
// DeleteTopics API in version 1 or above.
Throttle time.Duration

Expand Down
12 changes: 6 additions & 6 deletions produce.go
Original file line number Diff line number Diff line change
Expand Up @@ -111,8 +111,8 @@ type ProduceResponse struct {

// Offset of the first record that was written to the topic partition.
//
// This field will be zero if the kafka broker did no support the Produce
// API in version 3 or above.
// This field will be zero if the kafka broker did not support Produce API
// version 3 or above.
BaseOffset int64

// Time at which the broker wrote the records to the topic partition.
Expand All @@ -123,15 +123,15 @@ type ProduceResponse struct {

// First offset in the topic partition that the records were written to.
//
// This field will be zero if the kafka broker did not support Produce API
// version 5 or above (or if the first offset is zero).
// This field will be zero if the kafka broker did not support Produce
// API version 5 or above (or if the first offset is zero).
LogStartOffset int64

// If errors occurred writing specific records, they will be reported in
// this map.
//
// This field will always be empty if the kafka broker did not support
// Produce API version 8 or above.
// This field will always be empty if the kafka broker did not support the
// Produce API in version 8 or above.
RecordErrors map[int]error
}

Expand Down