newTopic

This is a system internal message and is likely not needed for your usage. When sending messages via MQTT, it will be automatically created by mqtt-kakfka-bridge.

Topic

Kafka: umh.v1.kafka.newTopic

Usage

Everytime a new topic is created, a message containing the name of that topic is sent here. The consumption of this message triggers the refresh of the metadata for all the other consumers, updating their subsrciption list with the newly created topic.

Every service connected with Kafka should subscribe to this topic by default.

Content

JSON

Example

A new topic is created:

{
  "topic": "ia/testCustomer/testLocation/testAsset/testTopic"
}

Producers

Any service that creates a new topic.

Consumers

• kafka-to-blob
• kafka-to-postgresql
• mqtt-kafka-bridge