kafkapub

README

---

title: Publish Kafka Message weight: 4613

Publish Kafka Message

This activity allows you to send a Kafka message

Installation

Flogo Web

This activity comes out of the box with the Flogo Web UI

Flogo CLI

flogo install github.com/TIBCOSoftware/flogo-contrib/activity/kafkapub

Schema

Inputs and Outputs:

{
  "input":[
    {
      "name": "BrokerUrls",
      "type": "string",
      "required": true
    },
    {
      "name": "Topic",
      "type": "string",
      "required": true
    },
    {
      "name": "Message",
      "type": "string",
      "required": true
    },
    {
      "name": "user",
      "type": "string",
      "required": false
    },
    {
      "name": "password",
      "type": "string",
      "required": false
    },
    {
      "name": "truststore",
      "type": "string",
      "required": false
    }
  ],
  "output": [
    {
      "name": "partition",
      "type": "int"
    },
    {
      "name": "offset",
      "type": "long"
    }
  ]
}

Settings

Setting	Required	Description
BrokerUrls	True	The Kafka cluster to connect to
Token	True	The Kafka topic on which to place the message
Message	True	The text message to send
user	False	If connectiong to a SASL enabled port, the userid to use for authentication
password	False	If connectiong to a SASL enabled port, the password to use for authentication
truststore	False	If connectiong to a TLS secured port, the directory containing the certificates representing the trust chain for the connection. This is usually just the CACert used to sign the server's certificate
partition	False	Documents the partition that the message was placed on
offset	False	Documents the offset for the message

Examples

The below example sends a message to the 'syslog' topic.

{
  "id": "kafkapub_1",
  "name": "Publish Kafka message",
  "description": "Publish a message to a kafka topic",
  "activity": {
    "ref": "github.com/TIBCOSoftware/flogo-contrib/activity/kafkapub",
    "input": {
      "BrokerUrls": "bilbo:9092",
      "Topic": "syslog",
      "Message": "mary had a little lamb"
    }
  }
}

Documentation

Index

• func NewActivity(metadata *activity.Metadata) activity.Activity
• type KafkaParms
• type KafkaPubActivity
  • func (a *KafkaPubActivity) Eval(context activity.Context) (done bool, err error)
  • func (a *KafkaPubActivity) Metadata() *activity.Metadata

Functions

func NewActivity

func NewActivity(metadata *activity.Metadata) activity.Activity

NewActivity creates a new activity

Types

type KafkaParms

type KafkaParms struct {
	// contains filtered or unexported fields
}

type KafkaPubActivity

type KafkaPubActivity struct {
	sync.Mutex
	// contains filtered or unexported fields
}

MyActivity is a stub for your Activity implementation

func (*KafkaPubActivity) Eval

func (a *KafkaPubActivity) Eval(context activity.Context) (done bool, err error)

Eval implements activity.Activity.Eval

func (*KafkaPubActivity) Metadata

func (a *KafkaPubActivity) Metadata() *activity.Metadata

Metadata implements activity.Activity.Metadata