Skip to content

Commit 315f9d8

Browse files
committed
Fixup retry/sleep after successful init producer id in idempotent producer
1 parent 369478a commit 315f9d8

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

kafka/producer/sender.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -319,6 +319,7 @@ def _maybe_wait_for_producer_id(self):
319319
error_type = Errors.for_code(response.error_code)
320320
if error_type is Errors.NoError:
321321
self._transaction_manager.set_producer_id_and_epoch(ProducerIdAndEpoch(response.producer_id, response.producer_epoch))
322+
break
322323
elif getattr(error_type, 'retriable', False):
323324
log.debug("Retriable error from InitProducerId response: %s", error_type.__name__)
324325
if getattr(error_type, 'invalid_metadata', False):

0 commit comments

Comments
 (0)