在AWS KinesisAncClient下用java配置Proxy

Question

我需要为Kinesis客户端配置代理。目前我正在使用KinesisAncClient对象对kinesis流执行异步操作。在互联网上搜索了一番之后，我得出的结论是，没有合适的资源可以帮助在异步客户端上配置代理。

那么，我们有没有办法在KinesisAsyncClient对象下配置代理host、port、username、password和non-proxy-hosts。

提前感谢！

Answer 1

我可以设置代理主机和端口，并使用以下代码传递给KinesisAncClient：

String hostString="127.0.0.1";
int port=8080;
ProxyConfiguration proxyConfiguration =ProxyConfiguration.builder().host(hostString).port(port).build();

SdkAsyncHttpClient httpClient = NettyNioAsyncHttpClient.builder().proxyConfiguration(proxyConfiguration).build();

KinesisAsyncClient client = KinesisAsyncClient.builder().httpClient(httpClient).build();

请注意，我已经设置了一个示例hostString和Port.

希望这能有所帮助。