问题原因:

 

如下图,kafka 中配置的是监听域名的方式,但程序里使用的是 ip:port 的连接方式。

解决办法:

kafka 中配置的是域名的方式,程序里也相应配置成 域名:port 的方式(注意:本地hosts中需要做好相应的域名映射)。

up-8524187657bb3ee43d35b35ea08e316886d.png

Logo

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

更多推荐