Broker Bridge Configuration

General Configuration

Key

Acceptable Values

Default

broker_bridge.config_file

The configuration filename for the Broker Bridge. Read the Broker Bridge Settings section on the specification file format.

path to a file

$(platform_etc_dir)/ broker_bridge_config.json

Kafka Bridge Configuration

The following shows an example configuration for a Kafka bridge.

bondy.conf
broker_bridge.config_file = $(platform_etc_dir)/broker_bridge_config.json
broker_bridge.kafka.enabled = on
broker_bridge.kafka.clients.default.allow_topic_auto_creation = off
broker_bridge.kafka.clients.default.auto_start_producers = on
broker_bridge.kafka.clients.default.endpoints = [{"127.0.0.1", 9092}]
broker_bridge.kafka.clients.default.max_metadata_sock_retry = 5
broker_bridge.kafka.clients.default.producer.partition_restart_delay_seconds = 2s
broker_bridge.kafka.clients.default.producer.required_acks = 1
broker_bridge.kafka.clients.default.producer.topic_restart_delay_seconds = 10s
broker_bridge.kafka.clients.default.reconnect_cool_down_seconds = 10s
broker_bridge.kafka.clients.default.restart_delay_seconds = 10s
broker_bridge.kafka.topics.account_events = ${MAGENTA_ACCOUNT_EVENTS_TOPIC}
broker_bridge.kafka.topics.user_events = ${MAGENTA_USER_EVENTS_TOPIC}

Key

Acceptable Values

Default

broker_bridge.kafka.enabled

on | off

off

broker_bridge.kafka.topics.$name

A mapping of Clients to Kafka topics. This mapping is used by the JSON broker_bridge.config_file which defines the subscribers for each bridge.

a list of erlang tuples

[{"127.0.0.1", 9092}]

broker_bridge.kafka.clients.$name.endpoints

list of

broker_bridge.kafka.clients.$name.restart_delay_seconds

How long to wait between attempts to restart the Kafka

client process when it crashes.

a time duration with units, e.g. '10s' for 10 seconds

10s

broker_bridge.kafka.clients.$name.max_metadata_sock_retry

integer

5

broker_bridge.kafka.clients.$name.reconnect_cool_down_seconds

Delay this configured number of seconds before retrying to

estabilish a new connection to the kafka partition leader.

a time duration with units, e.g. '10s' for 10 seconds

10s

broker_bridge.kafka.clients.$name.allow_topic_auto_creation

By default, the Kafka client respects what is configured in the broker

about topic auto-creation. i.e. whether `auto.create.topics.enable' is set in the broker configuration. However if this parameter is set to false, the client will avoid sending metadata requests that

may cause an auto-creation of the topic regardless of what

the broker config is.

on | off

on

broker_bridge.kafka.clients.$name.producer.topic_restart_delay_seconds

a time duration with units, e.g. '10s' for 10 seconds

10s

broker_bridge.kafka.clients.$name.producer.partition_restart_delay_seconds

a time duration with units, e.g. '10s' for 10 seconds

10s

broker_bridge.kafka.clients.$name.producer.required_acks

How many acknowledgements the Kafka broker should receive

from the clustered replicas before acknowledging producer. 0: the broker will not send any response (this is the only case

where the broker will not reply to a request) 1: The leader will wait the data is written to the local log

before sending a response. -1: If it is -1 the broker will block until the message is

committed by all in sync replicas before acknowledging.

integer

1

broker_bridge.kafka.clients.$name.socket.sndbuf

bytesize

broker_bridge.kafka.clients.$name.socket.recbuf

bytesize