...
Topic | Specify 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., If empty, the record key will be used to generate a partition number. |
Record Key Serializer | Specify whether the key should be written/sent as a string or as null. The default value is string . |
Record Key | Specify the record key. |
Idempotent | Specify |
Request Timeout | Specify 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 | ||
---|---|---|
|
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, |
---|---|
Group id | Specify the group to which the consumer belongs. This property is required when partition is not specified with the topic. |
Offset | Specify the position within a topic/partition to begin reading records. |
Poll interval | Specify a duration in milliseconds between polling. Default is 100 . |
Max Poll Records | Specify 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.
Default is |
Timeout | Specify 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 | ||
---|---|---|
|
...