专为小白打造—Kafka一篇文章入门
💡
原文中文，约11100字，阅读约需27分钟。
📝
内容提要
本文介绍Kafka生产者和消费者流程，异常场景实践，JMQ服务端配置消费失败重试逻辑，包括本地和服务端重试，需要分别配置。
🎯
关键要点
- Kafka是常用的消息队列中间件，具有解耦、异步、限流等特性。
- Topic是逻辑概念，Partition是物理概念，Partition提高消息性能与吞吐量。
- Broker是Kafka进程的实现，Partition的副本存在于不同的Broker中以保证可靠性。
- 生产者负责产生消息，消费者负责接收消息，ZooKeeper管理集群元数据。
- 消费者组确保一条消息只被一个消费者消费，支持横向扩展。
- ISR机制保证消息不丢失，HW和LEO用于管理副本的同步状态。
- Kafka全流程包括注册信息、创建主题、生产者发送数据和消费者消费数据。
- 生产者发送数据时会封装成ProducerRecord，支持序列化和分区选择。
- 消费者通过拉取模式消费消息，支持手动和自动提交offset。
- 异常场景中需注意捕获异常，避免影响后续消息消费。
- 重试机制分为本地重试和服务端重试，需要分别配置。
➡️
