Send message to Kafka

This activity provides your flogo application the ability to send a message to an Apache Kafka broker. Code is based on the Kafka activity created by Kai Waehner

Installation

flogo install github.com/jvanderl/flogo-components/activity/kafka

Link for flogo web:

https://github.com/jvanderl/flogo-components/activity/kafka

Schema

Inputs and Outputs:

{
    "input":[
    {
      "name": "server",
      "type": "string"
    },
    {
      "name": "configid",
      "type": "string"
    },
    {
      "name": "topic",
      "type": "string"
    },
    {
      "name": "partition",
      "type": "int"
    },
    {
      "name": "message",
      "type": "string"
    }
  ],
  "output": [
    {
      "name": "result",
      "type": "string"
    }
  ]
}

Settings

Configuration Examples

Simple

Configure a task in flow to send 'hello from flogo' to kafka topic 'test', partition 0:

{
  "id": 3,
  "type": 1,
  "activityType": "kafka",
  "name": "Send Message",
  "attributes": [
    { "name": "server", "value": "192.168.178.41:2181" },
    { "name": "configid", "value": "flogo-test" },
    { "name": "topic", "value": "test" },
    { "name": "partition", "value": "0" },
    { "name": "message", "value": "hello from flogo" },
  ]
}

Contributors

Kai Waehner Jan van der Lugt