1.76.3 • Published 1 year ago
@biorate/kafkajs v1.76.3
KafkaJS
KafkaJS connector
Examples:
import { inject, container, Types, Core } from '@biorate/inversion';
import { IConfig, Config } from '@biorate/config';
import { KafkaJSProducerConnector } from '@biorate/kafkajs';
class Root extends Core() {
@inject(KafkaJSProducerConnector) public producer: KafkaJSProducerConnector;
}
container.bind<IConfig>(Types.Config).to(Config).inSingletonScope();
container.bind<KafkaJSProducerConnector>(KafkaJSProducerConnector).toSelf().inSingletonScope();
container.bind<Root>(Root).toSelf().inSingletonScope();
container.get<IConfig>(Types.Config).merge({
KafkaJSGlobal: {
brokers: ['localhost:9092'],
clientId: 'test-app',
logLevel: 1,
},
KafkaJSProducer: [
{
name: 'producer',
global: '#{KafkaJSGlobal}',
},
],
});
(async () => {
const topic = 'test-kafkajs';
const root = container.get<Root>(Root);
await root.$run();
await root.producer!.current!.send({
topic,
messages: [
{ key: 'key 1', value: 'hello world 1' },
{ key: 'key 2', value: 'hello world 2' },
{ key: 'key 3', value: 'hello world 3' },
],
});
})();
Learn
- Documentation can be found here - docs.
Release History
See the CHANGELOG
License
Copyright (c) 2021-present Leonid Levkin (llevkin)
1.76.3
1 year ago
1.67.0
1 year ago
1.68.0
1 year ago
1.65.4
1 year ago
1.54.0
2 years ago
1.38.2
2 years ago
1.38.3
2 years ago
1.30.8
2 years ago
1.38.1
2 years ago
1.38.4
2 years ago
1.30.10
2 years ago
1.42.2
2 years ago
1.30.11
2 years ago
1.42.1
2 years ago
1.30.12
2 years ago
1.29.0
2 years ago
1.28.1
2 years ago
1.28.0
2 years ago
1.26.0
2 years ago
1.27.2
2 years ago
1.27.0
2 years ago
1.27.1
2 years ago
1.24.0
2 years ago
1.22.8
3 years ago
1.22.7
3 years ago
1.22.4
3 years ago
1.22.3
3 years ago