kafkajs kafkajs.provider.ts

60% Statements 3/5

100% Branches 0/0

0% Functions 0/2

60% Lines 3/5

Press n or j to go to the next uncovered block, b, p or k for the previous block.


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16 1x
 
 
1x
 
1x
 
 
 
 
 
 
 
 
 
  import { KafkaJS } from '@confluentinc/kafka-javascript';
import { IEventSdkOptions } from './kafkajs.type';
 
export const EVENT_SDK_KAFKAJS_TOKEN = 'EVENT_SDK_KAFKAJS_TOKEN';
 
export function getKafkaJsProvider(options: IEventSdkOptions) {
  return {
    provide: EVENT_SDK_KAFKAJS_TOKEN,
    useFactory: async () => {
      return new KafkaJS.Kafka({
        kafkaJS: options.client,
      });
    },
  };
}