Есть ли способ настроить KafkaConsumer (apache .kafka.kafka-clients) для работы с брокерами Kafka через прокси?

Question

Я использую клиент KafkaConsumer java для связи с брокерами Kafka. Мой пользователь может определить прокси (ip: порт) между KafkaConsumer и брокерами.

----------------------         -------------         -----------------------
| Application client |  <--->  | TCP Proxy |  <--->  | Target (e.g. kafka) |
----------------------         -------------         -----------------------

Без прокси конфигурации 'boostrap.servers' со списком брокера достаточно, чтобы установить sh исходный connection.

Мой вопрос: как я могу управлять KafkaConsumer для инициализации соединения с брокерами через прокси-сервер? имеет ли apache -Kafka такую ​​поддержку?

Я попытался найти свойство, такое как 'listeners' и 'advertised.listeners', однако они являются конфигурацией посредника, и я не могу настроить посредников.

Answer 1

Протокол TCP должен был бы установить sh квитирование соединения, затем запросить события у восходящего Kafka, а затем переслать обратно в виде потокового ответа запрашивающему клиенту ....

Если создание протокола TCP слишком много для вас, тогда вы могли бы вместо этого использовать прокси KAFKA REST.

В качестве альтернативы, уточнить, почему вы не можете напрямую подключиться к любому брокеру