tck consitent projection

Author: MatthieuMAIF

thoth-jooq/src/test/java/fr/maif/eventsourcing/impl/JooqKafkaTckImplementation.java

@@ -16,6 +16,7 @@
 import java.util.concurrent.Executors;
 
 import fr.maif.eventsourcing.Projection;
+import fr.maif.eventsourcing.datastore.TestConsistentProjection;
 import fr.maif.eventsourcing.datastore.TestProjection;
 import org.apache.kafka.clients.consumer.ConsumerConfig;
 import org.apache.kafka.clients.consumer.ConsumerRecord;
@@ -101,6 +102,7 @@ public void initClass() {
         postgres.start();
         kafka = new KafkaContainer();
         kafka.start();
+        consistentProjection = new TestConsistentProjection(actorSystem,kafka.getBootstrapServers(),eventFormat,dataSource);
     }
 
 
@@ -238,6 +240,11 @@ public Integer readProjection() {
         return ((TestProjection)this.testProjection).getCount();
     }
 
+    @Override
+    public Integer readConsistentProjection() {
+        return consistentProjection.getCount();
+    }
+
     private static Optional<Long> getEndOffsetIfNotReached(String topic, String kafkaServers, String groupId) {
         Properties properties = new Properties();
         properties.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, kafkaServers);