Kafka很强大，但是一步出错就可能导致系统数据损坏！
前言 Apache Kafka 已成为跨微服务异步通信的主流平台。它有很多强大的特性，让我们能够构建健壮、有弹性的异步架构。 同时，我们在使用它的过程中也需要小心很多潜在的陷阱。如果未能提前发现可能发生（换句话说就是迟早会发生）的问题，我们就要面对一个容易出错和损坏数据的系统了，Java中间件面试真题 +学习笔记。 今天小编会将重点介绍其中的一个陷阱：尝试处理消息时遭遇失败。首先，我们需要意识到消息消费可能会，而且迟早会遭遇失败。其次，我们需要确保在处理此类故障时不会引入更多问题。 Kafka 简介 网上也有一些介绍 Kafka 及其使用方法的深度文章。话虽如此，我们这里还是先简要回顾一下对我们的讨论很重要的一些概念。 事件日志、发布者和消费者 Kafka 是用来处理数据流的系统。从概念上讲，我们可以认为 Kafka 包含三个基本组件： 一个事件日志（Event Log），消息会发布到它这里 发布者（Publisher），将消息发布到事件日志 消费者（Consumer），消费（也就是使用）事件日志中的消息 与 RabbitMQ 之类的传统消息队列不同，Kafka 由消费者来决定何时读取...
