迁移至Kafka时，能否实现类似ActiveMQ的嵌入式Broker转发功能？

当然可以！不过Kafka的实现思路和你用ActiveMQ的嵌入式Broker模式不太一样，我给你整理两种符合需求的方案：

方案1：复刻「嵌入式Broker+转发」架构（最贴近原ActiveMQ逻辑） #

Kafka本身没有官方的"嵌入式Broker"概念，但你可以在应用进程中启动一个轻量的Kafka Broker实例（比如借助Spring Kafka的EmbeddedKafka组件，或者手动调用Kafka的Broker API启动），实现类似ActiveMQ嵌入式Broker的本地缓存+转发能力：

• 本地内嵌Broker：在应用中启动一个仅监听本地端口的Kafka Broker，配置本地磁盘作为消息存储路径（避免和外部集群冲突）。
• 消息转发配置：使用Kafka的**MirrorMaker 2（MM2）**工具，配置它将本地Broker上指定主题（对应你原来的someQueueName队列）的消息同步到外部Kafka集群。MM2会自动处理外部集群不可用的情况：当外部集群失联时，消息会暂存在本地Broker的磁盘上，直到集群恢复后再自动同步。
• 应用生产者配置：让你的应用生产者直接发送消息到本地内嵌Broker的目标主题即可。

这种方案完全复刻了你原来的ActiveMQ架构逻辑，本地消息有持久化保障，即使应用重启也不会丢失未转发的消息。

方案2：用Kafka Producer内置能力实现（更轻量推荐） #

如果你的核心需求只是「外部Broker不可用时暂存消息，恢复后自动发送」，其实不需要启动内嵌Broker，直接利用Kafka Producer的原生配置就能实现：

Kafka Producer本身自带本地内存缓存和重试机制，配合以下关键配置就能达到效果：

# 指定外部Kafka集群地址
bootstrap.servers=somehost:1234
# 设置本地内存缓存大小（示例为32MB）
buffer.memory=33554432
# 设置无限重试（直到Broker恢复）
retries=2147483647
# 设置重试间隔（示例为1秒）
retry.backoff.ms=1000
# 确保消息被外部Broker的所有副本确认后才算发送成功
acks=all
# 开启幂等性，避免重试时重复发送消息
enable.idempotence=true

如果担心应用崩溃导致内存缓存的消息丢失，你可以额外加一层本地磁盘持久化：比如在Producer发送失败时，把消息写入本地文件队列，启动一个后台线程定期重试发送这些本地消息。

这种方案更轻量，不需要额外管理内嵌Broker，是大多数场景下的首选。

两种方案对比 #

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