1.71.0 • Published 2 days ago
@biorate/rdkafka v1.71.0
Rdkafka
Rdkafka connector
Examples:
import { inject, container, Types, Core } from '@biorate/inversion';
import { IConfig, Config } from '@biorate/config';
import { RdkafkaConnector, RdkafkaConfig } from '@biorate/rdkafka';
class Root extends Core() {
@inject(RdkafkaConnector) public connector: RdkafkaConnector;
}
container.bind<IConfig>(Types.Config).to(Config).inSingletonScope();
container.bind<RdkafkaConnector>(RdkafkaConnector).toSelf().inSingletonScope();
container.bind<Root>(Root).toSelf().inSingletonScope();
container.get<IConfig>(Types.Config).merge({
Rdkafka: [
{
name: 'connection',
options: {},
},
],
});
(async () => {
const root = container.get<Root>(Root);
await root.$run();
})();
Learn
- Documentation can be found here - docs.
Release History
See the CHANGELOG
License
Copyright (c) 2021-present Leonid Levkin (llevkin)
1.70.0
2 days ago
1.71.0
2 days ago
1.66.0
1 month ago
1.66.1
1 month ago
1.68.0
1 month ago
1.66.2
1 month ago
1.65.9
1 month ago
1.65.4
2 months ago
1.54.0
4 months ago
1.38.2
10 months ago
1.38.3
10 months ago
1.30.8
11 months ago
1.38.1
10 months ago
1.38.4
10 months ago
1.30.10
11 months ago
1.40.0
9 months ago
1.42.0
9 months ago
1.41.0
9 months ago
1.42.2
9 months ago
1.30.11
11 months ago
1.42.1
9 months ago
1.30.12
10 months ago
1.30.4
12 months ago
1.30.5
12 months ago
1.29.0
1 year ago
1.28.1
1 year ago
1.28.0
1 year ago
1.30.3
12 months ago
1.30.0
1 year ago
1.26.0
1 year ago
1.27.2
1 year ago
1.27.0
1 year ago
1.27.1
1 year ago
1.25.1
1 year ago
1.24.0
1 year ago
1.22.3
1 year ago
1.22.1
2 years ago
1.22.2
1 year ago
1.22.8
1 year ago
1.22.5
1 year ago
1.22.9
1 year ago
1.20.1
2 years ago
1.21.1
2 years ago
1.20.0
2 years ago
1.11.5
2 years ago
1.11.2
2 years ago