如何在 azure event hub 上使用 prem 上的 kafka 消息？

Question

我想在 azure 事件中心中使用来自已经存在的 prem kafka 服务的 kafka 消息。 我有 topic 和 brokerlist 。 我找不到我应该在事件中心的什么地方配置它们以开始接收消息。 谁能帮我做步骤？

我尝试创建事件中心命名空间并创建事件。下一步应该做什么？

Answer 1

在 Azure 事件中心使用来自本地 Kafka 服务的 Kafka 消息。

感谢

silent

的评论。

您可以在事件中心使用 Kafka 协议支持。

1. 在 Azure 中创建事件中心。

2. 为创建的事件中心配置 Kafka 端点。

通过为事件中心创建 Kafka 连接字符串。 连接字符串由

Event Hubs namespace

名称、

Event Hub name

和

Kafka endpoint

组成。您可以在本地 Kafka 服务配置中找到 Kafka 端点。

将

{YOUR.EVENTHUBS.CONNECTION.STRING}

替换为事件中心命名空间的连接字符串。有关获取连接字符串的说明，请参阅获取事件中心连接字符串。这是一个示例配置：

sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="$ConnectionString" password="Endpoint=sb://mynamespace.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=XXXXXXXXXXXXXXXX";

引用自 MSDoc1 和 MSDoc2.