Skip to content

Kafka Integration

Some Prici feature are asynchronous and can be available via a Kafka broker to work.

Available environment variables

NameDescriptionRequired?Default value
KAFKA_URLKafka broker URL (multiple URLs can be split with comma)Yes-
KAFKA_CLIENT_IDKafka client IDNo'prici-api'
KAFKA_GROUP_IDKafka group IDNo'prici-api'
KAFKA_SASL_MECHANISMSASL mechanismNo'plain'
KAFKA_USERNAMESASL usernameNo-
KAFKA_PASSWORDSASL passwordNo-
KAFKA_CERT_PATHPath to the certificate folder (must inclde files: ca.crt, client-key.pem, client-cert.pem)No'kafka-cert'
KAFKA_SSLEnable SSL (insert "true" as string to enable)No'false'
KAFKA_TOPIC_INCOMINGIncoming topic nameNo'prici-incoming'
KAFKA_TOPIC_OUTGOINGOutgoing topic nameNo'prici-outgoing'
KAFKA_TOPIC_INCOMING_REPLYIncoming reply topic nameNo'prici-incoming-reply'
KAFKA_TOPIC_INCOMING_DEAD_LETTERIncoming dead letter topic nameNo-