Docker イメージでvsftpd サーバーを使用して Alpakka FTP-Source コネクタのトラバーサルの例を再作成しようとしていますが、接続できないようです。コードを調整する方法についての指針は大歓迎です。
FtpSettings ftpSettings = FtpSettings
.create(InetAddress.getLocalhost())
.withPort(21)
.withCredentials(FtpCredentials.NonAnonFtpCredentials.create("news", "test"))
.withBinary(true)
.withPassiveMode(true)
.withConfigureConnectionConsumer(
(FTPClient ftpClient) -> {
ftpClient.addProtocolCommandListener(
new PrintCommandListener(new PrintWriter(System.out), true));
});
Source<FtpFile, NotUsed> ftp = Ftp.ls("/", ftpSettings);
ftp.to(Sink.foreach(s -> LOGGER.info(s.name())));
参考までに: ログイン情報は filezilla などで機能しています。