kpatelatwork commented on pull request #10822:
URL: https://github.com/apache/kafka/pull/10822#issuecomment-857875970
Below are some logs when both connector and tasks are restarted.
> [2021-06-09 12:02:26,045] DEBUG Writing
RestartRequest{connectorName='simple-source', onlyFailed=false,
includeTasks=true} to Kafka
(org.apache.kafka.connect.storage.KafkaConfigBackingStore:487)
[2021-06-09 12:02:26,049] INFO [Worker clientId=connect-1,
groupId=connect-integration-test-connect-cluster] Received
RestartRequest{connectorName='simple-source', onlyFailed=false,
includeTasks=true}
(org.apache.kafka.connect.runtime.distributed.DistributedHerder:1709)
[2021-06-09 12:02:26,051] INFO [Worker clientId=connect-1,
groupId=connect-integration-test-connect-cluster] Executing plan to restart
connector and 4 of 4 tasks for RestartRequest{connectorName='simple-source',
onlyFailed=false, includeTasks=true}
(org.apache.kafka.connect.runtime.distributed.DistributedHerder:1137)
[2021-06-09 12:02:26,063] DEBUG [Worker clientId=connect-1,
groupId=connect-integration-test-connect-cluster] Restarting 4 of 4 tasks for
RestartRequest{connectorName='simple-source', onlyFailed=false,
includeTasks=true}
(org.apache.kafka.connect.runtime.distributed.DistributedHerder:1169)
[2021-06-09 12:02:26,114] DEBUG [Worker clientId=connect-1,
groupId=connect-integration-test-connect-cluster] Restarted 4 of 4 tasks for
RestartRequest{connectorName='simple-source', onlyFailed=false,
includeTasks=true} as requested
(org.apache.kafka.connect.runtime.distributed.DistributedHerder:1171)
[2021-06-09 12:02:26,114] INFO [Worker clientId=connect-1,
groupId=connect-integration-test-connect-cluster] Completed plan to restart
connector and 4 of 4 tasks for RestartRequest{connectorName='simple-source',
onlyFailed=false, includeTasks=true}
(org.apache.kafka.connect.runtime.distributed.DistributedHerder:1173)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
