...
Parasoft Kafka 传输扩展为 SOAtest 中适用的消息客户端工具添加了对 Apache Kafka 传输的支持。这使你能够在配置、发送和验证通过 传输的支持。这使您能够在配置、发送和验证通过 Kafka 发送的消息时充分利用 SOAtest 的丰富接口。
...
可以从 UI 或命令行中安装此工件。
UI 安装指南
- 选择 Parasoft> 首选项 Preferences。
- 在 System Properties 首选项页面，单击 Add JARs。
- 在打开的文件选择器中，选择 kafka.jar。
- 单击 Apply ，重启 SOAtest。
...
system.properties.classpath=<path to jar>/kafka.jar
使用说明
你可以配置你的消息客户端工具（例如， 您可以配置您的消息客户端工具（例如， SOAP Client、 EDI Client和 Messaging Client）以通过在工具 Transport 选项卡中启用它使用 Kafka 传输。从 Transport 下拉菜单选择 Kafka ，并配置可用选项。
如果系统有多个自定义扩展名，请从“选择实现”下拉菜单中选择 如果系统有多个自定义扩展名，请从 Select implementation 下拉菜单中选择 Kafka 。
配置
传输可以配置为生产者、消费者，或者两者都可以。若要仅将传输配置为生产者，请保留使用者配置设置为空。若要仅将传输配置为使用者，请保留生产者配置设置为空。
...
| Scroll Table Layout | ||
|---|---|---|
|
| 代理Brokers | 指定 Kafka 运行的以逗号分隔的服务器列表，包括端口。 |
|---|---|
| 日志级别Log Level | 指定要将多少信息记录到控制台。默认是 |
生产者设置
| Scroll Table Layout | ||
|---|---|---|
|
| 主题Topic | 指定 生产者 将向其写入消息的主题的名称。 |
|---|---|
| 分区Partition | 指定整数 用于主题中的分区 （比如， 如果为空，记录键将用于生成分区号。 |
| 记录关键序列化器Record Key Serializer | 指定键是应该以字符串形式写入/发送，还是以 null 形式写入/发送。默认值为 字符串。 |
| 记录键Record Key | 指定记录键。 |
| 幂等性Idempotent | 指定为 |
| 请求超时Request Timeout | 指定在超时之前等待多长时间（以毫秒为单位）来发送和接收确认。默认为 30000。 |
...
| Scroll Table Layout | ||
|---|---|---|
|
| 主题Topic | 指定用户应该订阅的主题名称或以逗号分隔的主题列表。 可以使用冒号和分区的整数号在主题中指定分区。例如， |
|---|---|
| 组 Group id | 指定使用者所属的组。如果没有使用主题指定分区，则需要此属性。 |
| 偏离量Offset | 指定要开始读取记录的主题/分区中的位置。 |
| 轮询间隔Poll interval | 指定轮询之间的持续时间（以毫秒为单位）。默认为 100。 |
| 最大轮询记录数Max Poll Records | 指定要在间隔间轮询的最大记录数。默认为 500。 |
| 提交偏离量Commit Offsets | 指定提交偏移量的模式。提交是分区中消费者可以恢复处理记录的点。
默认为 |
| 超时时间Timeout | 指定使用者在断开连接之前，应等待多少毫秒的时间将消息发布到订阅的主题/分区。默认为 30000。 |
...
| Scroll Table Layout | ||
|---|---|---|
|
保持连接Keep connection alive | 启用此选项，让客户端保持连接并重复，以便后续的发布。 |
|---|---|
测试执行后关闭连接Close connection after test execution | 启用此选项，在发布后直接关闭客户端连接。 |
第三方内容
...