通过 ssh 隧道转发 kafka 消费者

Question

卡夫卡经纪人是 10.2.1。

这有效：

$ ssh me@jumpbox
me@jumpbox:~$ kafka-console-consumer.sh --bootstrap-server \
                                          "10.200.1.1:9092,10.200.1.2:9092" \
                                        --topic "mytopic"

这不会：

$ ssh me@jumpbox -L 9998:10.200.1.1:9092 \
                 -L 9999:10.200.1.2:9092

### in a new terminal:

$ kafka-console-consumer --bootstrap-server "localhost:9998,localhost:9999" \
                         --topic "mytopic"

为什么不？

Answer 1

因为kafka代理将重定向消费者以使用原始主机。看到这个，/sf/ask/3209791791/