EventHub Produce from.body: "{{body}}" should be dynamic but it's not

[pavel-mxsf]

Expected Behavior

I'd like to call REST API and send result body to eventhub. Like this kafka blueprint: blueprint 151.

Actual Behaviour

It sends message to eventHub, but message body contains {{ outputs.api.body }} string instead of actual API response body.

Steps To Reproduce

See attached example (secrets and URLs redacted), log task shows what I expect in eventHub message.

Environment Information

• Kestra Version: 0.18.3
• Plugin version:
• Operating System (OS / Docker / Kubernetes): Kubernetes
• Java Version (If not docker):

Example flow

tasks:
  - id: api
    type: io.kestra.plugin.core.http.Request
    method: GET
    uri: http://xxx.com/xxx

  - id: logRequestDone
    type: io.kestra.plugin.core.log.Log
    message:
      - "{{ outputs.api.body }}"

  - id: testEventhub
    type: io.kestra.plugin.azure.eventhubs.Produce
    from:
      body: "{{ outputs.api.body }}"
    namespace: xxx
    eventHubName: xxx
    connectionString: "xxx"
    bodySerializer: JSON    
    bodyContentType: application/json
    eventProperties:
      source: kestra

[anna-geller]

can you try wrapping it in fromJson()?

id: repro
namespace: test
tasks:
  - id: api
    type: io.kestra.plugin.core.http.Request
    method: GET
    uri: https://reqres.in/api/repro

  - id: testEventhub
    type: io.kestra.plugin.azure.eventhubs.Produce
    disabled: true
    from:
      body: "{{ fromJson(outputs.api.body) }}"
    namespace: xxx
    eventHubName: xxx
    connectionString: "xxx"
    bodySerializer: JSON    
    bodyContentType: application/json
    eventProperties:
      source: kestra

[pavel-mxsf]

can you try wrapping it in fromJson()?

It doesn't do anything with that string, just sends "{{ fromJson(outputs.api.body) }}" to EH.