We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent adc99b1 commit 8f7c454Copy full SHA for 8f7c454
packages/service-utils/src/node/kafka.ts
@@ -117,7 +117,7 @@ export class KafkaProducer {
117
if (!this.producer) {
118
this.producer = this.kafka.producer({
119
allowAutoTopicCreation: options?.allowAutoTopicCreation ?? false,
120
- maxInFlightRequests: options?.maxInFlightRequests ?? 1000,
+ maxInFlightRequests: options?.maxInFlightRequests ?? 2000,
121
retry: { retries: options?.retries ?? 5 },
122
});
123
await this.producer.connect();
0 commit comments