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

@bluexlab/kafka-ts

Package Overview
Dependencies
Maintainers
0
Versions
4
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@bluexlab/kafka-ts - npm Package Compare versions

Comparing version 1.0.3 to 1.0.4

5

dist/index.d.ts

@@ -0,1 +1,2 @@

import { Logger } from 'pino';
import { EachMessagePayload, KafkaMessage } from 'kafkajs';

@@ -13,3 +14,3 @@

private logger;
constructor(processors: MessageProcessorType[], topics: string[], logger?: Console);
constructor(processors: MessageProcessorType[], topics: string[], logger?: Console | Logger);
start(): Promise<void>;

@@ -29,3 +30,3 @@ startBatchConsumer(): Promise<void>;

private logger;
constructor(topic: string, logger?: Console);
constructor(topic: string, logger?: Console | Logger);
start(): Promise<void>;

@@ -32,0 +33,0 @@ shutdown(): Promise<void>;

2

package.json
{
"name": "@bluexlab/kafka-ts",
"type": "module",
"version": "1.0.3",
"version": "1.0.4",
"description": "The kafka producer and consumer client",

@@ -6,0 +6,0 @@ "exports": {

Sorry, the diff of this file is not supported yet

SocketSocket SOC 2 Logo

Product

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

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc