Я пытаюсь настроить прокси-сервер (предпочтительнее в java), который может передавать мой поток соединения брокеру kafka.
Client (Consumer/Producer) <--> [PROXY SERVER] <--> Kafka Broker
Мой вариант использования - использовать данные из kafka, но параметры конфигурации должны быть переданы посреднику kafka.
например, bootstrap.servers=xx.xx.xx.xx:9091, topic=<encrypted-topic>
Порт 9091 - это прокси-сервер, на котором я расшифровываю тему в исходной теме и передаю поток соединения в kafka.
Работа уровня прокси состоит в том, чтобы проверить, присутствует ли зашифрованная тема в карте тем в памяти, и если да, то расшифровать тему и подключиться к брокеру kafka.