fs-doc

import { Kafka, Producer, Partitioners } from 'kafkajs';

export class KafkaProducer{
    
    private kafka: Kafka;
    private producer: Producer;
    private brokers: string[];
    private crashes: number;
    private maxCrashes: number;

fs-doc

import {KafkaConsumer} from "./kafkaConsumer";
import jwt from 'jsonwebtoken';

export class ServiceConsumer{

    private kafkaConsumer: KafkaConsumer;

    constructor(){

        //Create the Kafka consumer instance and subscribe to the topics

fs-doc

import {
    Kafka,
    Consumer,
    MessageSetEntry,
    RecordBatchEntry,
    ConsumerSubscribeTopics,
    ITopicConfig
} from 'kafkajs';
import { v4 as uuidv4 } from 'uuid';

fs-doc

/*
* Basic Commit Notepad
*/
// $ node committer.js [branch]

const { exec } = require("child_process");

const branch = process.argv[2] ? process.argv[2] : 'master'; //Master by default
const now = new Date();
const date = `${now.getDate()}.${now.getMonth() + 1}.${now.getFullYear()}`;

fs-doc

  helm repo add external-secrets https://charts.external-secrets.io