在本章节中：

概要

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 ，并配置可用选项。

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

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

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

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

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

保持连接	启用此选项，让客户端保持连接并重复，以便后续的发布。
测试执行后关闭连接	启用此选项，在发布后直接关闭客户端连接。

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

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