Update to latest signature (#207)

* Update to latest signature * Changed IP to another internal local network
masesgroup · Jan 27, 2024 · abc56e2 · abc56e2
1 parent 108184e
commit abc56e2
Show file tree

Hide file tree

Showing 27 changed files with 38 additions and 26 deletions.
diff --git a/src/net/KEFCore/Infrastructure/Internal/KafkaOptionsExtension.cs b/src/net/KEFCore/Infrastructure/Internal/KafkaOptionsExtension.cs
@@ -417,6 +417,18 @@ public virtual Properties StreamsOptions(string applicationId)
         return props;
     }
     /// <summary>
+    /// Build <see cref="ProducerConfigBuilder"/> for producers
+    /// </summary>
+    public virtual ProducerConfigBuilder ProducerOptionsBuilder()
+    {
+        ProducerConfigBuilder props = _producerConfigBuilder ?? new();
+        props.BootstrapServers = BootstrapServers;
+        props.Acks = ProducerConfigBuilder.AcksTypes.All;
+        props.Retries = 0;
+        props.LingerMs = 1;
+        return props;
+    }
+    /// <summary>
     /// Build <see cref="Properties"/> for producers
     /// </summary>
     public virtual Properties ProducerOptions()

diff --git a/src/net/KEFCore/Storage/Internal/EntityTypeProducer.cs b/src/net/KEFCore/Storage/Internal/EntityTypeProducer.cs
@@ -230,7 +230,7 @@ public EntityTypeProducer(IEntityType entityType, IKafkaCluster cluster)
         }
         else
         {
-            _kafkaProducer = new KNetProducer<TKey, TValueContainer>(_cluster.Options.ProducerOptions(), _keySerdes, _valueSerdes);
+            _kafkaProducer = new KNetProducer<TKey, TValueContainer>(_cluster.Options.ProducerOptionsBuilder(), _keySerdes, _valueSerdes);
             _streamData = _cluster.Options.UseKNetStreams ? new KNetStreamsRetriever<TKey, TValueContainer>(cluster, entityType)
                                                           : new KafkaStreamsTableRetriever<TKey, TValueContainer>(cluster, entityType, _keySerdes!, _valueSerdes!);
         }

diff --git a/test/KEFCore.Benchmark.Test/Benchmark.Avro.KNetReplicator.json b/test/KEFCore.Benchmark.Test/Benchmark.Avro.KNetReplicator.json
@@ -1,6 +1,6 @@
 {
   "UseAvro": true,
   "DatabaseName": "TestDBBenchmarkAvro",
-  "BootstrapServers": "192.168.1.108:9092",
+  "BootstrapServers": "192.168.0.101:9092",
   "NumberOfExecutions": 10
 }
diff --git a/test/KEFCore.Benchmark.Test/Benchmark.Avro.KNetStreams.json b/test/KEFCore.Benchmark.Test/Benchmark.Avro.KNetStreams.json
@@ -2,6 +2,6 @@
   "UseAvro": true,
   "DatabaseName": "TestDBBenchmarkAvro",
   "UseCompactedReplicator": false,
-  "BootstrapServers": "192.168.1.108:9092",
+  "BootstrapServers": "192.168.0.101:9092",
   "NumberOfExecutions": 10
 }
diff --git a/test/KEFCore.Benchmark.Test/Benchmark.Avro.KafkaStreams.json b/test/KEFCore.Benchmark.Test/Benchmark.Avro.KafkaStreams.json
@@ -3,6 +3,6 @@
   "DatabaseName": "TestDBBenchmarkAvro",
   "UseCompactedReplicator": false,
   "UseKNetStreams": false,
-  "BootstrapServers": "192.168.1.108:9092",
+  "BootstrapServers": "192.168.0.101:9092",
   "NumberOfExecutions": 10
 }
diff --git a/test/KEFCore.Benchmark.Test/Benchmark.KNetReplicator.json b/test/KEFCore.Benchmark.Test/Benchmark.KNetReplicator.json
@@ -1,5 +1,5 @@
 {
   "DatabaseName": "TestDBBenchmark",
-  "BootstrapServers": "192.168.1.108:9092",
+  "BootstrapServers": "192.168.0.101:9092",
   "NumberOfExecutions": 10
 }
diff --git a/test/KEFCore.Benchmark.Test/Benchmark.KNetStreams.json b/test/KEFCore.Benchmark.Test/Benchmark.KNetStreams.json
@@ -1,6 +1,6 @@
 {
   "DatabaseName": "TestDBBenchmark",
   "UseCompactedReplicator": false,
-  "BootstrapServers": "192.168.1.108:9092",
+  "BootstrapServers": "192.168.0.101:9092",
   "NumberOfExecutions": 10
 }
