root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MINOR: Update incorrect / misleading comment regarding rebalance exceptions in WorkerSinkTask (#13194) 

Reviewers: Chris Egerton <chrise@aiven.io>
This commit is contained in:
Yash Mayya 2023-02-03 19:30:08 +05:30 committed by GitHub
parent b8e606355b
commit 6e2b86597d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java
View File

@ -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;