Don't window records

2022-01-13 03:00:21 +01:00 · 2022-01-13 03:00:21 +01:00 · 006974ba23
parent f48a1d321b
commit 006974ba23
1 changed files with 1 additions and 2 deletions
--- a/src/main/java/it/tdlight/reactiveapi/KafkaProducer.java
+++ b/src/main/java/it/tdlight/reactiveapi/KafkaProducer.java
@ -40,8 +40,7 @@ public class KafkaProducer {
 						"tdlib.event.%d.%d".formatted(userId, liveId),
 						event
 				), null))
-				.windowTimeout(1024, Duration.ofMillis(10))
-				.flatMap(sender::send)
+				.flatMap(record -> sender.send(Mono.just(record)))
 				.doOnError(e -> LOG.error("Send failed", e))
 				.then();
 	}