Transport-specific Parameters

pulsar transports

If type = pulsar, the extended syntax is: 

url = pulsar://hostname:port

See Apache Pulsar Parameters for more information.

kafka transports

If type = kafka, the extended syntax is: 

brokers = hostname1:port1, …, hostnameN:portN
[schema_repository = ftl-server-url-list]

See Apache Kafka Parameters for more information.

tibftl transports

If type = tibftl, the extended syntax is: 

[endpoint = endpoint-name]
[import_subscriber_name = subscriber-name]
[import_match_string = {"fieldname1":value1,...,"fieldnameN":valueN}]
[export_format = format-name]
[export_constant = constant1,value1]
...
[export_constant = constantN,valueN]

See TIBCO FTL Parameters for descriptions.

tibrv transports

If type = tibrv, the extended syntax is:

[service = service]
[network = network]
[daemon = daemon]
[temp_destination_timeout = seconds]
[rv_queue_policy = [TIBRVQUEUE_DISCARD_NONE |
                   TIBRVQUEUE_DISCARD_FIRST |
                   TIBRVQUEUE_DISCARD_LAST]:max_msgs:qty_discard]

See Rendezvous Parameters for descriptions.

tibrvcm transports

If type = tibrvcm, the extended syntax is:

rv_tport = name # mandatory
[cm_name = name]
[ledger_file = file-name]
[sync_ledger = true | false]
[request_old = true | false]
[explicit_config_only = true | false]
[default_ttl = seconds]
[rv_queue_policy = [TIBRVQUEUE_DISCARD_NONE |
                   TIBRVQUEUE_DISCARD_FIRST |
                   TIBRVQUEUE_DISCARD_LAST]:max_msgs:qty_discard]

See Rendezvous Certified Messaging (RVCM) Parameters for descriptions.

Example 

[KAFKA01]
  brokers = host1:9092,host2:9092,host3:9092
  schema_repository = http://host1:8585,http://host2:8585,http://host3:8585

[PULSAR01]
  type = pulsar
  url = pulsar://host1:6650
				
[FTL01]
  type = tibftl
  endpoint = EP1
  import_subscriber_name = sub1
  import_match_string = {"f1":"foo","f2":true}
  export_format = format-1
  export_constant = constant1,value1
  export_constant = constant2,value2
  export_constant = constant3,value3

[RV01]
  type = tibrv
  topic_import_dm = TIBEMS_RELIABLE
  queue_import_dm = TIBEMS_PERSISTENT
  service = 7780 
  network = lan0
  daemon = tcp:host5:7885

[RVCM01]
  type = tibrvcm
  export_headers = true
  export_properties = true
  rv_tport = RV02
  cm_name = RVCMTrans1
  ledger_file = ledgerFile.store
  sync_ledger = true
  request_old = true
  default_ttl = 600

[RV02]
  type = tibrv
  topic_import_dm = TIBEMS_PERSISTENT
  queue_import_dm = TIBEMS_PERSISTENT
  service = 7780
  network = lan0
  daemon = tcp:host5:7885
  rv_queue_policy = TIBRVQUEUE_DISCARD_LAST:10000:100