Configuration Properties for the Kafka Clients
The following table lists all configuration properties for the Kafka clients (see also http://kafka.apache.org/documentation/#consumerconfigs):
Property | Description | Value |
---|---|---|
clientId | This ID identifies your program in Kafka. It has only naming purposes. | You can set the value as required. We recommend using some meaningful naming that identifies the purpose of the consumer so we can troubleshoot problems you may experience as developer easily. Do not use any personally identifiable information (PII) nor anything that would leak sensitive information about your infrastructure. |
groupId | This is the Kafka Consumer Group, in which your application is part. | Mapp provides you with the value. |
endpoints | The Kafka endpoint where you must consume the data from. | Mapp provides you with the value. |
topic | The Kafka Topic from which your application is consuming data. | Mapp provides you with the value. |
autoOffsetResetPolicy | Policy adopted by the consumer if there is no offset (point in Kafka time) to consume. | Possible values:
|
securityProtocol | The security protocol enforced when connecting to our Kafka. | SASL_SSL |
securitySaslMechanism | The SASL mechanism used for performing the authentication. | SCRAM-SHA-256 |
schemaRegistryUrl | The URL to the Mapp schema registry. | Mapp provides you with the value. |
keyDeserializer/ keySerde | The class that the Kafka Plain Consumer/ Kafka Streams Application will use to deserialize the record key. |
|
valueDeserializer/ valueSerde | The class that the Kafka Plain Consumer / Kafka Streams Application will use to deserialize the record value. |
|
valueSubjectNameStrategy | The class that the consumer will use to figure out where to get name of the AVRO Schema from. |
|
streamsNumOfThreads | The number of threads your Kafka Stream will use for processing. | The recommended value is at least 3. |