Spring integration sftp new version upgrade issues

Question

Error Log

[sshd-SshClient[thread-4] WARN o.a.s.c.k.AcceptAllServerKeyVerifier - Server at server presented unverified RSA key: SHA256:key

[sshd-SshClient[thread-3] WARN o.a.s.c.s.ClientSessionImpl - exceptionCaught(ClientSessionImpl[server])[state=Opened] IOException: Connection >reset [sshd-SshClient[thread-1] INFO o.a.s.c.s.ClientSessionImpl - Disconnecting(ClientSessionImpl[server]): SSH2_DISCONNECT_PROTOCOL_ERROR - Detected IdleTimeout after 600609/600000 ms.

For first line log known host file was accepted earlier but now it was not able to because of apache-sshd implemenation by spring integration team and for second line, when I checked came to know we can set heatbeat but in spring integration not getting how to pass

Answer 1

@Configuration public class SftpConfiguration {

@Value("${sftp.known-hosts}")
private Resource knownHosts;
@Value("${sftp.host}")
private String host;
@Value("${sftp.port}")
private int port;
@Value("${sftp.username}")
private String user;
@Value("${sftp.privatekey}")
private Resource privateKey;
@Value("${sftp.privateKeyPassphrase}")
private String privateKeyPassphrase;

@Bean(name = "sftpSessionFactory")
public DefaultSftpSessionFactory sftpSessionFactory() throws IOException {
    SshClient externalClient = SshClient.setUpDefaultClient();
    // serverKeyverifier will help to set the knowHosts
    ResourceKnownHostsServerKeyVerifier serverKeyVerifier = null;
    if (this.knownHosts != null) {
        serverKeyVerifier = new ResourceKnownHostsServerKeyVerifier(knownHosts);
    }
    externalClient.setServerKeyVerifier(serverKeyVerifier);
    if (this.privateKey != null) {
        IoResource<Resource> privateKeyResource = new AbstractIoResource<>(Resource.class, this.privateKey) {
            public InputStream openInputStream() throws IOException {
                return (this.getResourceValue()).getInputStream();
            }
        };

        try {
            Collection<KeyPair> keys = SecurityUtils.getKeyPairResourceParser().
                    loadKeyPairs(null, privateKeyResource,FilePasswordProvider.of(this.privateKeyPassphrase));
            externalClient.setKeyIdentityProvider(KeyIdentityProvider.wrapKeyPairs(keys));
        } catch (GeneralSecurityException ex) {
            throw new IOException("Cannot load private key: " + this.privateKey.getFilename(), ex);
        }
    }
    CoreModuleProperties.HEARTBEAT_INTERVAL.set(externalClient, Duration.ofSeconds(10));

    DefaultSftpSessionFactory sftpSessionFactory = new DefaultSftpSessionFactory(externalClient, false);
    sftpSessionFactory.setHost(host);
    sftpSessionFactory.setPort(port);
    sftpSessionFactory.setUser(user);

    return sftpSessionFactory;
}

}