Kafka Sub


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

Node Type

Input.

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

../../_images/kafka_sub.png


Name

The name for this node.


Host

The host address or domain name.


Topic

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


Authentication Method

The authentication method, Anonymous or Username/Password.

  • Anonymous: Does not need any authentication.

  • Username/Password: Enter the Username and Password used for authentication.


Description

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 receive any input message.

Output Sample

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

{
    "MetaData":{
        "topic":"topic1",
        "topic":"topic2"
    },
    "Body":{
        "externalId":"externalId",
        "timestamp":24214324324,
        "measurepoints":{
            "speed":32,
            "heat":40
        }
    }
}