feat(plugin): create Kafka plugin

[orandin]

• What kind of change does this PR introduce? (Bug fix, feature, docs update, ...)

Feature : add a Kafka plugin to produce messages (see #3)

• What is the current behavior? (You can also link to an open issue here)

uTask can't publish directly a message to a Kafka topic.

• What is the new behavior (if this is a feature change)?

Now, uTask can do it. A task can publish a message to a Kafka topic via this plugin.

• Does this PR introduce a breaking change? (What changes might users need to make in their application due to this PR?)

Nothing.

• Other information:
  Closes Action plugin: Kafka producer #3

Template used to test the plugin (click me)

Required: a kafka broker that listens on localhost:9092. How to Install Apache Kafka Using Docker — The Easy Way

name:             kafka
description:      Send message into kafka topic
long_description: Send message into kafka topic

title_format:     Send Kafka message
result_format:
  echo_message: 'ok'

allowed_resolver_usernames:   []
allow_all_resolver_usernames: true
auto_runnable: true
blocked:       false
hidden:        false

steps:
  sendKafka:
    description: Send message into kafka topic
    action:
      type: kafka
      configuration:
        brokers:
          - localhost:9092
        timeout: 20s
        message:
          topic: "utask"
          key: 'test'
          value: |
              {
                "message": "hello world"
              }

Result (click me)

Consumer

$ kaf consume utask
Key:         test
Partition:   0
Offset:      11
Timestamp:   2022-10-05 16:47:07.267 +0200 CEST
{
  "message": "hello world"
}

kaf is a CLI for Apache Kafka: https://github.com/birdayz/kaf

Step output

{
  "name": "sendKafka",
  "description": "Send message into kafka topic",
  "idempotent": false,
  "action": {
    "type": "kafka",
    "configuration": {
      "brokers": [
        "localhost:9092"
      ],
      "message": {
        "key": "test",
        "topic": "utask",
        "value": "{\n  \"message\": \"hello world\"\n}\n"
      }
    },
    "output": null
  },
  "output": {
    "offset": 11,
    "partition": 0
  },
  "state": "DONE",
  "try_count": 1,
  "max_retries": 10000,
  "last_run": "2022-10-05T16:47:07.279139+02:00",
  "foreach_strategy": "",
  "resources": null,
  "tags": null
}

[rbeuque74]

Thanks for your contribution.
Will run the CI on monday

[orandin]

Update: conflict resolved

[orandin]

Don't merge before squashing commits