We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 1b53598 commit 39aa421Copy full SHA for 39aa421
kafka/producer/transaction_manager.py
@@ -211,7 +211,7 @@ def _fail_if_not_ready_for_send(self):
211
if self.is_transactional():
212
if not self.has_producer_id():
213
raise Errors.IllegalStateError(
214
- "Cannot perform a 'send' before completing a call to initTransactions"
+ "Cannot perform a 'send' before completing a call to init_transactions"
215
" when transactions are enabled.")
216
217
if self._current_state != TransactionState.IN_TRANSACTION:
0 commit comments