Skip to content

Commit eb0fdbe

Browse files
fix linger for the internal producer
1 parent d8decf0 commit eb0fdbe

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

superstream-clients/src/main/java/ai/superstream/core/ClientStatsReporter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -95,7 +95,7 @@ public ClientStatsReporter(String bootstrapServers, Properties clientProperties,
9595
// Use efficient compression settings for the reporter itself
9696
this.producerProperties.put(ProducerConfig.COMPRESSION_TYPE_CONFIG, "zstd");
9797
this.producerProperties.put(ProducerConfig.BATCH_SIZE_CONFIG, 16384);
98-
this.producerProperties.put(ProducerConfig.LINGER_MS_CONFIG, 100);
98+
this.producerProperties.put(ProducerConfig.LINGER_MS_CONFIG, 1000);
9999

100100
// Mark as registered for recordBatch logic
101101
this.registered.set(true);

0 commit comments

Comments
 (0)