subject:"\[GitHub\] \[kafka\] lucasbru commented on a diff in pull request #11433\: KAFKA\-13295\: Avoiding Transation timeouts arising due to long restora…"

[GitHub] [kafka] lucasbru commented on a diff in pull request #11433: KAFKA-13295: Avoiding Transation timeouts arising due to long restora…

2023-05-05 Thread via GitHub

lucasbru commented on code in PR #11433: URL: https://github.com/apache/kafka/pull/11433#discussion_r1186098795 ## streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java: ## @@ -342,7 +342,19 @@ public void handleAssignment(final Map> activeTasks,

[GitHub] [kafka] lucasbru commented on a diff in pull request #11433: KAFKA-13295: Avoiding Transation timeouts arising due to long restora…

2023-05-04 Thread via GitHub

lucasbru commented on code in PR #11433: URL: https://github.com/apache/kafka/pull/11433#discussion_r1185039728 ## streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java: ## @@ -342,7 +342,19 @@ public void handleAssignment(final Map> activeTasks,