Versions Compared

Old Version 6

changes.mady.by.user user-50d80

Saved on

compared with

New Version 7

changes.mady.by.user user-50d80

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.
Comment: Published by Scroll Versions from space FUNCTDEV and version SVC2020.2

...

You can configure you message client tools (e.g., SOAP Client, EDI Client, and Messaging Client) to use the Kafka Transport by enabling it in the tool's Transport tab. Choose Kafka from the Transport drop-down menu and configure the available options.

Image RemovedImage Added

If your system has more than one custom extension, choose Kafka from the Select implementation drop-down menu. 

...

Scroll Table Layout
widths30%,70%

BrokersSpecify a comma-separated list of servers where Kafka is running, including the ports.
Security Protocol

Specifies the security protocol. You can specify following values: 

  • PLAINTEXT - Specifies an unauthenticated, non-encrypted channel.
  • SSL - Specifies for an SSL channel. 
  • SASL_PLAINTEXT - Specifies an SASL-authenticated, non-encrypted channel. This option requires additional configuration (see Kafka Transport 1.1).
  • SASL_SSL - Specifies an SASL-authenticated, SSL channel. This option requires additional configuration (see Kafka Transport 1.1).

The Transport Layer Security (TLS) settings will be applied when this Security Protocol is set to either SSL or SASL_SSL.

SASL_PLAINTEXT and SASL_SSL

You cannot fully configure the SASL_PLAINTEXT and SASL_SSL security protocols in the UI fields provided. If you want to use these security protocols, you must create a configuration file and adjust the sasl.jaas.config property to include the com.parasoft.soavirt.kafka.shaded package prefix. The following example demonstrates how to configure the package for the plain login module:

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

Specify the file in the Additional Settings File Path field under the Kafka Transport 1.1 or Kafka Transport 1.1.

Log Level

Specify how much information you want logged to the console. The default is 2 (warn).

Producer Settings

Scroll Table Layout
widths30%,70%

TopicSpecify the name of a topic to which the producer will write messages.
Partition

Specify the integer number for the partition in a topic (e.g., 0, 1, 2).

If empty, the record key will be used to generate a partition number.

Record Key SerializerSpecify whether the key should be written/sent as a string or as null. The default value is string.
Record KeySpecify the record key.
Idempotent

Specify true to insure that only one message and no duplicates will be sent to the broker. Default is false.

Request TimeoutSpecify the how long to wait in milliseconds to send and receive an acknowledgment before timing out. Default is 30000.
Additional Settings File Path

Specify a properties file containing additional settings that may be required to connect to your application. This setting is optional.

If this field is empty, SOAtest will use default Kafka settings for any additional settings your application may require that are not available in the UI.

Consumer Settings

Scroll Table Layout
widths30%,70%

Topic

Specify the name of a topic or a comma-separated list of topics to which the consumer should subscribe.

You can specify a partition within the topic with a colon and the integer number for the partition. For example, topic1:0.

Group idSpecify the group to which the consumer belongs. This property is required when partition is not specified with the topic.
OffsetSpecify the position within a topic/partition to begin reading records.
Poll intervalSpecify a duration in milliseconds between polling. Default is 100.
Max Poll RecordsSpecify the maximum number of records to poll between intervals. Default is 500.
Commit Offsets

Specify a mode for committing offsets. Commits are points in the partition at which the consumer can resume processing records.

  • autocommit: In this mode, Kafka will determine offset commits.
  • lastProcessedMessage: In this mode, the last message processed is set as the commit offset.
  • off: In this mode, no offsets are committed.

Default is autocommit.

TimeoutSpecify how many milliseconds the consumer should wait for messages to be published to the subscribed topic/partition before disconnecting. Default is 30000.
Additional Settings File Path

Specify a properties file containing additional settings that may be required to connect to your application. This setting is optional.

If this field is empty, SOAtest will use default Kafka settings for any additional settings your application may require that are not available in the UI.

Transport Layer Security

Scroll Table Layout
widths30%,70%

...