[
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)
