☰

SSHトンネルを介してKafkaの消費者を渡す

tag-icon • tag-icon ssh port-forwarding
SSHトンネルを介してKafkaの消費者を渡す

Kafkaブローカーは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"

なぜできないの？

ベストアンサー1

これは、Kafka ブローカーが元のホストを使用するようにコンシューマーをリダイレクトするためです。これを見て、https://stackoverflow.com/questions/45854168/consume-from-a-kafka-cluster-through-ssh-tunnel

おすすめ記事