我正在尝试设置一个代理服务器（在java中首选），它可以将我的连接流传递给kafka代理。 Client (Consumer/Producer) <--> [PROXY SERVER] <--> Kafka Broker 我的用例是使用来自kafka的数据，但是配置参数应该被代理给kafka代理。
例如 bootstrap.servers=xx.xx.xx.xx:9091, topic=<encrypted-topic> 端口9091是代理服务器，在这里我将主题解密为原始主题，并将连接流传递给kafka。
代理层的任务是检查加密的主题是否存在于主题的内存Map中，如果存在，则解密主题并连接到kafka代理。