通过SOCKS代理连接到Kafka

Question

我有一个在AWS上运行的Kafka集群。我想从我的应用程序服务器使用标准kafka-console-consumer连接到集群。应用服务器可以通过SOCKS代理访问Internet。不需要身份验证

我如何告诉Kafka客户端通过代理连接？

我尝试了很多事情，包括将标准的JVM代理参数添加到kaka-run-class.sh脚本中。但是我仍然出现拒绝连接错误。

exec $JAVA -DsocksProxyHost=proxy.host.name -DsocksProxyPort=1080 $KAFKA_HEAP_OPTS $KAFKA_JVM_PERFORMANCE_OPTS $KAFKA_GC_LOG_OPTS $KAFKA_JMX_OPTS $KAFKA_LOG4J_OPTS -cp $CLASSPATH $KAFKA_OPTS "$@"

编辑：事实证明，Kafka使用java.nio库。它的套接字实现与代理不兼容。因此，我使用的jvm参数对Kafka客户端无效。

Answer 1

这里遇到了同样的问题？想知道如何