在本章节中：

概要

Parasoft Kafka 传输扩展为 SOAtest 中适用的消息客户端工具添加了对 Apache Kafka 传输的支持。这使您能够在配置、发送和验证通过 Kafka 发送的消息时充分利用 SOAtest 的丰富接口。

要求

可以从 UI 或命令行中安装此工件。

将 kafka.jar 文件添加到 localsettings 属性文件中的 system.properties.classpath 属性中。例如：

system.properties.classpath=<path to jar>/kafka.jar

您可以配置您的消息客户端工具（例如， SOAP Client、 EDI Client和 Messaging Client）以通过在工具 Transport 选项卡中启用它使用 Kafka 传输。从 Transport 下拉菜单选择 Kafka ，并配置可用选项。

如果系统有多个自定义扩展名，请从 Select implementation 下拉菜单中选择 Kafka 。

传输可以配置为生产者、消费者，或者两者都可以。若要仅将传输配置为生产者，请保留使用者配置设置为空。若要仅将传输配置为使用者，请保留生产者配置设置为空。

Brokers	指定 Kafka 运行的以逗号分隔的服务器列表，包括端口。
Log Level	指定要将多少信息记录到控制台。默认是 `2` （警告）。

Topic	指定生产者将向其写入消息的主题的名称。
Partition	指定整数用于主题中的分区（比如， `0`、 `1`、 `2`）。如果为空，记录键将用于生成分区号。
Record Key Serializer	指定键是应该以字符串形式写入/发送，还是以 null 形式写入/发送。默认值为 `字符串`。
Record Key	指定记录键。
Idempotent	指定为 `true` 以确保只向代理发送一条消息，并且不向代理发送副本。默认为 `false`。
Request Timeout	指定在超时之前等待多长时间（以毫秒为单位）来发送和接收确认。默认为 `30000`。

Topic	指定用户应该订阅的主题名称或以逗号分隔的主题列表。可以使用冒号和分区的整数号在主题中指定分区。例如， `topic1:0`。
Group id	指定使用者所属的组。如果没有使用主题指定分区，则需要此属性。
Offset	指定要开始读取记录的主题/分区中的位置。
Poll interval	指定轮询之间的持续时间（以毫秒为单位）。默认为 `100`。
Max Poll Records	指定要在间隔间轮询的最大记录数。默认为 `500`。
Commit Offsets	指定提交偏移量的模式。提交是分区中消费者可以恢复处理记录的点。 `autocommit`: 在此模式下，Kafka 将确定偏移量提交。 `lastProcessedMessage`: 在此模式下，最后处理的消息被设置为提交偏移量。 `off`: 在此模式下，不提交任何偏移量。默认为 `autocommit`。
Timeout	指定使用者在断开连接之前，应等待多少毫秒的时间将消息发布到订阅的主题/分区。默认为 `30000`。

Keep connection alive	启用此选项，让客户端保持连接并重复，以便后续的发布。
Close connection after test execution	启用此选项，在发布后直接关闭客户端连接。

此扩展包括来自第三方的资源项，如下：

更多的许可详情可在该插件的 licenses 文件夹中获得。