diff --git a/test/KEFCore.Benchmark.Test/Benchmark.KafkaStreams.json b/test/KEFCore.Benchmark.Test/Benchmark.KafkaStreams.json
@@ -2,6 +2,6 @@
   "DatabaseName": "TestDBBenchmark",
   "UseCompactedReplicator": false,
   "UseKNetStreams": false,
-  "BootstrapServers": "192.168.1.108:9092",
+  "BootstrapServers": "192.168.0.101:9092",
   "NumberOfExecutions": 10
 }
diff --git a/test/KEFCore.Benchmark.Test/Benchmark.Protobuf.KNetReplicator.json b/test/KEFCore.Benchmark.Test/Benchmark.Protobuf.KNetReplicator.json
@@ -1,6 +1,6 @@
 {
   "UseProtobuf": true,
   "DatabaseName": "TestDBBenchmarkProtobuf",
-  "BootstrapServers": "192.168.1.108:9092",
+  "BootstrapServers": "192.168.0.101:9092",
   "NumberOfExecutions": 10
 }
diff --git a/test/KEFCore.Benchmark.Test/Benchmark.Protobuf.KNetStreams.json b/test/KEFCore.Benchmark.Test/Benchmark.Protobuf.KNetStreams.json
@@ -2,6 +2,6 @@
   "UseProtobuf": true,
   "DatabaseName": "TestDBBenchmarkProtobuf",
   "UseCompactedReplicator": false,
-  "BootstrapServers": "192.168.1.108:9092",
+  "BootstrapServers": "192.168.0.101:9092",
   "NumberOfExecutions": 10
 }
diff --git a/test/KEFCore.Benchmark.Test/Benchmark.Protobuf.KafkaStreams.json b/test/KEFCore.Benchmark.Test/Benchmark.Protobuf.KafkaStreams.json
@@ -3,6 +3,6 @@
   "DatabaseName": "TestDBBenchmarkProtobuf",
   "UseCompactedReplicator": false,
   "UseKNetStreams": false,
-  "BootstrapServers": "192.168.1.108:9092",
+  "BootstrapServers": "192.168.0.101:9092",
   "NumberOfExecutions": 10
 }
diff --git a/test/KEFCore.Complex.Test/ComplexTest.KNetReplicator.json b/test/KEFCore.Complex.Test/ComplexTest.KNetReplicator.json
@@ -1,6 +1,6 @@
 {
   "DatabaseName": "TestDBComplex",
-  "BootstrapServers": "192.168.1.108:9092",
+  "BootstrapServers": "192.168.0.101:9092",
   "NumberOfElements": 10,
   "NumberOfExtraElements": 1
 }
diff --git a/test/KEFCore.Extractor.Test/Extractor.Test.Blog.Avro.json b/test/KEFCore.Extractor.Test/Extractor.Test.Blog.Avro.json
@@ -1,4 +1,4 @@
 {
-  "BootstrapServers": "192.168.1.108:9092",
+  "BootstrapServers": "192.168.0.101:9092",
   "TopicToSubscribe": "TestDBBenchmarkAvro.MASES.EntityFrameworkCore.KNet.Test.Blog"
 }
diff --git a/test/KEFCore.Extractor.Test/Extractor.Test.Blog.json b/test/KEFCore.Extractor.Test/Extractor.Test.Blog.json
@@ -1,4 +1,4 @@
 {
-  "BootstrapServers": "192.168.1.108:9092",
+  "BootstrapServers": "192.168.0.101:9092",
   "TopicToSubscribe": "TestDBBenchmark.MASES.EntityFrameworkCore.KNet.Test.Blog"
 }
diff --git a/test/KEFCore.StreamTest/StreamTest.KafkaStreams.json b/test/KEFCore.StreamTest/StreamTest.KafkaStreams.json
@@ -1,4 +1,4 @@
 {
   "UseCompactedReplicator": false,
-  "BootstrapServers": "192.168.1.108:9092"
+  "BootstrapServers": "192.168.0.101:9092"
 }
diff --git a/test/KEFCore.StreamTest/StreamTest.KafkaStreamsModelBuilder.json b/test/KEFCore.StreamTest/StreamTest.KafkaStreamsModelBuilder.json
@@ -1,5 +1,5 @@
 {
   "UseCompactedReplicator": false,
   "UseModelBuilder": true,
-  "BootstrapServers": "192.168.1.108:9092"
+  "BootstrapServers": "192.168.0.101:9092"
 }
