向事件流添加自定义终结点或自定义应用源
如果要将自己的应用程序与事件流连接，可以添加自定义终结点或自定义应用作为源。 然后，可以使用在自定义终结点或自定义应用上公开的连接终结点，从自己的应用程序将事件流中的实时事件发送到事件流。 此外，在 Apache Kafka 协议可作为自定义终结点或自定义应用的选项的情况下，你可以通过 Apache Kafka 协议发送实时事件。
本文介绍了如何将自定义终结点源或自定义应用源添加到 Microsoft Fabric 事件流中的事件流。
注意
如果要使用预览版中的增强功能，请选择顶部的“增强功能”。 否则，请选择“标准功能”。 有关预览版中增强功能的信息，请参阅 Fabric 事件流简介。
先决条件
在开始之前，必须具有参与者或更高的 Fabric 高级工作区访问权限。
注意
一个事件流的源和目标的最大数量为 11。
将自定义终结点数据添加为源
新建事件流：
在主页页上，选择“事件流”。
在“新建事件流”对话框中，输入名称，确保选中“增强功能”（预览版）选项，然后选择“创建”。
要添加自定义终结点源，请在“入门”页面上，选择“使用自定义终结点”。
或者，如果已有已发布的事件流，并且想要将自定义终结点数据添加为源，请切换到“编辑”模式。 在功能区上，选择“添加源”>“自定义终结点”。
在“自定义终结点”对话框中，在“源名称”下，输入自定义源的名称，然后选择“添加”。
创建自定义终结点源后，会看到其在“编辑模式”下添加到画布上的事件流。 若要实现新添加的自定义应用源数据，请选择“发布”。
获取“详细信息”窗格上的终结点详细信息以发送事件
创建自定义终结点源后，其数据可用于实时视图中的可视化效果。
“详细信息”窗格有三个协议选项卡：“事件中心”、“AMQP”和“Kafka”。 每个协议选项卡有三页：基本信息、密钥和示例代码。 这些页面提供终结点详细信息以及相应的连接协议。
“基本信息”页显示自定义终结点的名称、类型和状态。
“密钥”页提供有关连接密钥的信息。 “示例代码”页提供了示例代码（其中嵌入了相应的密钥），可用于将事件流式传输到事件流中。 这些页面上的信息因协议而异。
事件中心
“事件中心”选项卡上的“密钥”页包含与事件中心的连接字符串相关的信息。 该信息包括“事件中心名称”、“共享访问密钥名称”、“主密钥”和“连接字符串 - 主密钥”。
事件中心格式是连接字符串的默认设置，它与 Azure 事件中心 SDK 兼容。 使用此格式，你通过事件中心协议连接到事件流。
以下示例显示了事件中心格式的连接字符串的呈现效果：
Endpoint=sb://eventstream-xxxxxxxx.servicebus.windows.net/;SharedAccessKeyName=key_xxxxxxxx;SharedAccessKey=xxxxxxxx;EntityPath=es_xxxxxxx
“事件中心”选项卡上的“示例代码”页提供了可立即使用的代码，其中包含有关事件中心内的连接密钥的必需信息。 只需将其复制并粘贴到应用程序中即可使用。
Kafka
Kafka 格式与 Apache Kafka 协议兼容，后者是一种流行的分布式流式处理平台，支持高吞吐量和低延迟的数据处理。 可以使用 Kafka 协议格式的“密钥”和“示例代码”信息来连接到事件流并流式传输事件。
“Kafka”选项卡上的“示例代码”页提供了现成的代码，其中包括 Kafka 格式的必要连接密钥。 只需复制它，它就可以供你使用。
AMQP
AMQP 格式与 AMQP 1.0 协议兼容，后者是一种标准消息传递协议，支持各种平台和语言之间的互操作性。 可以使用此格式通过 AMQP 协议连接到事件流。
“AMQP”选项卡上的“示例代码”页提供了可立即使用的代码，其中包含 AMQP 格式的连接密钥信息。
可以选择适合应用程序需求和偏好的协议格式，然后将连接字符串复制并粘贴到应用程序中。 还可以引用或复制“示例代码”页上的示例代码，其中显示了如何使用各种协议发送或接收事件。
相关内容
若要了解如何将其他源添加到 eventstream，请参阅以下文章：
先决条件
在开始之前，必须使用参与者权限或更高权限获取事件流所在高级工作区的访问权限。
注意
一个事件流的源和目标的最大数量为 11。
添加自定义应用作为源
如果要将自己的应用程序与事件流连接，可以添加自定义应用源。 然后，使用在自定义应用中公开的连接终结点，从自己的应用程序将数据发送到事件流。
若要添加自定义应用源：
在功能区上选择“新建源”或在主编辑器画布中选择“+”，然后选择“自定义应用”。
在“自定义应用”窗格上，输入自定义应用的源名称，然后选择“添加”。
获取“详细信息”窗格上的终结点详细信息以发送事件
成功将自定义应用程序创建为源后，可以在“详细信息”窗格上查看信息。
“详细信息”窗格有三个协议选项卡：“事件中心”、“AMQP”和“Kafka”。 每个协议选项卡有三页：基本信息、密钥和示例代码。 这些页面提供终结点详细信息以及相应的连接协议。
“基本信息”页显示自定义应用的名称、类型和状态。
“密钥”页提供有关连接密钥的信息。 “示例代码”页提供了示例代码（其中嵌入了相应的密钥），可用于将事件流式传输到事件流中。 这些页面上的信息因协议而异。
事件中心
“事件中心”选项卡上的“密钥”页包含与事件中心的连接字符串相关的信息。 该信息包括“事件中心名称”、“共享访问密钥名称”、“主密钥”和“连接字符串 - 主密钥”。
事件中心格式是连接字符串的默认设置，它与 Azure 事件中心 SDK 兼容。 使用此格式，你通过事件中心协议连接到事件流。
以下示例显示了事件中心格式的连接字符串的呈现效果：
Endpoint=sb://eventstream-xxxxxxxx.servicebus.windows.net/;SharedAccessKeyName=key_xxxxxxxx;SharedAccessKey=xxxxxxxx;EntityPath=es_xxxxxxx
“事件中心”选项卡上的“示例代码”页提供了可立即使用的代码，其中包含有关事件中心内的连接密钥的必需信息。 只需将其复制并粘贴到应用程序中即可使用。
Kafka
Kafka 格式与 Apache Kafka 协议兼容，后者是一种流行的分布式流式处理平台，支持高吞吐量和低延迟的数据处理。 可以使用 Kafka 协议格式的“密钥”和“示例代码”信息来连接到事件流并流式传输事件。
“Kafka”选项卡上的“示例代码”页提供了现成的代码，其中包括 Kafka 格式的必要连接密钥。 只需复制它，它就可以供你使用。
AMQP
AMQP 格式与 AMQP 1.0 协议兼容，后者是一种标准消息传递协议，支持各种平台和语言之间的互操作性。 可以使用此格式通过 AMQP 协议连接到事件流。
“AMQP”选项卡上的“示例代码”页提供了可立即使用的代码，其中包含 AMQP 格式的连接密钥信息。
可以选择适合应用程序需求和偏好的协议格式，然后将连接字符串复制并粘贴到应用程序中。 还可以引用或复制“示例代码”页上的示例代码，其中显示了如何使用各种协议发送或接收事件。
相关内容
若要了解如何将其他源添加到 eventstream，请参阅以下文章：