如何解决如何跟踪谁在Kafka中发布了消息？
想知道是否有办法强制代理包含有关推送记录的发布者的信息（可能在标头中）。
发布商可以这样做，但也可以轻松避免。
解决方法
“强制”经纪人？不，经纪人只接收记录的字节。该信息通常在生产者处完成，但即使如此，您也不能强制使用某种序列化程序或消息格式（对于后者，Confluent Server 提供代理端模式验证，但随后您会遇到客户端可以提供虚假信息）。 有了这个说明，CloudEvents 定义了元数据的“规范”，推荐用于事件驱动系统中的每条消息。
在我看来，您能做的最好的事情是强制授权 + 身份验证策略来跟踪用于访问一组主题的客户端/凭据。
OpenPolicyAgent 或 Apache Ranger 有 Kafka 插件可以帮助解决这个问题
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。
