Headers (outbound and inbound) do not comply with KafkaJS type definitions #45
Labels
bug
Something isn't working
fixed-present-in-next-release
Bug or improvement that's done, it is in the development branch but yet unreleased
The header implementation for both producers and consumers does not comply with the type definitions offered up in kafkajs.d.ts (which are unmodified from the KafkaJS originals).
Below is a comparison between KafkaJS and Confluent.
KafkaJS
Confluent
Two (maybe three) notable issues:
header1=alpha
andheader2=beta
were sent to Kafka askey=header1
andkey=header2
key=header1
andkey=header2
, KafkaJS compatibility would dictate a string key of"key"
and a string[] value of["header1","header2"]
The text was updated successfully, but these errors were encountered: