[jira] [Comment Edited] (KAFKA-15252) Task is not stopped until the poll interval passes in case of task restarting.

["Chris Egerton (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/KAFKA-15252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748778#comment-17748778 ] 

Chris Egerton edited comment on KAFKA-15252 at 7/29/23 3:12 AM:
----------------------------------------------------------------

I think this is caused by KAFKA-15090. [~nikita.krasnov] do you think we can close this as a duplicate, or is it a different issue?


was (Author: chrisegerton):
I think this is caused by KAFKA-15090. [~nikita.krasnov] do you think we can close this as a duplicate, or is this a different issue?

> Task is not stopped until the poll interval passes in case of task restarting.
> ------------------------------------------------------------------------------
>
>                 Key: KAFKA-15252
>                 URL: https://issues.apache.org/jira/browse/KAFKA-15252
>             Project: Kafka
>          Issue Type: Bug
>          Components: KafkaConnect
>            Reporter: Nikita
>            Priority: Major
>
> We face a problem with restarting of the tasks, sometimes it leads to resource leak. 
> We used the jdbc source connector and noticed an increasing of count of opened sessions on Vertica side. But this problem is applicable for all databases and possibly for all source connectors.
> Our case is the next: 
> 1) Run jdbc source connector (io.confluent.connect.jdbc.JdbcSourceConnector) and set poll.interval.ms (86400000) > task.shutdown.graceful.timeout.ms (it's the property on Kafka-connect side, we set 10000)
> 2) Send POST /connectors/<connector_name>/tasks/<task_number>/restart
> ER: count of session is the same as before restart
> AR: count of session increases
> The main problem is when org.apache.kafka.connect.runtime.Worker#stopAndAwaitTasks(java.util.Collection<org.apache.kafka.connect.util.ConnectorTaskId>)  method is called it doesn't stop a source task itself. 
> The source task stops only if polling process stops on source task side. 



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