Set default replication factor to -1 and fix test

qubicmio · qubicmio · commit 88cefc48664d · 2026-04-14T17:51:19.000+02:00
* Replication factor 3 breaks the integration test.
* Maybe it's better to use the defaults and override as it's specific to the deployment.
diff --git a/event-logs-dedup/src/main/resources/application.properties b/event-logs-dedup/src/main/resources/application.properties
@@ -18,7 +18,7 @@ streams.cache-max-bytes-buffering=10485760
 streams.num-stream-threads=1
 streams.topology-optimization=all
 # replication factor -1 uses the broker defaults
-streams.replication-factor=3
+streams.replication-factor=-1
 
 # Application-specific configuration
 dedup.input-topic=qubic-event-logs-incoming
diff --git a/event-logs-dedup/src/test/java/org/qubic/logs/dedup/DeduplicationApplicationIT.java b/event-logs-dedup/src/test/java/org/qubic/logs/dedup/DeduplicationApplicationIT.java
@@ -27,6 +27,7 @@
 )
 @TestPropertySource(properties = {
         "streams.bootstrap-servers=${spring.embedded.kafka.brokers}",
+        "streams.replication-factor=-1",
         "dedup.input-topic=log-in",
         "dedup.output-topic=log-out",
         "streams.state-dir=/tmp/${random.uuid}"

Original file line number	Diff line number	Diff line change
`@@ -27,6 +27,7 @@`
`27`	`27`	`)`
`28`	`28`	`@TestPropertySource(properties = {`
`29`	`29`	`"streams.bootstrap-servers=${spring.embedded.kafka.brokers}",`
	`30`	`+ "streams.replication-factor=-1",`
`30`	`31`	`"dedup.input-topic=log-in",`
`31`	`32`	`"dedup.output-topic=log-out",`
`32`	`33`	`"streams.state-dir=/tmp/${random.uuid}"`