我正在构建一个实时处理管道，使用kafka流来处理来自kafka和kafka connect的数据，将数据集成到mongodb中。下一阶段是记录kafka流和连接度量（延迟、吞吐量、跳过的记录等）并写入标准输出。实现这一目标的有效方法是什么？
提前谢谢