1、核心痛点解决: 官方spring-kafka仅支持单一Kafka集群配置,本项目完美解决项目中需要对接单个或多个Kafka集群的场景需求。
2、三大核心能力:
a)多集群灵活配置
支持单一集群或多集群同时配置
支持多种安全策略(SASL认证、SSL证书认证、宽松认证等)
可动态启用/禁用特定集群配置
支持主配置(primary)概念,简化默认使用场景
b)灵活消费者实例获取
提供JmConsumerFactory工厂,可动态创建消费者实例
支持指定topic和分区进行消费(如:topic0@0, topic0@1-3)
突破@KafkaListener注解的使用限制
满足独立使用、定制化等特殊场景需求
支持扩展属性配置
c)极简消息总线
提供事件发布与处理的统一抽象
易于理解和使用的事件驱动模型
支持集群定向任务、广播任务、节点控制等多元化作业场景
自动生成唯一消费者组ID(应用名@端口@MAC地址格式)
支持与Spring Cloud总线同时使用且不冲突
提供HTTP接口实现总线服务的启停控制
3、适用场景:
微服务架构中多Kafka集群接入
需要动态控制Kafka消费者的业务场景
分布式系统中的事件驱动架构
跨集群的消息路由与处理
需要精细化控制topic分区的消费场景
4、项目优势:
零侵入式集成,仅需引入依赖即可使用
配置方式与官方保持一致,学习成本低
兼容Spring Boot自动配置机制
提供完整的示例代码和配置说明
点击空白处退出提示














评论