Strimzi kafka mirrormaker2 Azure eventhubs 启动时出错

Question

我正在通过 Strimzi 设置 KafkaMirrorMaker2 并尝试将 kafka 主题镜像到 Azure eventhubs 。我能够让它适用于我在 Azure 中创建的事件中心命名空间，并且我在 Mirror Maker 配置中提供的连接字符串是命名空间本身的连接字符串 -> RootManagedSharedAccessKey （这对整个命名空间本身具有

manage / send / listen

权限） ）。然而，当我尝试连接到我们组织管理的另一个事件中心时，我遇到了启动镜像制作器的问题，并且我们对此中心没有太多控制和访问权限。管理团队为我们提供了一个特定于 eventhub 的连接字符串，我认为访问权限充其量只是

Send

，与我之前提到的命名空间级别连接字符串不同。

这是在mirrormaker pod日志中看到的错误

Could not look up partition metadata for offset backing store topic in allotted period. This could indicate a connectivity issue, unavailable topic partitions, or if this is your first use of the topic it may have taken too long to create

我的问题如下

1. Strimzi MirrorMaker2 需要什么级别的 eventhub 访问权限才能将 kafka 中的数据镜像到 eventhubs 。我们是否必须提供 namespace 级别连接以及授予的所有权限

   (Manage/Send/Listen)

2. 在我尝试的工作示例中，我没有预先创建一个 eventhub 来镜像源 kafka 主题，但随后镜像制作者在相应的命名空间中创建了一个集线器，并使用我的源主题和集群的命名模式（例如：my-cluster.my-topic）如镜像制造商定义文件中所述。当我们在 Azure 中预先创建了一个中心时，如果源主题名称与 hubname 相匹配，这将如何工作？是否有可能通过预先创建的集线器来实现此功能？