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 Kafka messages that arrive on the specified kafka 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 Kafka topics using the specified kafka 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 KAFKA01 and KAFKA02 receive from their respective Kafka brokers on the Kafka topic myTopics.news1.
  • Configure the EMS topic myTopics.news2 to export messages to the transport KAFKA02. The transport will publish these messages to the Kafka topic myTopics.news2.
addprop topic myTopics.news1 import="KAFKA01,KAFKA02" 
addprop topic myTopics.news2 export="KAFKA02"

Example 2

The following tibemsadmin commands perform the following:

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

Example 3

The following tibemsadmin commands perform the following:

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