From 261c1e525c5c635cdbf8c848dd179e8c0a2e8d2b Mon Sep 17 00:00:00 2001 From: harshadkhetpal Date: Tue, 7 Apr 2026 14:39:03 +0530 Subject: [PATCH] fix: correct typo "occured" to "occurred" --- arroyo/processing/strategies/produce.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/arroyo/processing/strategies/produce.py b/arroyo/processing/strategies/produce.py index b8051adf..f0a9a994 100644 --- a/arroyo/processing/strategies/produce.py +++ b/arroyo/processing/strategies/produce.py @@ -31,7 +31,7 @@ class Produce(ProcessingStrategy[Union[FilteredPayload, TStrategyPayload]]): stream processor to slow down. On poll we check for completion of the produced messages. If the message has been successfully - produced then the message is submitted to the next step. If an error occured the exception will + produced then the message is submitted to the next step. If an error occurred the exception will be raised. Important: The destination topic is always the `topic` passed into the constructor and not the