You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by "doupengwei (Jira)" <ji...@apache.org> on 2022/07/04 07:14:00 UTC

[jira] [Created] (KAFKA-14043) The latest status of the task is overwritten by the old status

doupengwei created KAFKA-14043:
----------------------------------

             Summary: The latest status of the task is overwritten by the old status
                 Key: KAFKA-14043
                 URL: https://issues.apache.org/jira/browse/KAFKA-14043
             Project: Kafka
          Issue Type: Bug
          Components: KafkaConnect
    Affects Versions: 2.4.0
         Environment: Centos 7.6

kafka  2.4.0
            Reporter: doupengwei


Kafka version : 2.4.0

connect.protocol : compatible

In kafka connect cluster, if  one node  faced net work issue,  then will caused worker try to stop connector and task which running on this node. and due to net work issue. it will stop failed and throw exception, then worker process will try to update task or connector status, producer will retry indefinitely until successfully sent. but due to net work issue, the new assignment have  performed on the other connect node. after net work recover, old task status will cover latest status.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)