Description

kafka_send in event_route like tcp:timeout, tcp:closed not work

event_route[tcp:closed] {
   if (kafka_send("my_topic", "tcp:closed")) {
       xlog("L_INFO", "send success tcp:closed");
   }
}
event_route[tcp:timeout] {
   if (kafka_send("my_topic", "tcp:timeout")) {
       xlog("L_INFO", "send success tcp:timeout");
   }
}

in log, its show "send success tcp:closed", "send success tcp:timeout",
but in kafka web ui, in the my_topic, can't find the "tcp:closed" or " tcp:timeout" message.

but if the kafka_send in onreply_route, message will be send ok, in the kafka web ui, the "some_route" can be find.

onreplay_route[some_route]{
   if (kafka_send("my_topic", "some_routet")) {
       xlog("L_INFO", "send success some_routet");
   }
}

Troubleshooting

Reproduction

Debugging Data

(paste your debugging data here)

Log Messages

(paste your log messages here)

SIP Traffic

i use tcpdump to capture the traffic between kamailio and kafka.

when use kafka_send in event_route, no packages captured.

Possible Solutions

Additional Information

Kamailio Version - output of kamailio -v

5.6.1

Operating System: centos7

(paste your output here)

—
Reply to this email directly, view it on GitHub, or unsubscribe.
You are receiving this because you are subscribed to this thread.

wangduanduan created an issue (kamailio/kamailio#4198)