我有一个Kafka集群在aws上运行。我想从我的应用服务器用标准kafka控制台使用者连接到集群。应用服务器可以通过socks代理访问internet。不需要身份验证
如何让Kafka客户端通过代理连接？
我尝试了很多方法，包括向kaka-run-class.sh脚本添加标准的jvm代理参数。但我仍然得到一个连接被拒绝的错误。

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客户端没有影响。