[kafka] branch trunk updated: MINOR: Update incorrect / misleading comment regarding rebalance exceptions in WorkerSinkTask (#13194)

[cegerton]

This is an automated email from the ASF dual-hosted git repository.

cegerton pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 6e2b86597d9 MINOR: Update incorrect / misleading comment regarding 
rebalance exceptions in WorkerSinkTask (#13194)
6e2b86597d9 is described below

commit 6e2b86597d9cd7c8b2019cffb895522deb63c93a
Author: Yash Mayya <yash.ma...@gmail.com>
AuthorDate: Fri Feb 3 19:30:08 2023 +0530

    MINOR: Update incorrect / misleading comment regarding rebalance exceptions 
in WorkerSinkTask (#13194)
    
    Reviewers: Chris Egerton <chr...@aiven.io>
---
 .../src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java
 
b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java
index 76dae3e7f3d..ec08b4ad412 100644
--- 
a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java
+++ 
b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java
@@ -474,7 +474,7 @@ class WorkerSinkTask extends WorkerTask {
     private ConsumerRecords<byte[], byte[]> pollConsumer(long timeoutMs) {
         ConsumerRecords<byte[], byte[]> msgs = 
consumer.poll(Duration.ofMillis(timeoutMs));
 
-        // Exceptions raised from the task during a rebalance should be 
rethrown to stop the worker
+        // Exceptions raised from the task during a rebalance should be 
rethrown to stop the task and mark it as failed
         if (rebalanceException != null) {
             RuntimeException e = rebalanceException;
             rebalanceException = null;