标签: 消息队列

所有带有标签 "消息队列".

• Kafka（五）消费者回调 +定时重试 + 理解Rebalance

  2023年11月25日

  至此为止，利用Kafka实现一个消息系统就基本完成了，所有关键的代码都在不同的博文中并进行了详细说明，说过想要体会完整的设计、实现思路，请移步源码仓库获取完整代码。下一篇关于Kafak的博文打算分享一下如何利用Kafka Connect将Oracle数据库的数据同步到Postgre SQL中。

• Kafka（四）消费者消费JSON消息+使用统一反序列化器+提升吞吐量

  2023年11月18日

  介绍Kafka消费者处理JSON消息的实现，包括统一反序列化、消息去重、失败重试与偏移量提交。结合压测讨论分区数和消费参数的调整，并使用模板方法复用不同优先级邮件的消费流程。

• Kafka（二）将邮件发送从业务系统中解耦之消息系统设计

  2023年11月4日

  以邮件发送为例，介绍通过Kafka解耦业务系统与邮件系统的设计思路。讨论两者的职责边界、统一消息格式、发送与回调流程，以及新旧系统切换时的回退方案，为后续生产者和消费者实现提供背景。

• Kafka（一）使用Docker Compose安装单机Kafka+Kafka UI+Prometheus JMX Exporter

  2023年9月30日

  使用Docker Compose搭建KRaft模式的单机Kafka，并集成Kafka UI和Prometheus JMX Exporter。说明监听器、角色、内存和监控配置，记录启动验证、JMX端口冲突及资源配置问题的排查方法。