Kafka

Table of Contents

• Context
  • groupId
  • key
  • cert
  • ca
  • topic
  • brokers
• Actions
  • Send Message(s)
  • Create Topic
• Events
  • Message Received

Contexts

groupId

key

cert

ca

topic

brokers

Actions

Send Message(s)

This action publishes one or more messages in the specified topic with the key and content provided.

Inputs

{
  "topic": "mytopic", /*The name of the topic(required)*/
  "messages": [ /*(required)*/
    {
      "key": "string",
      "value": "string",
    }
  ]
}

Outputs

Http Code 200

"No content"

Http Code 500

{
    "message": "string"
}

Create Topic

This action creates a new Kafka topic with the specified name, the desired number of partitions and the replication factor.

Inputs

{
  "name": "mytopic", /*The name of the topic to create(required)*/
  "partitions": 3, /*The number of partitions(required)*/
  "replicationFactor": 3, /*The number of replications(required)*/
}

Outputs

Http Code 200

"No content"

Http Code 500

{
    "message": "string"
}

Events

Message Received

This event is triggered by messages from the specified topic.

Payload

{
  "message": {
    "key": "string",
    "value": "string",
    "offset": "string",
    "timestamp": "number",
  }
}