@bluexlab/kafka-ts
Advanced tools
Comparing version 1.0.3 to 1.0.4
@@ -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>; |
{ | ||
"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
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
14764
319