marcinkowalczyk created an issue (kamailio/kamailio#4527)
### Description
I've noticed that when async UDP workers are enabled, kafka module fails to
send message:
```
udp_receiver_mode=1
async_workers_group="name=udp;workers=2"
loadmodule "kafka.so"
modparam("kafka", "brokers", "PLAINTEXT://kafka.kafka.svc:9092")
modparam("kafka", "topic", "name=ENV_NAME-kamailio-events")
modparam("kafka", "init_without_kafka", 1)
modparam("kafka", "log_without_overflow", 1)
request_route {
kafka_send("ENV_NAME-kamailio-events", "test");
}
```
ends with ` kafka module is unusable: no kafka object! Skip sending message,
message lost! `
```
{ "kamailio.time": "2025-12-16T10:54:58.992283140Z", "kamailio.idx": 7,
"kamailio.pid": 15, "kamailio.level": "ERROR", "kamailio.module": "kafka",
"kamailio.file": "kfk.c", "kamailio.line": 883, "kamailio.function":
"kfk_message_send", "kamailio.callid": "[email protected]",
"kamailio.logprefix": {"pod":"feat-kamailio-events-registrar-6d9dccb674-hscpr",
"ip":"10.25.90.198", "route":"DEFAULT_ROUTE:/etc/kamailio/kamailio.cfg:271",
"method":"KDMQ"}, "kamailio.message": { "text": "kafka module is unusable: no
kafka object! Skip sending message, message lost!" } }
```
### Troubleshooting
kafka is connected to broker, switch back
```
#udp_receiver_mode=1
#async_workers_group="name=udp;workers=2"
```
connects to broker, sends messages:
```
{ "kamailio.time": "2025-12-16T10:59:28.465896954Z", "kamailio.idx": 6,
"kamailio.pid": 14, "kamailio.level": "NOTICE", "kamailio.module": "kafka",
"kamailio.file": "kfk.c", "kamailio.line": 231, "kamailio.function":
"ic_broker_state_change", "kamailio.callid": "", "kamailio.logprefix": {
"text": "" }, "kamailio.message": { "text": "Connected broker: id: 0, proto:
plaintext, name:
kafka-controller-0.kafka-controller-headless.kafka.svc.cluster.local, port:
9092" } }
{ "kamailio.time": "2025-12-16T10:59:43.465966595Z", "kamailio.idx": 5,
"kamailio.pid": 13, "kamailio.level": "NOTICE", "kamailio.module": "kafka",
"kamailio.file": "kfk.c", "kamailio.line": 231, "kamailio.function":
"ic_broker_state_change", "kamailio.callid": "", "kamailio.logprefix": {
"text": "" }, "kamailio.message": { "text": "Connected broker: id: 0, proto:
plaintext, name:
kafka-controller-0.kafka-controller-headless.kafka.svc.cluster.local, port:
9092" } }
```
#### Reproduction
```
udp_receiver_mode=1
async_workers_group="name=udp;workers=2"
```
#### Log Messages
```
{ "kamailio.time": "2025-12-16T10:03:25.153752960Z", "kamailio.idx": 6,
"kamailio.pid": 14, "kamailio.level": "ERROR", "kamailio.module": "kafka",
"kamailio.file": "kafka_mod.c", "kamailio.line": 231, "kamailio.function":
"w_kafka_send", "kamailio.callid": "138s9pk0i28pgqn0hd5g",
"kamailio.logprefix": {"pod":"feat-kamailio-events-registrar-56646bbf74-fdkz7",
"ip":"10.25.82.199", "route":"dialog:end:/etc/kamailio/kamailio.cfg:1005",
"method":"BYE"}, "kamailio.message": { "text": "Cannot send kafka (topic:
feat-kamailio-events-kamailio-events) message:
{\"schemaVersion\":1,\"type\":\"dialog:end\",\"timestampMs\":\"1765879405153641\",\"metadata\":\"eyJtZXRhZGF0YSI6W3sidGVuYW50IjoiaXl5bWJxYyIsImNhbGxJZCI6NiwiZGVzY3JpcHRpb24iOiJPdXRib3VuZCBtZXRhZGF0YSIsIm9yaWdpbmF0aW5nVGVuYW50Ijp0cnVlfV19\",\"endCause\":\"BYE\"}"
} }
```
#### SIP Traffic
### Possible Solutions
### Additional Information
* **Kamailio Version** - output of `kamailio -v`
```
version: kamailio 6.0.4 (x86_64/linux)
flags: USE_TCP, USE_TLS, USE_SCTP, TLS_HOOKS, USE_RAW_SOCKS, DISABLE_NAGLE,
USE_MCAST, DNS_IP_HACK, SHM_MMAP, PKG_MALLOC, MEM_JOIN_FREE, Q_MALLOC,
F_MALLOC, TLSF_MALLOC, DBG_SR_MEMORY, USE_FUTEX, FAST_LOCK-ADAPTIVE_WAIT,
USE_DNS_CACHE, USE_DNS_FAILOVER, USE_NAPTR, USE_DST_BLOCKLIST, HAVE_RESOLV_RES,
TLS_PTHREAD_MUTEX_SHARED
ADAPTIVE_WAIT_LOOPS 1024, MAX_RECV_BUFFER_SIZE 262144, MAX_SEND_BUFFER_SIZE
262144, MAX_URI_SIZE 1024, BUF_SIZE 65535, DEFAULT PKG_SIZE 8MB
poll method support: poll, epoll_lt, epoll_et, sigio_rt, select.
id: unknown
compiled with gcc 12.2.0
```
* **Operating System**:
```
FROM ghcr.io/kamailio/kamailio:6.0.4-bookworm
```
--
Reply to this email directly or view it on GitHub:
https://github.com/kamailio/kamailio/issues/4527
You are receiving this because you are subscribed to this thread.
Message ID: <kamailio/kamailio/issues/[email protected]>_______________________________________________
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!
