The following table lists all configuration properties for the Kafka clients using Python.
Property | Description | Value |
|---|---|---|
bootstrap.servers | The Kafka endpoint where you must consume the data from. | Mapp provides you with the value. |
offset.reset | Policy adopted by the Consumer where there is no offset (point in Kafka time) where to consume from. | Recommended value is earliest so your consumer will not miss any data (but it is more likely that you will process items more than once). If you set it to latest, your consumer will start consuming the most up to date data on the stream (however you may ignore some data that was already there). |
group.id | This will be the Kafka Consumer Group your application will be part of. | Mapp provides you with the value. |
security.protocol | The security protocol enforced when connecting to our Kafka. |
|
sasl.mechanism | The SASL mechanism used for performing the authentication. |
|
sasl.username | The user name used to perform the authentication. | Mapp provides you with the value. |
sasl.password | The password used to perform the authentication. | Mapp provides you with the value. |
error_cb | The callback function that will get invoked in case there is an error consuming from the topic. |