章节目录：

概要

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

要求

  • Apache Kafka 代理 0.10.0.0 或更高版本
  • Parasoft SOAtest 9.10.0 或更高版本

安装

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

UI 安装

  1. 选择 Parasoft> 首选项。
  2. 在系统属性首选项页面，点击添加 JARs。
  3. 在打开的文件选择器中，选择 kafka.jar。
  4. 点击应用，重启 SOAtest。

命令行安装

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

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

使用说明

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

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

配置

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

Connection 设置

Brokers指定 Kafka 运行的以逗号分隔的服务器列表，包括端口。
Security Protocol

指定安全协议。可以指定以下值： 

  • PLAINTEXT - 指定未经验证的非加密通道。
  • SSL - 为 SSL 通道指定。 
  • SASL_PLAINTEXT- 指定经过 SASL 验证的非加密通道。该选项要求额外配置（请参阅 SASL_PLAINTEXT and SASL_SSL）。
  • SASL_SSL - 指定经过 SASL 验证的 SSL 通道。该选项要求额外配置（请参阅 SASL_PLAINTEXT and SASL_SSL）。

当此安全协议设置为 SSL 或 SASL_SSL 时，将应用传输层安全（TLS）设置。

SASL_PLAINTEXT 和 SASL_SSL

在提供的 UI 字段中无法完全配置 SASL_PLAINTEXT 和 SASL_SSL 安全协议。要使用这些安全协议，则必须创建配置文件并调整 sasl.jaas.config 属性，使其包含 com.parasoft.soavirt.kafka.shaded 包前缀。下面的示例演示了如何为普通登录模块配置包：

com.parasoft.soavirt.kafka.shaded.apache.kafka.common.security.plain.PlainLoginModule 

在 Producer Settings或 Consumer Settings设置下的 Additional Settings File Path 字段中指定文件。

Log Level

指定要将多少信息记录到控制台。默认为 2（警告）。

Producer 设置

Topic指定生产者将向其写入消息的主题的名称。
Partition

指定整数用于主题中的分区（例如，0、1、2）。

如果为空，记录键将用于生成分区号。

Record Key Serializer指定键是应该以字符串形式写入/发送，还是以 null 形式写入/发送。默认值为字符串。
Record Key指定记录键。
Idempotent

指定为 true 以确保只向代理发送一条消息，并且不向代理发送副本。默认为 false。

Request Timeout指定在超时之前等待多长时间（以毫秒为单位）来发送和接收确认。默认为 30000。
Additional Settings File Path

指定一个属性文件，其中包含与应用程序连接可能需要的其他设置。此设置为可选设置。

如果此字段为空，SOAtest 将使用默认 Kafka 设置来处理应用程序可能需要但 UI 中没有的其他设置。

Consumer 设置

Topic

指定用户应该订阅的主题名称或以逗号分隔的主题列表。

可以使用冒号和分区的整数号在主题中指定分区。例如，topic1:0。

Group id指定使用者所属的组。如果没有使用主题指定分区，则需要此属性。
Offset指定要开始读取记录的主题/分区中的位置。
Poll interval指定轮询之间的持续时间（以毫秒为单位）。默认为 100。
Max Poll Records指定要在间隔间轮询的最大记录数。默认为 500。
Commit Offsets

指定提交偏移量的模式。提交是分区中消费者可以恢复处理记录的点。

  • autocommit: 在此模式下，Kafka 将确定偏移量提交。
  • lastProcessedMessage: 在此模式下，最后处理的消息被设置为提交偏移量。
  • off: 在此模式下，不提交任何偏移量。

默认为 autocommit。

Timeout指定使用者在断开连接之前，应等待多少毫秒的时间将消息发布到订阅的主题/分区。默认为 30000。
Additional Settings File Path

指定一个属性文件，其中包含与应用程序连接可能需要的其他设置。此设置为可选设置。

如果此字段为空，SOAtest 将使用默认 Kafka 设置来处理应用程序可能需要但 UI 中没有的其他设置。

Transport Layer Security Settings

TLS Protocol

定义在建立安全连接时要使用的传输层协议。

默认：TLSv1.2 

Security Provider用于 TLS 连接的安全提供者的名称。默认值违 JVM 的默认安全提供者。
Key Store File Location定义资产（.tst、.pva、.pva）密钥库文件的绝对路径或相对路径。
Key Store Type

定义提供的密钥库文件类型。根据加载到 JVM 的不同安全提供者，可以处理不同的密钥库类型。如果向 JVM 添加了其他安全提供者，则选中安全提供者的文档，以收集可用密钥库类型名称。

Key Store Password

定义用于从密钥库文件中提取密钥/证书的密钥。

如果留空，则将尝试在没有密码的情况下提取密钥。

Key Password指定密钥库文件中私有密钥的密码。此设置对客户端而言为可选项。 
Trust Store File Location

定义资产（.tst、.pva、.pva）信任库文件的绝对路径或相对路径。

默认：Trust All Certificates 

Trust Store Type

定义提供的信任库文件类型。根据加载到 JVM 的不同安全提供者，可以处理不同的信任库类型。如果向 JVM 添加了其他安全提供者，则选中安全提供者的文档，以收集可用信任库类型名称。

Trust Store Password

定义用于从信任库文件中提取密钥/证书的密码。如果留空，则将尝试在没有密码的情况下提取密钥。

连接管理设置 

保持连接

启用此选项，让客户端保持连接并重复，以便后续的发布。

测试执行之后关闭连接

启用此选项，在发布后直接关闭客户端连接。

第三方内容

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

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

  • No labels

Need assistance? Visit our support page