Attribute | Description | Kafka Property | Allowed Values / Examples |
---|
Name (name) | Specify a name for the alias. | - | any string |
Standard |
---|
Servers | Provide a list of Kafka brokers with (optional) ports. | bootstrap.servers | kafka1.acme.com , kafka2.acme.com:9092 |
Enable Idempotence
| Enables the producer to write a message to Kafka exactly once. | enable.idempotence | true | Write message exactly once to the specified partition of the topic during the lifetime of the producer - without data loss and order per partition (default). |
false | Message may be delivered multiple times on e.g. connection failures. |
Compression
|
---|
Compression Type
| Provide a compression codec for compressing message sets. | compression.type | none | No compression (default). |
gzip | Compress with gzip. |
Security
|
---|
Protocol Security
| Provide the protocol used to communicate with the Kafka brokers. | security.protocol | plaintext | Use plain text (default). |
ssl | Use SSL. |
Ssl Private Key File | Provide the path to the client's private key file (PEM) to be used for authentication. | ssl.key.location | a valid path |
Ssl Private Key Password | Provide the password for the private key file. | ssl.key.password | a valid password |
Ssl Private Key String | Provide the client's private key string (PEM format) to be used for authentication. | ssl.key.pem | a valid key string |
Ssl Client Certificate File | Provide the path to the client's public key file (PEM) to be used for authentication. | ssl.certificate.location | a valid path |
Ssl Client Certificate String | Provide the client's public key string (PEM format) to be used for authentication. | ssl.certificate.pem | a valid key string |
Ssl CA Location | Specify how to find CA certificate(s) for verifying the key of the Kafka broker. | ssl.ca.location | <path> | File or directory path to the CA certificate(s). |
probe | Guess the location of the CA store and try to find the CA certificate(s) automatically. |
bundled | Use the CA bundle provided with PAS. |
Ssl CA String | Provide the CA certificate string (PEM format) to verify the key of the Kafka broker. | ssl.ca.pem | a valid CA certificate string |
Advanced
|
---|
Additional Properties | Use this to directly set properties of the Kafka producer.
Info |
---|
Using this attribute, you can also overwrite the dedicated settings above. In this case, - the Compiler will show a warning,
- the service will log a warning on startup.
|
|
| buffer.memory=67108864 , retries=4294967294 |