Module: kamailio Branch: master Commit: 4a7c3af7095257fd2e32ce2e33d66346256abafb URL: https://github.com/kamailio/kamailio/commit/4a7c3af7095257fd2e32ce2e33d6634… Author: Kamailio Dev <kamailio.dev(a)kamailio.org> Committer: Kamailio Dev <kamailio.dev(a)kamailio.org> Date: 2020-05-20T14:16:17+02:00 modules: readme files regenerated - kafka ... [skip ci] --- Modified: src/modules/kafka/README --- Diff: https://github.com/kamailio/kamailio/commit/4a7c3af7095257fd2e32ce2e33d6634… Patch: https://github.com/kamailio/kamailio/commit/4a7c3af7095257fd2e32ce2e33d6634… --- diff --git a/src/modules/kafka/README b/src/modules/kafka/README index 315decd070..47452c21ff 100644 --- a/src/modules/kafka/README +++ b/src/modules/kafka/README @@ -35,6 +35,7 @@ Javier Gallart 2.4. Functions 2.4.1. kafka_send(topic, msg) + 2.4.2. kafka_send_key(topic, msg, key) 2.5. RPC Commands @@ -47,8 +48,9 @@ Javier Gallart 1.2. Set configuration parameter 1.3. Set topic parameter 1.4. kafka_send usage - 1.5. kafka.stats usage + 1.5. kafka_send_key usage 1.6. kafka.stats usage + 1.7. kafka.stats usage Chapter 1. Admin Guide @@ -68,6 +70,7 @@ Chapter 1. Admin Guide 2.4. Functions 2.4.1. kafka_send(topic, msg) + 2.4.2. kafka_send_key(topic, msg, key) 2.5. RPC Commands @@ -91,6 +94,7 @@ Chapter 1. Admin Guide 2.4. Functions 2.4.1. kafka_send(topic, msg) + 2.4.2. kafka_send_key(topic, msg, key) 2.5. RPC Commands @@ -206,13 +210,34 @@ modparam("kafka", "topic", "name=third_topic") kafka_send("my_topic", "test message"); ... +2.4.2. kafka_send_key(topic, msg, key) + + Send a message with an associated key to a specific topic via Kafka + server. + + This function returns -1 for all sort of errors. (So execution of + script continues) + + Parameters: + * topic: (string) name of the topic. It is mandatory. + * msg: (string) message to send. It is mandatory. + * key: (string) associate this key with the message. It is mandatory. + + Available via KEMI framework as kafka.send_key. + + Example 1.5. kafka_send_key usage +... +# Send "test message" to topic "my_topic" with key "my_key" +kafka_send_key("my_topic", "test message", "my_key"); +... + 2.5. RPC Commands 2.5.1. kafka.stats Show statistics about total sent messages and failed to deliver ones. - Example 1.5. kafka.stats usage + Example 1.6. kafka.stats usage ... kamcmd kafka.stats Total messages: 26 Errors: 0 @@ -225,7 +250,7 @@ Total messages: 26 Errors: 0 Parameter: topic (string) name of the topic. Required. - Example 1.6. kafka.stats usage + Example 1.7. kafka.stats usage ... # Show statistics for my_topic. kamcmd kafka.stats_topic "my_topic"