如何追踪谁在卡夫卡中发布了一条信息



想知道是否有办法强制代理包含有关推送记录的发布者的信息(可能在标头中(。

出版商可以这样做,但也可以很容易地避免。

"力";经纪人?否,代理只接收记录的字节。这些信息通常会在生产者处完成,但即使这样,您也不能强制使用特定的序列化程序或消息格式(对于稍后的版本,Confluent Server提供代理端架构验证,但随后您会遇到客户端可能提供虚假信息的问题(。注意,CloudEvents定义了一个";spec";用于事件驱动系统中为每条消息推荐的元数据。

在我看来,您能做的最好的事情就是强制授权+身份验证策略来跟踪用于访问一组主题的客户端/凭据。

OpenPolicyAgent或Apache Ranger有Kafka插件,可以帮助实现

最新更新