Java应用向Kafka发数据：选Kafka原生API还是Kafka JMS Client？

先直接给结论：如果是全新开发的Java应用，绝对优先选Kafka官方提供的Java Producer/Consumer API，而不是Kafka JMS Client，具体原因和你关心的JMS优势问题，我整理如下：

一、为什么选原生API？ #

1. 官方明确的最佳实践
   Kafka官方文档明确建议新应用开发使用原生API——它提供了Kafka JMS Client没有的大量高级功能，比如精细的分区控制、事务消息支持、自定义序列化/反序列化逻辑、批量发送的性能优化等，这些都是构建高性能、高可靠Kafka生产者的核心能力。

2. Kafka和JMS的模型天然不匹配
   Kafka本质上是一个分布式日志存储系统，而非传统意义上的JMS消息Broker。JMS规范里的很多核心概念（比如严格的队列/主题语义、持久化订阅的精确语义、特定的消息确认模式），在Kafka里并没有完全对应的实现，强行用JMS API去套Kafka的模型，会出现语义不一致的情况，后续排查问题会非常头疼。

3. 强耦合无法避免
   哪怕你用了JMS Client，你的应用还是得和Kafka强绑定——比如要配置Kafka的Broker地址、分区策略、副本数这些Kafka特有的参数，根本达不到JMS原本“一次开发适配多种Broker”的预期。反而多了一层JMS适配层，增加了不必要的复杂度和性能开销。

二、JMS对接Kafka有没有优势？ #

说实话，优势非常有限，只有一种特定场景能体现：如果你的应用已经基于JMS规范开发完成，现在要迁移到Kafka，又不想大规模修改业务代码。这种情况下，Kafka JMS Client可以作为过渡方案，让你快速把消息发送目标切换到Kafka，暂时不用动核心业务逻辑。

但对于你这种全新开发的项目，这个优势完全不存在——用JMS API反而会限制你使用Kafka的原生能力，还平白多了一层适配的风险，完全得不偿失。

内容的提问来源于stack exchange，提问作者Mahesh