Record headers should be deserialized as STRING and not as a string representation of the contents of a byte array. - Githubissues

kestra-io / plugin-kafka

https://kestra.io/plugins/plugin-kafka/

Apache License 2.0

4 stars 5 forks source link

Record headers should be deserialized as STRING and not as a string representation of the contents of a byte array. #65

Closed fhussonnois closed 8 months ago

fhussonnois commented 8 months ago

Expected Behavior

Headers should be deserialized as STRING.

Actual Behaviour

Currently, headers are returned as a string representation of the contents of a byte array.

kestra-consume-task-header

Steps To Reproduce

No response

Environment Information

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

Example flow

id: kafka-consumer
namespace: dev
tasks:
  - id: consumer
    type: io.kestra.plugin.kafka.Consume
    topicPattern: kestra-.*
    properties:
      bootstrap.servers: localhost:9092
      group.id: kestra
      metadata.max.age.ms: 1000
    maxRecords: 10
    maxDuration: PT10S  
    keyDeserializer: STRING
    valueDeserializer: STRING