[ https://issues.apache.org/jira/browse/KAFKA-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
jiwei updated KAFKA-10461: -------------------------- Description: public static final String EMIT_HEARTBEATS_ENABLED = EMIT_HEARTBEATS + ENABLED_SUFFIX; private static final String EMIT_HEARTBEATS_ENABLED_DOC = "Whether to emit heartbeats to target cluster."; When I set it "false", it dosen‘t work! !image-2020-09-04-11-29-58-624.png|width=448,height=260! While the value of interval is "-1", method stopped.await(-1) will return false. Then MirrorHeartbeatTask will emit heartbeat one by one endlessly. was: public static final String EMIT_HEARTBEATS_ENABLED = EMIT_HEARTBEATS + ENABLED_SUFFIX; private static final String EMIT_HEARTBEATS_ENABLED_DOC = "Whether to emit heartbeats to target cluster."; When I set it "false", it dosen‘t work! !image-2020-09-04-11-29-58-624.png|width=448,height=260! While the value of interval is "-1", method stopped.await(-1) will return false. Then MirrorHeartbeatTask will emit heartbeat one by one endlessly. > The config of closing heartbeat is invalid. > ------------------------------------------- > > Key: KAFKA-10461 > URL: https://issues.apache.org/jira/browse/KAFKA-10461 > Project: Kafka > Issue Type: Improvement > Components: KafkaConnect > Affects Versions: 2.6.0 > Reporter: jiwei > Priority: Critical > Attachments: image-2020-09-04-11-29-58-624.png > > > public static final String EMIT_HEARTBEATS_ENABLED = EMIT_HEARTBEATS + > ENABLED_SUFFIX; > private static final String EMIT_HEARTBEATS_ENABLED_DOC = "Whether to emit > heartbeats to target cluster."; > When I set it "false", it dosen‘t work! > !image-2020-09-04-11-29-58-624.png|width=448,height=260! > While the value of interval is "-1", method stopped.await(-1) will return > false. Then MirrorHeartbeatTask will emit heartbeat one by one endlessly. > -- This message was sent by Atlassian Jira (v8.3.4#803005)