Клиент Confluent SchemaRegistry игнорирует настройки системного проксиJAVA

Программисты JAVA общаются здесь
Ответить
Anonymous
 Клиент Confluent SchemaRegistry игнорирует настройки системного прокси

Сообщение Anonymous »

пытаюсь подключиться к Kafka, но с реестром схемы за прокси-сервером, требующим аутентификации. Я знаю, что клиент реестра схемы сейчас не поддерживает предоставление учетных данных прокси (https://github.com/confluentinc/schema- ... ssues/2137).
Как бы я ни старался чтобы установить настройки прокси-сервера на системном уровне и повторно использовать их в моем Java-приложении, которое подключается к реестру схемы и пытается отправить простое сообщение.
Попытка 1:
  • установить системные переменные http_proxy, https_proxy, HTTP_PROXY и HTTPS_PROXY (используя синтаксис http://
    :@:
  • проверьте подключение через CURL – работает!
  • запустите приложение Java с системным параметром:

Код: Выделить всё

java -Djava.net.useSystemProxies=true -jar ./avro-producer-2.1.0-jar-with-dependencies.jar
результат: Ошибка: соединение отклонено. Похоже, параметры прокси были полностью проигнорированы.

Код: Выделить всё

[2024-01-12 16:56:47,210] (io.confluent.kafka.schemaregistry.client.rest.RestService) - ERROR Failed to send HTTP request to endpoint: https://xyz.cloud/subjects/mycorp.crm.campaign.
V1-value/versions
java.net.ConnectException: Connection refused (Connection refused)
at java.net.PlainSocketImpl.socketConnect(Native Method) ~[?:1.8.0_352]
at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350) ~[?:1.8.0_352]
at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206) ~[?:1.8.0_352]
at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188) ~[?:1.8.0_352]
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392) ~[?:1.8.0_352]
at java.net.Socket.connect(Socket.java:607) ~[?:1.8.0_352]
at sun.security.ssl.SSLSocketImpl.connect(SSLSocketImpl.java:293) ~[?:1.8.0_352]
at sun.net.NetworkClient.doConnect(NetworkClient.java:175) ~[?:1.8.0_352]
at sun.net.www.http.HttpClient.openServer(HttpClient.java:463) ~[?:1.8.0_352]
at sun.net.www.http.HttpClient.openServer(HttpClient.java:558) ~[?:1.8.0_352]
at sun.net.www.protocol.https.HttpsClient.(HttpsClient.java:264) ~[?:1.8.0_352]
at sun.net.www.protocol.https.HttpsClient.New(HttpsClient.java:367) ~[?:1.8.0_352]
at
Попытка 2:

[*]запуск приложения Java со всеми параметрами прокси в командной строке:

Код: Выделить всё

    java -Dhttp.proxyHost=myproxy.myorg.com -Dhttp.proxyPort=8080 -Dhttp.proxyUser=myuser_dev -Dhttp.proxyPassword=p3aFxxxx -Dhttps.proxyHost=myproxy.myorg.com -Dhttps.proxyPort=8080 -Dhttps.proxyUser=myuser_dev -Dhttps.proxyPassword=p3aFxxxx -Djdk.http.auth.tunneling.disabledSchemes="" -Djdk.http.auth.proxying.disabledSchemes="" -Djdk.https.auth.tunneling.disabledSchemes="" -Djdk.https.auth.proxying.disabledSchemes="" -jar ./avro-producer-2.1.0-jar-with-dependencies.jar
результат: ошибка прокси возвращает требуемую авторизацию

Код: Выделить всё

    (io.confluent.kafka.schemaregistry.client.rest.RestService) - ERROR Failed to send HTTP request to endpoint: https://xyz.cloud/subjects/mycorp.crm.campaign.
V1-value/versions
java.io.IOException: Unable to tunnel through proxy. Proxy returns "HTTP/1.1 407 authenticationrequired"
at sun.net.www.protocol.http.HttpURLConnection.doTunneling(HttpURLConnection.java:2154) ~[?:1.8.0_352]
at sun.net.www.protocol.https.AbstractDelegateHttpsURLConnection.connect(AbstractDelegateHttpsURLConnection.java:195) ~[?:1.8.0_352]
at sun.net.www.protocol.http.HttpURLConnection.getOutputStream0(HttpURLConnection.java:1342) ~[?:1.8.0_352]
at sun.net.www.protocol.http.HttpURLConnection.getOutputStream(HttpURLConnection.java:1317) ~[?:1.8.0_352]
at sun.net.www.protocol.https.HttpsURLConnectionImpl.getOutputStream(HttpsURLConnectionImpl.java:264) ~[?:1.8.0_352]
at io.confluent.kafka.schemaregistry.client.rest.RestService.sendHttpRequest(RestService.java:178) [avro-producer-2.1.0-jar-with-dependencies.jar:?]
Версия Java — OpenJDK 1.8.0_352
Что я делаю не так?

Подробнее здесь: https://stackoverflow.com/questions/778 ... y-settings
Ответить

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

Вернуться в «JAVA»