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 6a1a430
Show file tree
Hide file tree
Showing 3 changed files with 10 additions and 10 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
14 changes: 7 additions & 7 deletions produce.go
Original file line number Diff line number Diff line change
Expand Up @@ -111,27 +111,27 @@ 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
// This field will be zero if the kafka broker did not support the Produce
// API in version 3 or above.
BaseOffset int64

// Time at which the broker wrote the records to the topic partition.
//
// This field will be zero if the kafka broker did not support Produce API
// version 2 or above.
// This field will be zero if the kafka broker did not support the Produce
// API in version 2 or above.
LogAppendTime time.Time

// 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 the Produce
// API in 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 6a1a430

Please sign in to comment.