@@ -35,8 +35,8 @@ type AddPartitionsToTxnRequest struct {
35
35
Topics map [string ][]AddPartitionToTxn
36
36
}
37
37
38
- // AddPartitioinsToTxnResponse is the response structure for the AddPartitioinsToTxn function.
39
- type AddPartitioinsToTxnResponse struct {
38
+ // AddPartitionsToTxnResponse is the response structure for the AddPartitionsToTxn function.
39
+ type AddPartitionsToTxnResponse struct {
40
40
// The amount of time that the broker throttled the request.
41
41
Throttle time.Duration
42
42
@@ -62,7 +62,7 @@ type AddPartitionToTxnPartition struct {
62
62
func (c * Client ) AddPartitionsToTxn (
63
63
ctx context.Context ,
64
64
req * AddPartitionsToTxnRequest ,
65
- ) (* AddPartitioinsToTxnResponse , error ) {
65
+ ) (* AddPartitionsToTxnResponse , error ) {
66
66
protoReq := & addpartitionstotxn.Request {
67
67
TransactionalID : req .TransactionalID ,
68
68
ProducerID : int64 (req .ProducerID ),
@@ -88,7 +88,7 @@ func (c *Client) AddPartitionsToTxn(
88
88
89
89
r := m .(* addpartitionstotxn.Response )
90
90
91
- res := & AddPartitioinsToTxnResponse {
91
+ res := & AddPartitionsToTxnResponse {
92
92
Throttle : makeDuration (r .ThrottleTimeMs ),
93
93
Topics : make (map [string ][]AddPartitionToTxnPartition , len (r .Results )),
94
94
}
0 commit comments