Configuration Properties for the Kafka Clients (Python)

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_SSL

sasl.mechanism

The SASL mechanism used for performing the authentication.

SCRAM-SHA-256

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.