Search code examples
apache-kafkakafkajs

how to scale producers in kafkajs application using Apache Kafka and Nodejs


I am building a central notification Engine for all micro services. I am using KafkaJs library. To scale consumer we can create multiple consumers. How do i scale producers in kafkajs? Can i create multiple producers in KafkaJs library?


Solution

  • A producer is typically a single variable within any app and reused across functions

    To scale producers you'd deploy multiple processes of the same producer app