Topics

Topic definitions (in the configuration file topics.conf) can set the import and export properties to specify one or more transports:

Parameter Name Description
import

Import all Pulsar messages that arrive on the specified pulsar transports and deliver them to this EMS topic.

import is not supported for wildcard topics (see Wildcards).

export Take all messages that arrive on this EMS topic and export them to Pulsar topics using the specified pulsar transports.
Note: The EMS server never re-exports an imported message on the same topic. (For general information about topics.conf syntax and semantics, see topics.conf. You can also configure topics using the administration tool command addprop topic.)

Examples

Example 1

The following tibemsadmin commands perform the following:

  • Configure the EMS topic myTopics.news1 to import all messages that the transports PULSAR01 and PULSAR02 receive from their respective Pulsar brokers on the Pulsar topic myTopics.news1.
  • Configure the EMS topic myTopics.news2 to export messages to the transport PULSAR02. The transport will publish these messages to the Pulsar topic myTopics.news2.
addprop topic myTopics.news1 import="PULSAR01,PULSAR02" 
addprop topic myTopics.news2 export="PULSAR02"

Example 2

The following tibemsadmin commands perform the following:

  • Configure EMS topic myTopics.events1 to import messages that the transport PULSAR03 receives on the Pulsar topic myTopics.events1.
  • Configure EMS topic myTopics.events2 to import messages that the transport PULSAR03 receives on the Pulsar topic myTopics.events2.
addprop topic myTopics.events1 import="PULSAR03"
addprop topic myTopics.events2 import="PULSAR03"

Example 3

The following tibemsadmin commands perform the following:

  • Configure EMS topic myTopics.updates1 to export messages to the transport PULSAR04. The transport will publish these messages to the Pulsar topic myTopics.updates1.
  • Configure EMS topic myTopics.updates2 to export messages to the transport PULSAR04. The transport will publish these messages to the Pulsar topic myTopics.updates2.
addprop topic myTopics.updates1 export="PULSAR04"
addprop topic myTopics.updates2 export="PULSAR04"