Skip to content

Commit

Permalink
all: fix spelling errors
Browse files Browse the repository at this point in the history
  • Loading branch information
kevinburkesegment committed Apr 29, 2023
1 parent 84acde1 commit 3e5ad70
Show file tree
Hide file tree
Showing 3 changed files with 9 additions and 9 deletions.
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

0 comments on commit 3e5ad70

Please sign in to comment.