Kafka Sub¶

The Kafka Sub node establishes a Kafka client that can subscribe up to 5 Kafka topics.

Node Type¶

Trigger.

Input and Output Ability¶

This node does not have an entry point and has 1 exit point. The output can be any format and is the message this client retrieves from the subscribed topic. The Kafka topic is automatically saved to the output metadata ${metadata.topic}.

Node Properties¶

Node Name

Required.

The name for this node.

Host

Required.

The host address or domain name.

Topic

Required.

The Kafka topic to subscribe to. The maximum number of topics you can subscribe to is 5.

User Name

Required.

The user name used for authentication.

Password

Required.

The password for the User Name for authentication.

Description

Optional.

The description for the node.

Test Connection

You can click the Test Connection button to test the Kafka connectivity.

Limitations¶

Number of connections: 1
Maximum number of topics: 5
As the Kafka server is not managed by EnOS, connection problems could occur due to server downtime or other instances that are not within our control.

Samples¶

Input Sample¶

This node does not have an entry point.

Output Sample¶

Example of a JSON object retrieved from the Kafka topic. Its topic information is stored in the metadata.

{
    "externalId":"externalId",
    "timestamp":24214324324,
    "measurepoints":{
        "speed":32,
        "heat":40
    }
}