Apache Kafka

Integration with LogicHub

Connecting with Apache Kafka

To connect to Apache Kafka following details are required:

  • Label: Connection name.
  • Reference Values: Define variables here to templatize integration connections and actions. For example, you can use https://www.{{hostname}}.com where, hostname is a variable defined in this input. For more information on how to add data, see 'Add Data' Input Type for Integrations.
  • Server Address: Server address for Apache Kafka.
  • Server port: Server port to connect to Apache Kafka.
  • Kafka API version: api_version for Apache Kafka. Some example : [(0, 10, 1), (0, 10, 0), (0, 10), (0, 9),
    (0, 8, 2), (0, 8, 1), (0, 8, 0)].
  • Username: Username to connect to Apache Kafka.
  • Password: Password to connect to Apache Kafka.

Actions with Apache Kafka

Publish Feed

Publish a feed(message) to the given topic in Apache Kafka.

Inputs to this Action

  • Connection: Choose a connection that you have created.
  • Topic column name: Column name from parent table that contains Topic.
  • Feed column name: Column name from parent table that contains Feed.

Output of Action
JSON containing following items:

  • has_error: True/False
  • error: message/null
  • result: Successfully published message

Get Feeds

Get feeds from the topic in Apache Kafka.

Inputs to this Action

  • Connection: Choose a connection that you have created.
  • Topic column name: Column name from parent table that contains Topic.
  • Maximum Rows: Limit of records to be fetched.

Output of Action
JSON containing following items:

  • has_error: True/False
  • error: message/null
  • result: feed

Did this page help you?