Module: kamailio Branch: master Commit: cc8bd051b411d5b375a318ae245a4363512cfdea URL: https://github.com/kamailio/kamailio/commit/cc8bd051b411d5b375a318ae245a4363512cfdea
Author: Daniel-Constantin Mierla <[email protected]> Committer: Daniel-Constantin Mierla <[email protected]> Date: 2025-12-17T13:03:14+01:00 kafka: init child for rank rpc - GH #4527 --- Modified: src/modules/kafka/kafka_mod.c --- Diff: https://github.com/kamailio/kamailio/commit/cc8bd051b411d5b375a318ae245a4363512cfdea.diff Patch: https://github.com/kamailio/kamailio/commit/cc8bd051b411d5b375a318ae245a4363512cfdea.patch --- diff --git a/src/modules/kafka/kafka_mod.c b/src/modules/kafka/kafka_mod.c index 3cb09482c3a..ee97fbd24bb 100644 --- a/src/modules/kafka/kafka_mod.c +++ b/src/modules/kafka/kafka_mod.c @@ -154,10 +154,13 @@ static int mod_init(void) static int child_init(int rank) { - /* call kfk_init() only for timer processes and routing processes */ + /* call kfk_init() only for rpc, timer and routing processes */ /* Note that only these processes will be able to send kafka messages */ - if(rank != PROC_TIMER && rank <= PROC_MAIN) - return 0; + if(rank != PROC_RPC) { + if(rank != PROC_TIMER && rank <= PROC_MAIN) { + return 0; + } + } child_init_ok = 1; if(kfk_init(brokers_param)) { _______________________________________________ Kamailio - Development Mailing List -- [email protected] To unsubscribe send an email to [email protected] Important: keep the mailing list in the recipients, do not reply only to the sender!
