设置：1.正在运行Kafka的docker kafka容器。2.java basic应用程序，从kafka容器外部生成和使用kafka消息。
从容器外部，我尝试使用java脚本发送kafka消息，并使用java脚本编写的consumer来使用这些消息。如果我正在用kafka容器的ip地址和主机名详细信息更新etc/hosts文件，这是有效的。请建议防止更新etc/hosts文件详细信息的解决方案。要求：使用etc/hosts文件，我们如何从外部访问kafka容器。
设置：1.正在运行Kafka的docker kafka容器。2.java basic应用程序，从kafka容器外部生成和使用kafka消息。
从容器外部，我尝试使用java脚本发送kafka消息，并使用java脚本编写的consumer来使用这些消息。如果我正在用kafka容器的ip地址和主机名详细信息更新etc/hosts文件，这是有效的。请建议防止更新etc/hosts文件详细信息的解决方案。要求：使用etc/hosts文件，我们如何从外部访问kafka容器。
1条答案
按热度按时间zqdjd7g91#
我的问题有答案了。需要为kafka“server.properties”文件中的“0.0.0.0:9092”提供“listener”值。更新了kafka的docker文件，这样当容器为kafka启动时，它应该具有低于kafka容器中侦听器的值。
kafka容器>配置>服务器属性>侦听器=0.0.0.0:9092。
完成后，只需启动带有zookeeper端口转发的kafka容器和带有localhost的kafka端口。然后，您可以将Kafka消息从本地发送到Kafka容器，也可以从Kafka容器外部使用这些消息。