newTopic

newTopic messages are sent when a new topic is created. This allows new topics to be almost immediatly detected, instead of waiting for the consumers to automatically refresh.

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

keydata typedescription
topicstringname of the new topic

JSON

Example

A new topic is created:

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

Producers

Any service that creates a new topic.

Consumers