Socket
Socket
Sign inDemoInstall

@amplication/plugin-broker-kafka

Package Overview
Dependencies
7
Maintainers
8
Versions
62
Alerts
File Explorer

Advanced tools

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


Version published
Weekly downloads
107K
decreased by-14.49%
Maintainers
8
Created
Weekly downloads
 

Readme

Source

@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

Last updated on 14 Mar 2024

Did you know?

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

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc