Kafka简介
Kafka最初由Linkedin公司开辟的分布式、分区的、多副本的、多订阅者的消息系统。它提供了雷同于JMS的特性，但是在计划实现上完全不同，别的它并不是JMS规范的实现。kafka对消息保存是根据Topic进行归类，发送消息者称为Producer；消息继承者称为Consumer；别的kafka集群有多个kafka实例组成，每个实例(server)称为broker。无论是kafka集群，还是producer和consumer都依赖于zookeeper来保证系统可用性集群保存一些meta信息（kafka的0.8版本之后，producer不在依赖zookeeper保存meta信息，而是producer本身保存meta信息）。本文不打算对Apache Kafka的原理和实现进行介绍，而在编程的角度上介绍如何利用Apache Kafka。我们分别介绍如何编写Producer、Consumer以及Partitioner等。
Producer发送的消息是如何定位到具体的broker
- 生产者初始化：Producer在初始化时会加载配置参数，并开启网络线程准备发送消息。
- 拦截器逻辑：Producer可以设置拦截器来预处理消息，比方，修改大概丰富消息内容。
- 序列化：Producer将处理后的消息key/value进行序列化，以便在网络上传输。
- 分区计谋：Producer会根据分区计谋选择一个合适的分区，这个分区计谋可以是轮询、随机大概根据key的哈希值等。
- 选择Broker：Producer并不直接将消息发送到指定的Broker，而是将消息发送到所选分区的leader副本地点的Broker。如果一个主题有多个分区，这些分区会均匀分布在集群中的Broker上。每个分区都有一个leader副本，Producer总是将消息发送到leader副本，然后由leader副本负责同步到follower副本。
- 发送模式：Producer发送消息的模式主要有三种：发后即忘（不关心结果），同步发送（等候结果），以及异步发送（通过Future对象跟踪状态）。
- 缓冲和批量发送：为了进步服从，Producer会先将消息收集到一个批次中，然后再一次性发送到Broker。
- 可靠性配置：Producer可以通过设置request.required.acks参数来控制消息的可靠性级别，比方，设置为"all"时，必要全部in-sync replicas都确认吸取后才以为消息发送乐成。
- 失败重试：如果哀求失败，Producer会根据配置的retries参数来决定是否重试发送消息。
Kafka的Producer通过一系列步调来确定消息的发送目标，此中分区计谋和leader副本的选择是关键步调，确保了消息可以或许正确地发送到相应的Broker。同时，通过公道的配置和重试机制，Producer可以或许保证消息的可靠性和系统的健壮性。
Kafka存储文件长什么样
在kafka集群中，每个broker（一个kafka实例称为一个broker）中有多个topic，topic数量可以本身设定。在每个topic中又有多个partition，每个partition为一个分区。kafka的分区有本身的命名的规则，它的命名规则为topic的名称+有序序号，这个序号从0开始依次增长。
在每个partition中有可以分为多个segment file。当生产者往partition中存储数据时，内存中存不下了，就会往segment file内里存储。kafka默认每个segment file的巨细是500M，在存储数据时，会老师成一个segment file，当这个segment file到500M之后，再天生第二个segment file 以此类推。每个segment file对应两个文件，分别是以.log末端的数据文件和以.index末端的索引文件。
具体来说，Kafka中的每个分区（Partition）由一个或多个Segment组成。每个Segment现实上是磁盘上的一个目录，这个目录下面会包含几个特定的文件：
- .log文件：这是真正存储消息数据的地方。每个Segment有一个对应的.log文件，它存储了属于这个Segment的全部消息。
- .index文件：索引文件，用于快速定位到.log文件中的具体消息。通过.index文件可以高效地查找消息地点的.log文件位置。
- .timeindex文件（可选）：如果启用了时间戳索引，还会有这个文件。它用于按时间戳高效检索消息。
别的，Segment作为Kafka中数据构造的根本单位，计划成固定巨细，如许做可以方便地进行数据的清理和压缩，同时保证性能。当一个Segment文件写满后，Kafka会主动创建一个新的Segment来继承存储数据。旧的Segment文件在满足肯定条件（如被消费且达到肯定的保存期）后会被删除，释放磁盘空间。
每个segment file也有本身的命名规则，每个名字有20个字符，不够用0填充。每个名字从0开始命名，下一个segment file文件的名字就是上一个segment file中最后一条消息的索引值。在.index文件中，存储的是key-value格式的，key代表在.log中按顺序开始第条消息，value代表该消息的位置偏移。但是在.index中不是对每条消息都做记载，它是每隔一些消息记载一次，制止占用太多内存。纵然消息不在index记载中在已有的记载中查找，范围也大大缩小了。
Consumer如何消费数据
Kafka中的Consumer通过以下步调来消费数据：
- 创建消费者实例：必要创建一个消费者实例，并指定一些关键配置，如消费者所属的群组、Topic名称以及与服务器通信的相关设置。
- 订阅主题：创建好的消费者实例必要订阅一个或多个主题，以便开始吸取消息。
- 拉取数据：与一些消息系统采用的推送模式不同，Kafka的消费者采用的是“拉取”模式。这意味着消费者必要主动从Broker拉取数据，而不是等候Broker将数据推送过来。这种模式使得消费者可以根据自身处理能力来控制数据的获取速率。
- 长轮询机制：在没有新消息可消费时，消费者会利用长轮询机制等候新消息到达。消费者调用poll()方法时可以设置超时时间（timeout），如许如果没有新消息，消费者会在等候一段时间后返回，并在下次调用poll()时继承尝试获取新消息。
- 提交偏移量：消费者在消费过程中会跟踪每个分区的消费进度，即偏移量（offset）。当消费者处理完消息后，它会提交当前的偏移量到Broker，以便在服务重启或故障恢复的情况下可以从准确的位置继承消费数据。
- 故障恢复：如果消费者发生宕机等故障，由于Kafka会持久化消费者的偏移量信息，消费者可以在恢复后继承从之条件交的偏移量处消费数据，确保不丢失任何消息。
- 消费者群组：Kafka支持多个消费者组成一个群组共同消费一个主题。在一个群组内，每个消费者会被分配不同的分区来消费，从而实现负载平衡和横向伸缩。同一个分区不能被一个群组内的多个消费者同时消费。
- 数据处理：消费者在拉取到数据后，可以根据本身的业务逻辑对数据进行处理，好比进行及时流处理大概存储到数据库中进行离线分析。
综上所述，Kafka的Consumer通过上述流程高效地从Broker拉取并处理数据，这些特性使得Kafka可以或许在高吞吐量和可扩展性方面表现精彩，恰当处理大规模数据流的场景。
Kafka中的逾期数据处理机制
kafka作为一个消息中心件，是必要定期处理数据的，否则磁盘就爆了。
处理的机制
- 根据数据的时间长短进行清理，比方数据在磁盘中超过多久会被清理（默认是168个小时）
- 根据文件巨细的方式给进行清理，比方数据巨细超过多大时，删除数据（巨细是按照每个partition的巨细来界定的）。
删除逾期的日记的方式
Kafka通过日记清理机制来删除逾期的日记，主要依赖于两个配置参数来实现这一功能：
- 日记保存时间：通过设置log.retention.hours参数，可以指定日记文件的保存时间。当日记文件的保存时间超过这个设定值时，这些文件将被删除。
- 日记清理计谋：Kafka支持两种日记清理计谋，分别是delete和compact。delete计谋会根据数据的保存时间或日记的最大巨细来进行删除。而compact计谋则是根据消息中的key来进行删除操作，通常用于特定类型的主题，如__consumer_offsets。
别的，在Kafka 0.9.0及更高版本中，日记清理功能默认是开启的（log.cleaner.enable默以为true）。这意味着Kafka会主动运行清理线程来执行定时清理任务。
综上所述，Kafka通过结合保存时间和清理计谋的配置，实现了对逾期日记的有效管理。这些机制确保了系统资源的公道利用，同时制止了因日记无限增长而导致的潜在问题
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。 |
