fix tests

MAIF · May 26, 2023 · aa5c66e · aa5c66e
1 parent ee0554e
commit aa5c66e
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/thoth-core-akka/src/test/java/fr/maif/eventsourcing/impl/KafkaEventPublisherTest.java b/thoth-core-akka/src/test/java/fr/maif/eventsourcing/impl/KafkaEventPublisherTest.java
@@ -110,7 +110,7 @@ static void afterClass() {
     @SuppressWarnings("unchecked")
     public void eventConsumption() throws IOException, InterruptedException {
 
-        String topic = createTopic(1, 5, 1);
+        String topic = createTopic(11, 5, 1);
 
         KafkaEventPublisher<TestEvent, Void, Void> publisher = createPublisher(topic);
         EventStore<Tuple0, TestEvent, Void, Void> eventStore = mock(EventStore.class);
@@ -168,7 +168,7 @@ private <T> Publisher<T> txStream(T... values) {
     @Test
     @SuppressWarnings("unchecked")
     public void eventConsumptionWithEventFromDb() throws IOException {
-        String topic = createTopic(2, 5, 1);
+        String topic = createTopic(12, 5, 1);
         KafkaEventPublisher<TestEvent, Void, Void> publisher = createPublisher(topic);
         EventStore<Tuple0, TestEvent, Void, Void> eventStore = mock(EventStore.class);
         when(eventStore.openTransaction()).thenReturn(CompletionStages.successful(Tuple.empty()));
@@ -215,7 +215,7 @@ public void eventConsumptionWithEventFromDb() throws IOException {
     @SuppressWarnings("unchecked")
     public void testRestart() throws IOException {
         AtomicBoolean failed = new AtomicBoolean(false);
-        String topic = createTopic(3, 5, 1);
+        String topic = createTopic(13, 5, 1);
         KafkaEventPublisher<TestEvent, Void, Void> publisher = createPublisher(topic);
         EventStore<Tuple0, TestEvent, Void, Void> eventStore = mock(EventStore.class);
         when(eventStore.openTransaction()).thenReturn(CompletionStages.successful(Tuple.empty()));