Skip to content

Commit 5d94f0a

Browse files
committed
new FindCoordinatorRequest attrs in transaction manager
1 parent 193745f commit 5d94f0a

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

kafka/producer/transaction_manager.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -756,8 +756,8 @@ def __init__(self, transaction_manager, coord_type, coord_key):
756756
else:
757757
raise ValueError("Unrecognized coordinator type: %s" % (coord_type,))
758758
self.request = FindCoordinatorRequest[version](
759-
coordinator_key=coord_key,
760-
coordinator_type=coord_type_int8,
759+
key=coord_key,
760+
key_type=coord_type_int8,
761761
)
762762

763763
@property

0 commit comments

Comments
 (0)