Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More

@amplication/plugin-broker-kafka

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@amplication/plugin-broker-kafka

Use a Kafka message broker to communicate between services generated with Amplication

  • 2.0.13
  • latest
  • npm
  • Socket score

Version published
Weekly downloads
90K
decreased by-29.92%
Maintainers
0
Weekly downloads
 
Created

@amplication/plugin-broker-kafka

NPM Downloads

Implement Kafka as the message broker in your Amplication's generated services.

Purpose

This plugin generates the relevant code to provide you with end-to-end integration for a Kafka message broker.

It generates the following parts:

  • A topics list as a selectable enum.

  • Kafka module and service that contains an emit function to send messages to a Kafka queue.

  • Kafka controller with an endpoint listener for each topic connected to the service, and their type is “receive."

  • A Kafka options getter function that extracts all the relevant variables from the nestjs common ConfigService (by default if would load the available environment variables)

Usage

This plugin provides you with a ready configured NestJS module that you can use in your service. To customize the client options update the .env file with the relevant options.

FAQs

Package last updated on 16 Jul 2024

Did you know?

Socket

Socket for GitHub automatically highlights issues in each pull request and monitors the health of all your open source dependencies. Discover the contents of your packages and block harmful activity before you install or update your dependencies.

Install

Related posts