Kafka日志压缩回调



我正在使用Kafka日志压缩程序,我想知道当Kafka broker执行我的Topic的日志压缩时,是否有任何回调函数可以作为消费者调用。

到目前为止,我还看不到任何回调,所以我想知道检测日志压缩发生的标准策略是什么。

问候

客户端本身与此类事件的代理没有通信。过去,我们使用Splunk从LogCleaner进程日志中捕获压缩事件,如果出于任何原因需要(我们只将其用于管理调试,客户端从不需要(,我们可以基于此生成webhook事件

最新更新