From aa5c66e50c417786d0957dc5802b6329b9efa2ab Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Alexandre=20Del=C3=A8gue?= Date: Fri, 26 May 2023 11:23:53 +0200 Subject: [PATCH] fix tests --- .../fr/maif/eventsourcing/impl/KafkaEventPublisherTest.java | 6 +++--- 1 file changed, 3 insertions(+), 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 index 23b065f9..10973566 100644 --- 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 publisher = createPublisher(topic); EventStore eventStore = mock(EventStore.class); @@ -168,7 +168,7 @@ private Publisher txStream(T... values) { @Test @SuppressWarnings("unchecked") public void eventConsumptionWithEventFromDb() throws IOException { - String topic = createTopic(2, 5, 1); + String topic = createTopic(12, 5, 1); KafkaEventPublisher publisher = createPublisher(topic); EventStore 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 publisher = createPublisher(topic); EventStore eventStore = mock(EventStore.class); when(eventStore.openTransaction()).thenReturn(CompletionStages.successful(Tuple.empty()));