Kafka Broker Bridge Settings

Kafka Bridge Subscriptions Specification Format Extensions
Action Object
Property
Required
Type
Description
Examples
id
true
string
A unique identifier for this specification
subscribers_1
meta
false
object
An arbitrary object containing user metadata. Bondy treats it as an opaque object.
{"foo" : "bar"}
subscriptions
true
​
​
​
The following snippet provides an example subscriptions using the defined Action Object.
/bondy/etc/subscriptions.json
{
    "id":"subscribers_1",
    "meta":{},
    "subscriptions" : [
        {
            "bridge": "bondy_kafka_bridge",
            "match": {
                "realm": "com.example.realm",
                "topic" : "com.example.user.created",
                "options": {"match": "exact"}
            },
            "action": {
                "type": "produce_sync",
                "topic": "{{kafka.topics |> get(com.magenta.wamp_events)}}",
                "key": "\"{{event.topic}}/{{event.publication_id}}\"",
                "value": "{{event}}",
                "options" : {
                    "client_id": "default",
                    "acknowledge": true,
                    "required_acks": "all",
                    "partition": null,
                    "partitioner": {
                        "algorithm": "fnv32a",
                        "value": "\"{{event.topic}}/{{event.publication_id}}\""
                    },
                    "encoding": "json"
                }
            }
        }
    ]
}
​

Configuring - Previous

Broker Bridge Settings

Next - Using

Introduction to WAMP

Last updated 7 months ago

Property	Required	Type	Description	Examples
id	true	string	A unique identifier for this specification	subscribers_1
meta	false	object	An arbitrary object containing user metadata. Bondy treats it as an opaque object.	{"foo" : "bar"}
subscriptions	true