如何在Azure Event Hub中消费本地Kafka集群的消息？

1. 确认Event Hub命名空间的Kafka兼容功能已启用 #

• 登录Azure门户，进入你的Event Hub命名空间
• 在左侧“设置”菜单里找到“Kafka”选项，确认“启用Kafka”开关是打开的（默认开启，没开的话直接打开就行）

2. 把本地Kafka的消息同步到Event Hub #

Event Hub支持Kafka兼容协议，你可以通过两种方式把本地Kafka的消息导进来：

方式一：修改本地Kafka生产者配置直接发消息到Event Hub #

• 先拿Event Hub命名空间的连接字符串：进入命名空间的“共享访问策略”，选一个有“发送”权限的策略（比如RootManageSharedAccessKey），复制它的“连接字符串-主密钥”
• 给本地Kafka生产者加这些配置：
  • bootstrap.servers：设为 <你的命名空间名称>.servicebus.windows.net:9093
  • security.protocol：SASL_SSL
  • sasl.mechanism：PLAIN
  • sasl.jaas.config：org.apache.kafka.common.security.plain.PlainLoginModule required username="$ConnectionString" password="你刚才复制的连接字符串";
  • acks：设为1（按需调整）
• 把生产者的目标Topic改成你创建的Event Hub名称（Event Hub名称和Kafka Topic是一一对应的）

方式二：用Kafka Connect做消息同步 #

• 下载Azure Event Hub的Kafka Connect连接器
• 配置Connect任务：
  • 源连接器：指向本地Kafka集群，指定要同步的Topic
  • Sink连接器：指向Event Hub的Kafka端点，填好连接字符串和目标Event Hub名称
• 启动Connect任务，它会自动把本地Kafka的消息同步到Event Hub

3. 验证消息是否成功接收 #

• 打开Azure门户里的Event Hub页面，看“指标”里的“传入消息”数据有没有增长
• 或者用Azure CLI命令 az eventhubs eventhub show-metrics --namespace-name <命名空间名> --name <Event Hub名> 查看接收情况
• 也可以用Kafka客户端连接到Event Hub，试着消费消息确认同步成功

4. 优化权限与安全（建议做） #

• 别用RootManageSharedAccessKey，单独创建一个只有“发送”权限的共享访问策略给生产者/Connect任务，降低权限风险
• 配置IP防火墙或虚拟网络服务端点，只允许本地Kafka集群访问Event Hub命名空间，提升安全性

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