1. server.properties 配置文件中,只要advertised.listeners如下配置即可,listeners 可以不配。
    在这里插入图片描述
  2. 最主要的就是阿里云服务器需要添加安全组规则,把 9092 端口开放,否则就连接不上。
    在这里插入图片描述
    在这里插入图片描述
    在这里插入图片描述

此时相应的启动消费者或者启动生产者的命令为:bin/kafka-console-consumer.sh --bootstrap-server外网IP:9092 --topic pers
在这里插入图片描述
注意红框处必须写外网IP,不能写 localhost

Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