我试图在我的kafka主题中发送一些示例记录以及模式。联机producer.send(记录)我面临未经授权的错误?
我已经在配置中提供了基本的验证细节和url。另外,我已经为这个主题分配了各种角色。
可能缺少什么,为什么不允许我发送记录?
提供您的详细信息日志,然后我们可以更深入地查看。基本上,你应该仔细检查与producer相关的配置:
- tls是否启用
- client-id(如果启用事务性)
- 目标主题的ACL(写权限)