Fix typos in client and protocol. (segmentio#745)

daheige · Sep 22, 2021 · df148e4 · df148e4
1 parent 392c450
commit df148e4
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/addpartitionstotxn.go b/addpartitionstotxn.go
@@ -35,8 +35,8 @@ type AddPartitionsToTxnRequest struct {
 	Topics map[string][]AddPartitionToTxn
 }
 
-// AddPartitioinsToTxnResponse is the response structure for the AddPartitioinsToTxn function.
-type AddPartitioinsToTxnResponse struct {
+// AddPartitionsToTxnResponse is the response structure for the AddPartitionsToTxn function.
+type AddPartitionsToTxnResponse struct {
 	// The amount of time that the broker throttled the request.
 	Throttle time.Duration
 
@@ -62,7 +62,7 @@ type AddPartitionToTxnPartition struct {
 func (c *Client) AddPartitionsToTxn(
 	ctx context.Context,
 	req *AddPartitionsToTxnRequest,
-) (*AddPartitioinsToTxnResponse, error) {
+) (*AddPartitionsToTxnResponse, error) {
 	protoReq := &addpartitionstotxn.Request{
 		TransactionalID: req.TransactionalID,
 		ProducerID:      int64(req.ProducerID),
@@ -88,7 +88,7 @@ func (c *Client) AddPartitionsToTxn(
 
 	r := m.(*addpartitionstotxn.Response)
 
-	res := &AddPartitioinsToTxnResponse{
+	res := &AddPartitionsToTxnResponse{
 		Throttle: makeDuration(r.ThrottleTimeMs),
 		Topics:   make(map[string][]AddPartitionToTxnPartition, len(r.Results)),
 	}

diff --git a/protocol/protocol.go b/protocol/protocol.go
@@ -439,7 +439,7 @@ type GroupMessage interface {
 }
 
 // TransactionalMessage is an extension of the Message interface implemented by some
-// request types to inform the program that they should be reouted to a transaction
+// request types to inform the program that they should be routed to a transaction
 // coordinator.
 type TransactionalMessage interface {
 	// Returns the transactional id configured on the message.