[ https://issues.apache.org/jira/browse/KAFKA-10707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Sasikumar Senthilnathan updated KAFKA-10707: -------------------------------------------- Description: Am trying to establish a connection via SOCKS proxy(SOCKS5) from Kafka Client for producing messages. Do we have any way to set the SOCKS proxy via Java client? I have tried setting it via java args as below java -cp ".:BOOT-INF/lib/*" Sample -DsocksProxyHost=xxxx -DsocksProxyPort=1080 -DsocksNonProxyHosts="xxxxx" Am getting the below exception {code:java} Exception in thread "main" java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Topic xxxxxx not present in metadata after 60000 ms. {code} was: Am trying to establish a connection via SOCKS proxy(SOCKS5) from Kafka Client for producing messages. Do we have any way to set the SOCKS proxy via Java client? I have tried setting it via java args as below java -cp ".:BOOT-INF/lib/*" Sample -DsocksProxyHost=xxxx -DsocksProxyPort=1080 -DsocksNonProxyHosts="xxxxx" > Socks Proxy is not taking effect in Java API > -------------------------------------------- > > Key: KAFKA-10707 > URL: https://issues.apache.org/jira/browse/KAFKA-10707 > Project: Kafka > Issue Type: Bug > Components: clients, consumer, producer > Affects Versions: 2.5.0 > Reporter: Sasikumar Senthilnathan > Priority: Major > > Am trying to establish a connection via SOCKS proxy(SOCKS5) from Kafka Client > for producing messages. > Do we have any way to set the SOCKS proxy via Java client? > I have tried setting it via java args as below > > java -cp ".:BOOT-INF/lib/*" Sample -DsocksProxyHost=xxxx > -DsocksProxyPort=1080 -DsocksNonProxyHosts="xxxxx" > > Am getting the below exception > {code:java} > Exception in thread "main" java.util.concurrent.ExecutionException: > org.apache.kafka.common.errors.TimeoutException: Topic xxxxxx not present in > metadata after 60000 ms. > {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)