diff --git a/test/KEFCore.StreamTest/StreamTest.KafkaStreamsNoLoad.json b/test/KEFCore.StreamTest/StreamTest.KafkaStreamsNoLoad.json
@@ -2,5 +2,5 @@
   "DeleteApplicationData": false,
   "LoadApplicationData": false,
   "UseCompactedReplicator": false,
-  "BootstrapServers": "192.168.1.108:9092"
+  "BootstrapServers": "192.168.0.101:9092"
 }
diff --git a/test/KEFCore.StreamTest/StreamTest.KafkaStreamsPersisted.json b/test/KEFCore.StreamTest/StreamTest.KafkaStreamsPersisted.json
@@ -3,5 +3,5 @@
   "DeleteApplicationData": false,
   "LoadApplicationData": false,
   "UseCompactedReplicator": false,
-  "BootstrapServers": "192.168.1.108:9092"
+  "BootstrapServers": "192.168.0.101:9092"
 }
diff --git a/test/KEFCore.Test/Test.KNetReplicator.json b/test/KEFCore.Test/Test.KNetReplicator.json
@@ -1,3 +1,3 @@
 {
-  "BootstrapServers": "192.168.1.108:9092"
+  "BootstrapServers": "192.168.0.101:9092"
 }
diff --git a/test/KEFCore.Test/Test.KNetReplicatorModelBuilder.json b/test/KEFCore.Test/Test.KNetReplicatorModelBuilder.json
@@ -1,4 +1,4 @@
 {
   "UseModelBuilder": true,
-  "BootstrapServers": "192.168.1.108:9092"
+  "BootstrapServers": "192.168.0.101:9092"
 }
diff --git a/test/KEFCore.Test/Test.KNetReplicatorNoLoad.json b/test/KEFCore.Test/Test.KNetReplicatorNoLoad.json
@@ -1,5 +1,5 @@
 {
   "DeleteApplicationData": false,
   "LoadApplicationData": false,
-  "BootstrapServers": "192.168.1.108:9092"
+  "BootstrapServers": "192.168.0.101:9092"
 }
diff --git a/test/KEFCore.Test/Test.KNetReplicatorWithEvents.json b/test/KEFCore.Test/Test.KNetReplicatorWithEvents.json
@@ -1,5 +1,5 @@
 {
-  "BootstrapServers": "192.168.1.108:9092",
+  "BootstrapServers": "192.168.0.101:9092",
   "DatabaseName": "TestDBWithEvents",
   "NumberOfElements": 10,
   "WithEvents": true

diff --git a/test/KEFCore.Test/Test.KafkaStreams.json b/test/KEFCore.Test/Test.KafkaStreams.json
@@ -1,4 +1,4 @@
 {
   "UseCompactedReplicator": false,
-  "BootstrapServers": "192.168.1.108:9092"
+  "BootstrapServers": "192.168.0.101:9092"
 }
diff --git a/test/KEFCore.Test/Test.KafkaStreamsModelBuilder.json b/test/KEFCore.Test/Test.KafkaStreamsModelBuilder.json
@@ -1,5 +1,5 @@
 {
   "UseCompactedReplicator": false,
   "UseModelBuilder": true,
-  "BootstrapServers": "192.168.1.108:9092"
+  "BootstrapServers": "192.168.0.101:9092"
 }
diff --git a/test/KEFCore.Test/Test.KafkaStreamsNoLoad.json b/test/KEFCore.Test/Test.KafkaStreamsNoLoad.json
@@ -2,5 +2,5 @@
   "DeleteApplicationData": false,
   "LoadApplicationData": false,
   "UseCompactedReplicator": false,
-  "BootstrapServers": "192.168.1.108:9092"
+  "BootstrapServers": "192.168.0.101:9092"
 }
diff --git a/test/KEFCore.Test/Test.KafkaStreamsPersisted.json b/test/KEFCore.Test/Test.KafkaStreamsPersisted.json
@@ -3,5 +3,5 @@
   "DeleteApplicationData": false,
   "LoadApplicationData": false,
   "UseCompactedReplicator": false,
-  "BootstrapServers": "192.168.1.108:9092"
+  "BootstrapServers": "192.168.0.101:9092"
 }
diff --git a/test/KEFCore.Test/TestAvro.KNetReplicatorModelBuilder.json b/test/KEFCore.Test/TestAvro.KNetReplicatorModelBuilder.json
@@ -1,5 +1,5 @@
 {
   "UseAvro":  true,
   "UseModelBuilder": true,
-  "BootstrapServers": "192.168.1.108:9092"
+  "BootstrapServers": "192.168.0.101:9092"
 }