Configuring
Contributing
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
1
{
2
"id":"subscribers_1",
3
"meta":{},
4
"subscriptions" : [
5
{
6
"bridge": "bondy_kafka_bridge",
7
"match": {
8
"realm": "com.example.realm",
9
"topic" : "com.example.user.created",
10
"options": {"match": "exact"}
11
},
12
"action": {
13
"type": "produce_sync",
14
"topic": "{{kafka.topics |> get(com.magenta.wamp_events)}}",
15
"key": "\"{{event.topic}}/{{event.publication_id}}\"",
16
"value": "{{event}}",
17
"options" : {
18
"client_id": "default",
19
"acknowledge": true,
20
"required_acks": "all",
21
"partition": null,
22
"partitioner": {
23
"algorithm": "fnv32a",
24
"value": "\"{{event.topic}}/{{event.publication_id}}\""
25
},
26
"encoding": "json"
27
}
28
}
29
}
30
]
31
}
32
Copied!
Last modified 2yr ago