Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

Sign up
Appearance settings

Headers (outbound and inbound) do not comply with KafkaJS type definitions for eachBatch consumers #129

Closed
Assignees
Labels
bugSomething isn't working fixed-present-in-next-releaseBug or improvement that's done, it is in the development branch but yet unreleased
@EricMCornelius

Description

os: ubuntu 24.04 ARM
node_version: 22.9.0
npm_version: 10.9.0
confluent-kafka-javascript version: v0.2.1

Steps to Reproduce

Any kafkajs consumer using an eachBatch configuration has invalid headers structure. Console logging from a basic setup when sending headers yields:

{
 key: null,
 value: <Buffer 7b 22 74 79 70 65 22 3a 22 74 65 73 74 5f 65 76 65 6e 74 22 2c 22 65 76 65 6e 74 22 3a 7b 22 6d 65 73 73 61 67 65 22 3a 22 65 76 65 6e 74 20 23 31 34 ... 271 more bytes>,
 timestamp: '1729305041677',
 attributes: 0,
 offset: '1785544',
 size: 321,
 leaderEpoch: 20,
 headers: {
 '0': {
 org: <Buffer 37 33 38 30 33 35 64 63 2d 30 34 34 38 2d 35 66 38 64 2d 61 66 30 33 2d 35 30 30 32 36 61 61 30 38 36 36 62>
 }
 }
}

Additional context
This was fixed for eachMessage but not for eachBatch.

Metadata

Metadata

Assignees

Labels

bugSomething isn't working fixed-present-in-next-releaseBug or improvement that's done, it is in the development branch but yet unreleased

Type

No type

Projects

No projects

Milestone

No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions

      AltStyle によって変換されたページ (->オリジナル) /