File tree Expand file tree Collapse file tree 6 files changed +8
-8
lines changed Expand file tree Collapse file tree 6 files changed +8
-8
lines changed Original file line number Diff line number Diff line change 1
- test :
1
+ test :
2
2
KAFKA_SKIP_NETTEST=1 \
3
3
KAFKA_VERSION=2.3.1 \
4
4
go test -race -cover ./...
5
5
6
- docker :
7
- docker-compose up -d
6
+ docker :
7
+ docker-compose up -d
Original file line number Diff line number Diff line change @@ -33,7 +33,7 @@ type AddOffsetsToTxnResponse struct {
33
33
// The amount of time that the broker throttled the request.
34
34
Throttle time.Duration
35
35
36
- // An error that may have occured when attempting to add the offsets
36
+ // An error that may have occurred when attempting to add the offsets
37
37
// to a transaction.
38
38
//
39
39
// The errors contain the kafka error code. Programs may use the standard
Original file line number Diff line number Diff line change @@ -50,7 +50,7 @@ type AddPartitionToTxnPartition struct {
50
50
// The ID of the partition.
51
51
Partition int
52
52
53
- // An error that may have occured when attempting to add the partition
53
+ // An error that may have occurred when attempting to add the partition
54
54
// to a transaction.
55
55
//
56
56
// The errors contain the kafka error code. Programs may use the standard
Original file line number Diff line number Diff line change @@ -144,7 +144,7 @@ func (w *writer) Close() error {
144
144
if err != nil {
145
145
w .err = err
146
146
}
147
- w .enc .Reset (devNull {}) // don't retain the underyling writer
147
+ w .enc .Reset (devNull {}) // don't retain the underlying writer
148
148
w .c .encoderPool .Put (w .enc )
149
149
w .enc = nil
150
150
return err
Original file line number Diff line number Diff line change @@ -23,7 +23,7 @@ type EndTxnRequest struct {
23
23
// The epoch associated with the current producer session for the given PID
24
24
ProducerEpoch int
25
25
26
- // Committed should be set to true if the transaction was commited , false otherwise.
26
+ // Committed should be set to true if the transaction was committed , false otherwise.
27
27
Committed bool
28
28
}
29
29
Original file line number Diff line number Diff line change @@ -30,7 +30,7 @@ type HeartbeatRequest struct {
30
30
31
31
// HeartbeatResponse represents a response from a heartbeat request.
32
32
type HeartbeatResponse struct {
33
- // Error is set to non-nil if an error occured .
33
+ // Error is set to non-nil if an error occurred .
34
34
Error error
35
35
36
36
// The amount of time that the broker throttled the request.
You can’t perform that action at this time.
0 commit comments