ローカル使用Kafka APIと仮想マシン上のkafkaノード消費/生産データエラーCan't resolve address

ローカルIDEAに書かれたdemoが仮想マシン上のkafkaにアクセスしてデータを消費しようとしたが、次のようにエラーが発生した.
10:18:40.347 [main] DEBUG org.apache.kafka.clients.NetworkClient - Give up sending metadata request since no node is available 10:18:40.447 [main] DEBUG org.apache.kafka.clients.NetworkClient - Initialize connection to node 0 for sending metadata request 10:18:40.447 [main] DEBUG org.apache.kafka.clients.NetworkClient - Initiating connection to node 0 at k8s-master01:9092. 10:18:40.447 [main] DEBUG org.apache.kafka.clients.NetworkClient - Error connecting to node 0 at k8s-master01:9092: java.io.IOException: Can’t resolve address: k8s-master01:9092 at org.apache.kafka.common.network.Selector.connect(Selector.java:156) at org.apache.kafka.clients.NetworkClient.initiateConnect(NetworkClient.java:489) at org.apache.kafka.clients.NetworkClient.access 400 ( N e t w o r k C l i e n t . j a v a : 47 ) a t o r g . a p a c h e . k a f k a . c l i e n t s . N e t w o r k C l i e n t 400(NetworkClient.java:47) at org.apache.kafka.clients.NetworkClient 400(NetworkClient.java:47)atorg.apache.kafka.clients.NetworkClientDefaultMetadataUpdater.maybeUpdate(NetworkClient.java:624) at org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeUpdate(NetworkClient.java:543) at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:254) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.clientPoll(ConsumerNetworkClient.java:320) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:213) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:193) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.awaitMetadataUpdate(ConsumerNetworkClient.java:134) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureCoordinatorKnown(AbstractCoordinator.java:184) at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:886) at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:853) at com.gc.troy.kafka.KafkaCsmMsg.main(KafkaCsmMsg.java:29) Caused by: java.nio.channels.UnresolvedAddressException: null at sun.nio.ch.Net.checkAddress(Net.java:101) at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:622) at org.apache.kafka.common.network.Selector.connect(Selector.java:153) … 13 common frames omitted 10:18:40.447 [main] DEBUG org.apache.kafka.clients.NetworkClient-Give up sending metadata request since no de is available————————————————————————————————————————————————————————————————————————————以上のエラーメッセージから、本地でk 8 s-master 01:9092というアドレスが認識できないことがわかります.このアドレスはkafkaのプロファイルserverです.propertiesでlistenersのアドレスを構成するには、次の手順に従います.

listeners=PLAINTEXT://k8s-master01:9092

したがってhostname部分をip:192.168に変更する必要がある.17.151、次のようになります.

listeners=PLAINTEXT://192.168.17.151:9092

あるいはローカルマシンにローカルドメイン名マッピングを追加し、修正が完了したらkafkaを再起動し、問題解決!
————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————