KNetCompactedReplicator becomes the default engine (#96)

src/net/Common/Common.props

@@ -4,7 +4,7 @@
 		<Owners>MASES s.r.l.</Owners>
 		<Authors>MASES s.r.l.</Authors>
 		<Company>MASES s.r.l.</Company>
-		<Version>0.9.1.0</Version>
+		<Version>0.9.2.0</Version>
 		<TargetFrameworks>net6.0</TargetFrameworks>
 		<LangVersion>latest</LangVersion>
 		<GenerateAssemblyInfo>true</GenerateAssemblyInfo>

src/net/KEFCore/Infrastructure/Internal/KafkaOptionsExtension.cs

@@ -46,7 +46,7 @@ public class KafkaOptionsExtension : IDbContextOptionsExtension
     private string? _applicationId;
     private string? _bootstrapServers;
     //private bool _producerByEntity = false;
-    private bool _useCompactedReplicator = false;
+    private bool _useCompactedReplicator = true;
     private bool _usePersistentStorage = false;
     private int _defaultNumPartitions = 1;
     private int? _defaultConsumerInstances = null;
@@ -203,7 +203,7 @@ public virtual KafkaOptionsExtension WithBootstrapServers(string bootstrapServer
     //    return clone;
     //}
 
-    public virtual KafkaOptionsExtension WithCompactedReplicator(bool useCompactedReplicator = false)
+    public virtual KafkaOptionsExtension WithCompactedReplicator(bool useCompactedReplicator = true)
     {
         var clone = Clone();
 

src/net/KEFCore/Infrastructure/KafkaDbContext.cs

@@ -202,7 +202,7 @@ public KafkaDbContext(DbContextOptions options) : base(options)
     /// <summary>
     /// Use <see cref="MASES.KNet.Replicator.KNetCompactedReplicator{TKey, TValue}"/> instead of Apache Kafka Streams
     /// </summary>
-    public virtual bool UseCompactedReplicator { get; set; } = false;
+    public virtual bool UseCompactedReplicator { get; set; } = true;
     /// <summary>
     /// The optional <see cref="ConsumerConfigBuilder"/> used when <see cref="UseCompactedReplicator"/> is <see langword="true"/>
     /// </summary>

test/Common/ProgramConfig.cs

@@ -30,7 +30,7 @@ public class ProgramConfig
         public bool EnableKEFCoreTracing { get; set; } = false;
         public bool UseInMemoryProvider { get; set; } = false;
         public bool UseModelBuilder { get; set; } = false;
-        public bool UseCompactedReplicator { get; set; } = false;
+        public bool UseCompactedReplicator { get; set; } = true;
         public bool UsePersistentStorage { get; set; } = false;
         public string DatabaseName { get; set; } = "TestDB";
         public string DatabaseNameWithModel { get; set; } = "TestDBWithModel";

test/KEFCore.Benchmark.Avro.Test/Benchmark.Avro.Test.InMemory.json

@@ -1,4 +1,5 @@
 {
+  "DatabaseName": "TestDBBenchmarkAvro",
   "UseInMemoryProvider": true,
-  "NumberOfExecutions":  10
+  "NumberOfExecutions": 10
 }

test/KEFCore.Benchmark.Avro.Test/Benchmark.Avro.Test.KNetReplicator.json

@@ -1,5 +1,5 @@
 {
-  "UseCompactedReplicator": true,
+  "DatabaseName": "TestDBBenchmarkAvro",
   "BootstrapServers": "192.168.1.103:9092",
   "NumberOfExecutions": 10
 }

test/KEFCore.Benchmark.Avro.Test/Benchmark.Avro.Test.KafkaStreams.json

@@ -1,4 +1,6 @@
 {
+  "DatabaseName": "TestDBBenchmarkAvro",
+  "UseCompactedReplicator": false,
   "BootstrapServers": "192.168.1.103:9092",
   "NumberOfExecutions": 10
 }

test/KEFCore.Benchmark.Test/BenchmarkTest.InMemory.json

@@ -1,4 +1,5 @@
 {
+  "DatabaseName": "TestDBBenchmark",
   "UseInMemoryProvider": true,
-  "NumberOfExecutions":  10
+  "NumberOfExecutions": 10
 }

test/KEFCore.Benchmark.Test/BenchmarkTest.KNetReplicator.json

@@ -1,5 +1,5 @@
 {
-  "UseCompactedReplicator": true,
+  "DatabaseName": "TestDBBenchmark",
   "BootstrapServers": "192.168.1.103:9092",
   "NumberOfExecutions": 10
 }

test/KEFCore.Benchmark.Test/BenchmarkTest.KafkaStreams.json

@@ -1,4 +1,6 @@
 {
+  "DatabaseName": "TestDBBenchmark",
+  "UseCompactedReplicator": false,
   "BootstrapServers": "192.168.1.103:9092",
   "NumberOfExecutions": 10
 }

test/KEFCore.Complex.Test/ComplexTest.KNetReplicator.json

@@ -1,6 +1,5 @@
 {
   "DatabaseName": "TestDBComplex",
-  "UseCompactedReplicator": true,
   "BootstrapServers": "192.168.1.103:9092",
   "NumberOfElements": 10,
   "NumberOfExtraElements": 1

test/KEFCore.Test/Test.KNetReplicator.json

@@ -1,4 +1,3 @@
 {
-  "UseCompactedReplicator": true,
   "BootstrapServers": "192.168.1.103:9092"
 }

test/KEFCore.Test/Test.KNetReplicatorModelBuilder.json

@@ -1,5 +1,4 @@
 {
-  "UseCompactedReplicator": true,
   "UseModelBuilder": true,
   "BootstrapServers": "192.168.1.103:9092"
 }

test/KEFCore.Test/Test.KNetReplicatorNoLoad.json

@@ -1,5 +1,4 @@
 {
-  "UseCompactedReplicator": true,
   "DeleteApplicationData": false,
   "LoadApplicationData": false,
   "BootstrapServers": "192.168.1.103:9092"

test/KEFCore.Test/Test.KafkaStreams.json

@@ -1,3 +1,4 @@
 {
+  "UseCompactedReplicator": false,
   "BootstrapServers": "192.168.1.103:9092"
 }

test/KEFCore.Test/Test.KafkaStreamsModelBuilder.json

@@ -1,4 +1,5 @@
 {
+  "UseCompactedReplicator": false,
   "UseModelBuilder": true,
   "BootstrapServers": "192.168.1.103:9092"
 }

test/KEFCore.Test/Test.KafkaStreamsNoLoad.json

@@ -1,5 +1,6 @@
 {
   "DeleteApplicationData": false,
   "LoadApplicationData": false,
+  "UseCompactedReplicator": false,
   "BootstrapServers": "192.168.1.103:9092"
 }

test/KEFCore.Test/Test.KafkaStreamsPersisted.json

@@ -2,5 +2,6 @@
   "UsePersistentStorage": true,
   "DeleteApplicationData": false,
   "LoadApplicationData": false,
+  "UseCompactedReplicator": false,
   "BootstrapServers": "192.168.1.103:9092"
 }