@saniot/kafka-header-helper

Kafka Header

---

Introduction:

It create a header structure for kafka payload.

How to use:

1. kafkaHeader

const { kafkaHeader } = require("kafka_header");

Change in code

# Payload before header
let payload = [
        {
            key: kafkaKey,
            value: kafkaValue
        },
    ];

# Payload after adding header
let payload = [
        {
            key: kafkaKey,
            value: kafkaValue,
            header: { ...kafkaHeader("service_name") },
        },
    ];

2. addHeader

const { addHeader } = require("kafka_header");

Change in code

# Before
await kafkaProducer.send({
            topic: kafkaTopic,
            messages: payload,
        });

# After
await kafkaProducer.send({
            topic: kafkaTopic,
            messages: addHeader(payload, 'service_name'),
        });