这是一个非常通用的、体系结构类型的问题。我有一个源系统（kafka），其中数据在一个主题中不断流动。有一个外部客户对数据感兴趣。经过多次对话，我们决定实现一个基于pull的系统，客户机通过反向代理从kafka主题中提取数据。
我如何在微观层面进行审计，以确认源中的所有数据确实已交付给客户机？这是一个大容量系统（约400毫秒/秒）。我当然可以给客户提供Kafka滞后通知的进度。不过，这并不会告诉我们在传输过程中是否有任何消息丢失或丢失。
任何提示都将不胜感激。
谢谢