在平时我们使用 Jenkins 执行任务构建时候会产生很多指标性数据，这些数据会输出到 Jenkins 日志中，在 Jenkins 中日志是存储到文件里面的，且数据量多我们收集起存储来不是很方便，很多时候我们只要部分指标关键数据，例如，用于统计任务构建时长的'开始时间'和'结束时间'、'任务执行次数'、'任务执行人'、'任务编号'等等。收集这些关系指标数据有很多方法，可以使用 logstash 插件将数据输入到 Elasticsearch 中，也可以输出到 Kafka 等应用处理后再存储，这里就是将数据输出到 Kafka 中，方便后续处理这些数据。这里介绍下如何安装与使用该插件。

kafka是一个分布式消息队列，具有高性能、持久化、多副本备份、横向扩展能力。生产者往队列里写消息，消费者从队列里取消息进行业务逻辑。一般在架构设计中起到解耦、削峰、异步处理的作用。最近学习了下它的使用，项目中主要是 SpringBoot 框架开发程序，所以这里简单介绍下 kafka 相关知识，以及详细介绍下 SpringBoot 使用 Spring For Kafka 组件是如何操作 Kafka 的。

Kafka 是由 Apache 软件基金会开发的一个开源流处理平台，由 Scala 和 Java 编写。它是一个分布式、支持分区的的、多副本，基于 zookeeper 协调的分布式消息系统。它最大特性是可以实时的处理大量数据以满足各种需求场景，比如基于 Hadoop 的批处理系统、低延时的实时系统、storm/Spark 流式处理引擎，web/nginx 日志，访问日志，消息服务等等。这里将演示如何在 Kubernetes 中部署 Kafka、Zookeeper、kafka-manager 几个应用实践。