|
Improve this Doc
diff --git a/docs/api/MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaSingletonOptions.html b/docs/api/MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaSingletonOptions.html
index b238e84f..80c424ce 100644
--- a/docs/api/MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaSingletonOptions.html
+++ b/docs/api/MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaSingletonOptions.html
@@ -363,18 +363,18 @@ Property Value
|
- Improve this Doc
+ Improve this Doc
- View Source
+ View Source
-
- ProducerByEntity
+
+ ProducerConfig
Declaration
-
public virtual bool ProducerByEntity { get; }
+
public virtual ProducerConfigBuilder ProducerConfig { get; }
Property Value
@@ -386,25 +386,25 @@ Property Value
- Boolean |
+ MASES.KNet.Producer.ProducerConfigBuilder |
|
|
- Improve this Doc
+ Improve this Doc
- View Source
+ View Source
-
- ProducerConfig
+
+ StreamsConfig
Declaration
-
public virtual ProducerConfigBuilder ProducerConfig { get; }
+
public virtual StreamsConfigBuilder StreamsConfig { get; }
Property Value
@@ -416,25 +416,25 @@ Property Value
- MASES.KNet.Producer.ProducerConfigBuilder |
+ MASES.KNet.Streams.StreamsConfigBuilder |
|
|
- Improve this Doc
+ Improve this Doc
- View Source
+ View Source
-
- StreamsConfig
+
+ TopicConfig
Declaration
-
public virtual StreamsConfigBuilder StreamsConfig { get; }
+
public virtual TopicConfigBuilder TopicConfig { get; }
Property Value
@@ -446,25 +446,25 @@ Property Value
- MASES.KNet.Streams.StreamsConfigBuilder |
+ MASES.KNet.Common.TopicConfigBuilder |
|
|
- Improve this Doc
+ Improve this Doc
- View Source
+ View Source
-
- TopicConfig
+
+ UseCompactedReplicator
Declaration
-
public virtual TopicConfigBuilder TopicConfig { get; }
+
public virtual bool UseCompactedReplicator { get; }
Property Value
@@ -476,25 +476,25 @@ Property Value
- MASES.KNet.Common.TopicConfigBuilder |
+ Boolean |
|
|
- Improve this Doc
+ Improve this Doc
- View Source
+ View Source
-
- UseCompactedReplicator
+
+ UseDeletePolicyForTopic
Declaration
-
public virtual bool UseCompactedReplicator { get; }
+
public virtual bool UseDeletePolicyForTopic { get; }
Property Value
diff --git a/docs/api/MASES.EntityFrameworkCore.KNet.Infrastructure.KafkaDbContext.html b/docs/api/MASES.EntityFrameworkCore.KNet.Infrastructure.KafkaDbContext.html
index 53c9bd12..17b410d6 100644
--- a/docs/api/MASES.EntityFrameworkCore.KNet.Infrastructure.KafkaDbContext.html
+++ b/docs/api/MASES.EntityFrameworkCore.KNet.Infrastructure.KafkaDbContext.html
@@ -741,6 +741,37 @@ Property Value
+
+ |
+ Improve this Doc
+
+
+ View Source
+
+
+ UseDeletePolicyForTopic
+
+
+ Declaration
+
+
public bool UseDeletePolicyForTopic { get; set; }
+
+ Property Value
+
+
+
+ Type |
+ Description |
+
+
+
+
+ Boolean |
+ |
+
+
+
|
Improve this Doc
diff --git a/docs/api/MASES.EntityFrameworkCore.KNet.Infrastructure.KafkaDbContextOptionsBuilder.html b/docs/api/MASES.EntityFrameworkCore.KNet.Infrastructure.KafkaDbContextOptionsBuilder.html
index c59a12e2..652f6b83 100644
--- a/docs/api/MASES.EntityFrameworkCore.KNet.Infrastructure.KafkaDbContextOptionsBuilder.html
+++ b/docs/api/MASES.EntityFrameworkCore.KNet.Infrastructure.KafkaDbContextOptionsBuilder.html
@@ -683,6 +683,60 @@ Returns
+
+ |
+ Improve this Doc
+
+
+ View Source
+
+
+ WithUseDeletePolicyForTopic(Boolean)
+
+
+ Declaration
+
+
public virtual KafkaDbContextOptionsBuilder WithUseDeletePolicyForTopic(bool useDeletePolicyForTopic = false)
+
+ Parameters
+
+
+
+ Type |
+ Name |
+ Description |
+
+
+
+
+ Boolean |
+ useDeletePolicyForTopic |
+ If true, then will be used delete cleanup policy when the topic is created the first time.
+ |
+
+
+
+ Returns
+
+
+
|
diff --git a/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.html b/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.html
index c2bf7f45..ddc44d4c 100644
--- a/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.html
+++ b/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.html
@@ -455,7 +455,7 @@ Returns
Improve this Doc
- View Source
+ View Source
ExecuteTransaction(IList<IUpdateEntry>, IDiagnosticsLogger<DbLoggerCategory.Update>)
@@ -569,7 +569,7 @@ Type Parameters
Improve this Doc
- View Source
+ View Source
GetValueBuffers(IEntityType)
diff --git a/docs/articles/currentstate.html b/docs/articles/currentstate.html
index 9afee216..6618f190 100644
--- a/docs/articles/currentstate.html
+++ b/docs/articles/currentstate.html
@@ -73,7 +73,8 @@ KEFCore: development state
- [x] A working provider based on Apache Kafka Streams
- [x] The provider can use KNetCompactedReplicator
-- [x] A first external package for serialization based on previous available serializers
+- [x] An external package for serialization based on .NET 6 Json serializers
+- [x] An external package for serialization based on Apache Avro serializers
diff --git a/docs/articles/gettingstarted.html b/docs/articles/gettingstarted.html
index 8c97bc9f..ab194f65 100644
--- a/docs/articles/gettingstarted.html
+++ b/docs/articles/gettingstarted.html
@@ -74,6 +74,9 @@ KEFCore: Getting started
an installed JRE/JDK (11+)
an accessible Apache Kafka broker (a full cluster or a local Dockerized version)
+
+IMPORTANT NOTE: till the first major version, all releases shall be considered not stable: this means the API public, or internal, can be change without notice.
+
First project setup
- Create a new simple empty project:
diff --git a/docs/articles/intro.html b/docs/articles/intro.html
index a89c1d14..7479210c 100644
--- a/docs/articles/intro.html
+++ b/docs/articles/intro.html
@@ -72,6 +72,9 @@ Welcome to KEFCore
KEFCore is the Entity Framework Core provider for Apache Kafka.
Based on KNet it allows to use Apache Kafka as a distributed database and more.
This project adheres to the Contributor Covenant code of conduct. By participating, you are expected to uphold this code. Please report unacceptable behavior to coc_reporting@masesgroup.com.
+
+IMPORTANT NOTE: till the first major version, all releases shall be considered not stable: this means the API public, or internal, can be change without notice.
+
diff --git a/docs/articles/kafkadbcontext.html b/docs/articles/kafkadbcontext.html
index c199e923..ee6bccff 100644
--- a/docs/articles/kafkadbcontext.html
+++ b/docs/articles/kafkadbcontext.html
@@ -83,7 +83,8 @@ KEFCore: KafkaDbContext
- DefaultNumPartitions: the default number of partitions used when topics are created for each entity
- DefaultReplicationFactor: the replication factor to use when data are stored in Apache Kafka
- DefaultConsumerInstances: the consumer instances to be allocated when UseCompactedReplicator is true
-- UsePersistentStorage: set to true to use a persintent storage between multiple application startup
+- UsePersistentStorage: set to true to use a persistent storage between multiple application startup
+- UseDeletePolicyForTopic: set to true to enable delete cleanup policy
- UseCompactedReplicator: Use
KNetCompactedReplicator
instead of Apache Kafka Streams to manage data to or from topics
- ConsumerConfig: parameters to use for Producer
- ProducerConfig: parameters to use for Producer
diff --git a/docs/articles/roadmap.html b/docs/articles/roadmap.html
index 08fdb94e..4520d8a2 100644
--- a/docs/articles/roadmap.html
+++ b/docs/articles/roadmap.html
@@ -75,6 +75,7 @@ KEFCore: roadmap
- [ ] Extends the first provider with new features able to create Apache Kafka Streams topology to retrieve information
- [x] Use KNetCompactedReplicator beside Apache Kafka Streams
- [x] Add external package to manage data serialization
+- [x] Add Avro external package to manage data serialization
diff --git a/docs/articles/serialization.html b/docs/articles/serialization.html
index 50fae2cc..27221d3b 100644
--- a/docs/articles/serialization.html
+++ b/docs/articles/serialization.html
@@ -71,6 +71,9 @@ KEFCore: serialization
Entity Framework Core provider for Apache Kafka shall convert the entities used within the model in something viable from the backend.
Each backend has its own schema to convert entities into something else; database providers converts entities into database schema or blob in Cosmos.
+
+IMPORTANT NOTE: till the first major version, all releases shall be considered not stable: this means the API public, or internal, can be change without notice.
+
Basic concepts
Entity Framework Core provider for Apache Kafka shall convert the entities into record will be stored in the topics of Apache Kafka cluster.
The way the entities are converted shall follows a schema.
diff --git a/docs/index.html b/docs/index.html
index 1c066644..41048ecc 100644
--- a/docs/index.html
+++ b/docs/index.html
@@ -65,10 +65,24 @@
KEFCore:
KEFCore is the Entity Framework Core provider for Apache Kafka.
Based on KNet it allows to use Apache Kafka as a distributed database and more.
-This project adheres to the Contributor Covenant code of conduct. By participating, you are expected to uphold this code. Please report unacceptable behavior to coc_reporting@masesgroup.com.
+
+IMPORTANT NOTE: till the first major version, all releases shall be considered not stable: this means the API public, or internal, can be change without notice.
+
Scope of the project
This project aims to create a provider to access the information stored within an Apache Kafka cluster using the paradigm behind Entity Framework.
The project is based on available information within the official EntityFrameworkCore repository, many classes was copied from there as reported in the official documentation within the Microsoft website at https://docs.microsoft.com/en-us/ef/core/providers/writing-a-provider.
+Community and Contribution
+Do you like the project?
+
+Do you want to help us?
+
+- put a ⭐ on this project
+- open issues to request features or report bugs 🐛
+- improves the project with Pull Requests
+
+This project adheres to the Contributor Covenant code of conduct. By participating, you are expected to uphold this code. Please report unacceptable behavior to coc_reporting@masesgroup.com.
Summary
diff --git a/docs/manifest.json b/docs/manifest.json
index f367813a..62805a3d 100644
--- a/docs/manifest.json
+++ b/docs/manifest.json
@@ -117,7 +117,7 @@
"output": {
".html": {
"relative_path": "api/MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.IKafkaSingletonOptions.html",
- "hash": "Uj+KkTMA3PK9c3cDDDzpuEGuaNq45BWbNVSXWZ6l6pg="
+ "hash": "Job5dRYS4+Gq8EwhocLGZMeJynnvSt2DPwtPcaciwXU="
}
},
"is_incremental": false,
@@ -141,7 +141,7 @@
"output": {
".html": {
"relative_path": "api/MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaOptionsExtension.html",
- "hash": "lVuDPb87TSUd2IIinaadzHgXPeImalzFlEUals4yVco="
+ "hash": "oTGj9mKv4EkBStE9qajUeF82tfNRIsE2EFnhwj4JKL4="
}
},
"is_incremental": false,
@@ -153,7 +153,7 @@
"output": {
".html": {
"relative_path": "api/MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaSingletonOptions.html",
- "hash": "dKRD/cTxyf0SYK5B1n5/CnSVcY8ryzNP+8OoVgbLq8o="
+ "hash": "RNxpLH95UUQ35kPgGSL7ug5AZO+BqDbg61MAQAWI4O4="
}
},
"is_incremental": false,
@@ -177,7 +177,7 @@
"output": {
".html": {
"relative_path": "api/MASES.EntityFrameworkCore.KNet.Infrastructure.KafkaDbContext.html",
- "hash": "CgUS4RSVtOjSoBtPFUdT4alrh07irpfZ7ko5bLMBWFQ="
+ "hash": "goj59V+c/IA5I8IaUuYGM750a9if3vxSWRmVE0d9O80="
}
},
"is_incremental": false,
@@ -189,7 +189,7 @@
"output": {
".html": {
"relative_path": "api/MASES.EntityFrameworkCore.KNet.Infrastructure.KafkaDbContextOptionsBuilder.html",
- "hash": "gi4bNrDTxNi1lPSAFtQCHSgUFSHwJ0V61Jd7MjyZhRg="
+ "hash": "ux2wyv3nfSjYC2sBVu6AC4fGNetuaiyP0x7oW8hPVkE="
}
},
"is_incremental": false,
@@ -873,7 +873,7 @@
"output": {
".html": {
"relative_path": "api/MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.html",
- "hash": "7tkQuXtSYLP+2OEKrB1WARj4wojjjbAIVvFPKJL7sRM="
+ "hash": "iuZf5X6458CN4egz2Xhap/Msan92hRBQPRmZl4k5/JA="
}
},
"is_incremental": false,
@@ -1173,7 +1173,7 @@
"output": {
".html": {
"relative_path": "articles/currentstate.html",
- "hash": "HjbEWUlg0OIXkeYwgwS3TUaCiQsmjlBg9RrGeGiupGQ="
+ "hash": "AEJqbWKhDPgMH9H0vuOltBq10FOeOCCydMiPd798PeQ="
}
},
"is_incremental": false,
@@ -1185,7 +1185,7 @@
"output": {
".html": {
"relative_path": "articles/gettingstarted.html",
- "hash": "/W951ShoKJvr7SXGYXKrRDugpRR/FTy30Luh+uw6MHw="
+ "hash": "Jc/Bp+rZXRvt3FJhnQy09YwOSAlttWCaxrbfIOfDaRI="
}
},
"is_incremental": false,
@@ -1200,7 +1200,7 @@
"output": {
".html": {
"relative_path": "articles/intro.html",
- "hash": "/L3P8eBFqqgcEl8VFEqCNL/2H7U48boHjK4c9k/S8VQ="
+ "hash": "Q8GVgyYEaQSvfbCkklK8aF4aD8PXN4P5xf7KmXGp60M="
}
},
"is_incremental": false,
@@ -1212,7 +1212,7 @@
"output": {
".html": {
"relative_path": "articles/kafkadbcontext.html",
- "hash": "IzR5GENib2j0xHPGZaVJCH/gd/FOUNAa1BCIkkH9PVg="
+ "hash": "J9UgM0BvY5RvDOxuVTerP136GLogLyL8Z3CRaG2J7yA="
}
},
"is_incremental": false,
@@ -1224,7 +1224,7 @@
"output": {
".html": {
"relative_path": "articles/roadmap.html",
- "hash": "62EeGAX/Mve/T32XGy3X1i+K/PrGsxY/0P4b4gXS3jM="
+ "hash": "/vF2q6eVwzhOE0YBeGkIWwRNGqNYgQKSSIIPikZiQNs="
}
},
"is_incremental": false,
@@ -1236,7 +1236,7 @@
"output": {
".html": {
"relative_path": "articles/serialization.html",
- "hash": "ZAwpoq0IA6oqhjiLBFRzH61UIX59pwRz99fih0ck7qc="
+ "hash": "oWzIVCGfg3/EJnJV2PYtxQzajMYTc6qGRkBAxpdrHvg="
}
},
"is_incremental": false,
@@ -1286,7 +1286,7 @@
"output": {
".html": {
"relative_path": "index.html",
- "hash": "qZ2orWittKheGZw50tqSCrdjpH6l296RNQPFvHuYSiM="
+ "hash": "zZDHatL33w3Y87AXH9ly5sIMY13X8CqEcUc0mEATooA="
}
},
"is_incremental": false,
diff --git a/docs/xrefmap.yml b/docs/xrefmap.yml
index 1b430369..49c2b423 100644
--- a/docs/xrefmap.yml
+++ b/docs/xrefmap.yml
@@ -330,6 +330,19 @@ references:
isSpec: "True"
fullName: MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.IKafkaSingletonOptions.UseCompactedReplicator
nameWithType: IKafkaSingletonOptions.UseCompactedReplicator
+- uid: MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.IKafkaSingletonOptions.UseDeletePolicyForTopic
+ name: UseDeletePolicyForTopic
+ href: api/MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.IKafkaSingletonOptions.html#MASES_EntityFrameworkCore_KNet_Infrastructure_Internal_IKafkaSingletonOptions_UseDeletePolicyForTopic
+ commentId: P:MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.IKafkaSingletonOptions.UseDeletePolicyForTopic
+ fullName: MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.IKafkaSingletonOptions.UseDeletePolicyForTopic
+ nameWithType: IKafkaSingletonOptions.UseDeletePolicyForTopic
+- uid: MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.IKafkaSingletonOptions.UseDeletePolicyForTopic*
+ name: UseDeletePolicyForTopic
+ href: api/MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.IKafkaSingletonOptions.html#MASES_EntityFrameworkCore_KNet_Infrastructure_Internal_IKafkaSingletonOptions_UseDeletePolicyForTopic_
+ commentId: Overload:MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.IKafkaSingletonOptions.UseDeletePolicyForTopic
+ isSpec: "True"
+ fullName: MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.IKafkaSingletonOptions.UseDeletePolicyForTopic
+ nameWithType: IKafkaSingletonOptions.UseDeletePolicyForTopic
- uid: MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.IKafkaSingletonOptions.UseNameMatching
name: UseNameMatching
href: api/MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.IKafkaSingletonOptions.html#MASES_EntityFrameworkCore_KNet_Infrastructure_Internal_IKafkaSingletonOptions_UseNameMatching
@@ -698,6 +711,19 @@ references:
isSpec: "True"
fullName: MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaOptionsExtension.UseCompactedReplicator
nameWithType: KafkaOptionsExtension.UseCompactedReplicator
+- uid: MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaOptionsExtension.UseDeletePolicyForTopic
+ name: UseDeletePolicyForTopic
+ href: api/MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaOptionsExtension.html#MASES_EntityFrameworkCore_KNet_Infrastructure_Internal_KafkaOptionsExtension_UseDeletePolicyForTopic
+ commentId: P:MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaOptionsExtension.UseDeletePolicyForTopic
+ fullName: MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaOptionsExtension.UseDeletePolicyForTopic
+ nameWithType: KafkaOptionsExtension.UseDeletePolicyForTopic
+- uid: MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaOptionsExtension.UseDeletePolicyForTopic*
+ name: UseDeletePolicyForTopic
+ href: api/MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaOptionsExtension.html#MASES_EntityFrameworkCore_KNet_Infrastructure_Internal_KafkaOptionsExtension_UseDeletePolicyForTopic_
+ commentId: Overload:MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaOptionsExtension.UseDeletePolicyForTopic
+ isSpec: "True"
+ fullName: MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaOptionsExtension.UseDeletePolicyForTopic
+ nameWithType: KafkaOptionsExtension.UseDeletePolicyForTopic
- uid: MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaOptionsExtension.UseNameMatching
name: UseNameMatching
href: api/MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaOptionsExtension.html#MASES_EntityFrameworkCore_KNet_Infrastructure_Internal_KafkaOptionsExtension_UseNameMatching
@@ -922,6 +948,19 @@ references:
isSpec: "True"
fullName: MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaOptionsExtension.WithTopicConfig
nameWithType: KafkaOptionsExtension.WithTopicConfig
+- uid: MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaOptionsExtension.WithUseDeletePolicyForTopic(System.Boolean)
+ name: WithUseDeletePolicyForTopic(Boolean)
+ href: api/MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaOptionsExtension.html#MASES_EntityFrameworkCore_KNet_Infrastructure_Internal_KafkaOptionsExtension_WithUseDeletePolicyForTopic_System_Boolean_
+ commentId: M:MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaOptionsExtension.WithUseDeletePolicyForTopic(System.Boolean)
+ fullName: MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaOptionsExtension.WithUseDeletePolicyForTopic(System.Boolean)
+ nameWithType: KafkaOptionsExtension.WithUseDeletePolicyForTopic(Boolean)
+- uid: MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaOptionsExtension.WithUseDeletePolicyForTopic*
+ name: WithUseDeletePolicyForTopic
+ href: api/MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaOptionsExtension.html#MASES_EntityFrameworkCore_KNet_Infrastructure_Internal_KafkaOptionsExtension_WithUseDeletePolicyForTopic_
+ commentId: Overload:MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaOptionsExtension.WithUseDeletePolicyForTopic
+ isSpec: "True"
+ fullName: MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaOptionsExtension.WithUseDeletePolicyForTopic
+ nameWithType: KafkaOptionsExtension.WithUseDeletePolicyForTopic
- uid: MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaOptionsExtension.WithUseNameMatching(System.Boolean)
name: WithUseNameMatching(Boolean)
href: api/MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaOptionsExtension.html#MASES_EntityFrameworkCore_KNet_Infrastructure_Internal_KafkaOptionsExtension_WithUseNameMatching_System_Boolean_
@@ -1097,19 +1136,6 @@ references:
isSpec: "True"
fullName: MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaSingletonOptions.KeySerializationType
nameWithType: KafkaSingletonOptions.KeySerializationType
-- uid: MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaSingletonOptions.ProducerByEntity
- name: ProducerByEntity
- href: api/MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaSingletonOptions.html#MASES_EntityFrameworkCore_KNet_Infrastructure_Internal_KafkaSingletonOptions_ProducerByEntity
- commentId: P:MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaSingletonOptions.ProducerByEntity
- fullName: MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaSingletonOptions.ProducerByEntity
- nameWithType: KafkaSingletonOptions.ProducerByEntity
-- uid: MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaSingletonOptions.ProducerByEntity*
- name: ProducerByEntity
- href: api/MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaSingletonOptions.html#MASES_EntityFrameworkCore_KNet_Infrastructure_Internal_KafkaSingletonOptions_ProducerByEntity_
- commentId: Overload:MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaSingletonOptions.ProducerByEntity
- isSpec: "True"
- fullName: MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaSingletonOptions.ProducerByEntity
- nameWithType: KafkaSingletonOptions.ProducerByEntity
- uid: MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaSingletonOptions.ProducerConfig
name: ProducerConfig
href: api/MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaSingletonOptions.html#MASES_EntityFrameworkCore_KNet_Infrastructure_Internal_KafkaSingletonOptions_ProducerConfig
@@ -1162,6 +1188,19 @@ references:
isSpec: "True"
fullName: MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaSingletonOptions.UseCompactedReplicator
nameWithType: KafkaSingletonOptions.UseCompactedReplicator
+- uid: MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaSingletonOptions.UseDeletePolicyForTopic
+ name: UseDeletePolicyForTopic
+ href: api/MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaSingletonOptions.html#MASES_EntityFrameworkCore_KNet_Infrastructure_Internal_KafkaSingletonOptions_UseDeletePolicyForTopic
+ commentId: P:MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaSingletonOptions.UseDeletePolicyForTopic
+ fullName: MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaSingletonOptions.UseDeletePolicyForTopic
+ nameWithType: KafkaSingletonOptions.UseDeletePolicyForTopic
+- uid: MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaSingletonOptions.UseDeletePolicyForTopic*
+ name: UseDeletePolicyForTopic
+ href: api/MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaSingletonOptions.html#MASES_EntityFrameworkCore_KNet_Infrastructure_Internal_KafkaSingletonOptions_UseDeletePolicyForTopic_
+ commentId: Overload:MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaSingletonOptions.UseDeletePolicyForTopic
+ isSpec: "True"
+ fullName: MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaSingletonOptions.UseDeletePolicyForTopic
+ nameWithType: KafkaSingletonOptions.UseDeletePolicyForTopic
- uid: MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaSingletonOptions.UseNameMatching
name: UseNameMatching
href: api/MASES.EntityFrameworkCore.KNet.Infrastructure.Internal.KafkaSingletonOptions.html#MASES_EntityFrameworkCore_KNet_Infrastructure_Internal_KafkaSingletonOptions_UseNameMatching
@@ -1492,6 +1531,19 @@ references:
isSpec: "True"
fullName: MASES.EntityFrameworkCore.KNet.Infrastructure.KafkaDbContext.UseCompactedReplicator
nameWithType: KafkaDbContext.UseCompactedReplicator
+- uid: MASES.EntityFrameworkCore.KNet.Infrastructure.KafkaDbContext.UseDeletePolicyForTopic
+ name: UseDeletePolicyForTopic
+ href: api/MASES.EntityFrameworkCore.KNet.Infrastructure.KafkaDbContext.html#MASES_EntityFrameworkCore_KNet_Infrastructure_KafkaDbContext_UseDeletePolicyForTopic
+ commentId: P:MASES.EntityFrameworkCore.KNet.Infrastructure.KafkaDbContext.UseDeletePolicyForTopic
+ fullName: MASES.EntityFrameworkCore.KNet.Infrastructure.KafkaDbContext.UseDeletePolicyForTopic
+ nameWithType: KafkaDbContext.UseDeletePolicyForTopic
+- uid: MASES.EntityFrameworkCore.KNet.Infrastructure.KafkaDbContext.UseDeletePolicyForTopic*
+ name: UseDeletePolicyForTopic
+ href: api/MASES.EntityFrameworkCore.KNet.Infrastructure.KafkaDbContext.html#MASES_EntityFrameworkCore_KNet_Infrastructure_KafkaDbContext_UseDeletePolicyForTopic_
+ commentId: Overload:MASES.EntityFrameworkCore.KNet.Infrastructure.KafkaDbContext.UseDeletePolicyForTopic
+ isSpec: "True"
+ fullName: MASES.EntityFrameworkCore.KNet.Infrastructure.KafkaDbContext.UseDeletePolicyForTopic
+ nameWithType: KafkaDbContext.UseDeletePolicyForTopic
- uid: MASES.EntityFrameworkCore.KNet.Infrastructure.KafkaDbContext.UsePersistentStorage
name: UsePersistentStorage
href: api/MASES.EntityFrameworkCore.KNet.Infrastructure.KafkaDbContext.html#MASES_EntityFrameworkCore_KNet_Infrastructure_KafkaDbContext_UsePersistentStorage
@@ -1700,6 +1752,19 @@ references:
isSpec: "True"
fullName: MASES.EntityFrameworkCore.KNet.Infrastructure.KafkaDbContextOptionsBuilder.WithKeySerializationType
nameWithType: KafkaDbContextOptionsBuilder.WithKeySerializationType
+- uid: MASES.EntityFrameworkCore.KNet.Infrastructure.KafkaDbContextOptionsBuilder.WithUseDeletePolicyForTopic(System.Boolean)
+ name: WithUseDeletePolicyForTopic(Boolean)
+ href: api/MASES.EntityFrameworkCore.KNet.Infrastructure.KafkaDbContextOptionsBuilder.html#MASES_EntityFrameworkCore_KNet_Infrastructure_KafkaDbContextOptionsBuilder_WithUseDeletePolicyForTopic_System_Boolean_
+ commentId: M:MASES.EntityFrameworkCore.KNet.Infrastructure.KafkaDbContextOptionsBuilder.WithUseDeletePolicyForTopic(System.Boolean)
+ fullName: MASES.EntityFrameworkCore.KNet.Infrastructure.KafkaDbContextOptionsBuilder.WithUseDeletePolicyForTopic(System.Boolean)
+ nameWithType: KafkaDbContextOptionsBuilder.WithUseDeletePolicyForTopic(Boolean)
+- uid: MASES.EntityFrameworkCore.KNet.Infrastructure.KafkaDbContextOptionsBuilder.WithUseDeletePolicyForTopic*
+ name: WithUseDeletePolicyForTopic
+ href: api/MASES.EntityFrameworkCore.KNet.Infrastructure.KafkaDbContextOptionsBuilder.html#MASES_EntityFrameworkCore_KNet_Infrastructure_KafkaDbContextOptionsBuilder_WithUseDeletePolicyForTopic_
+ commentId: Overload:MASES.EntityFrameworkCore.KNet.Infrastructure.KafkaDbContextOptionsBuilder.WithUseDeletePolicyForTopic
+ isSpec: "True"
+ fullName: MASES.EntityFrameworkCore.KNet.Infrastructure.KafkaDbContextOptionsBuilder.WithUseDeletePolicyForTopic
+ nameWithType: KafkaDbContextOptionsBuilder.WithUseDeletePolicyForTopic
- uid: MASES.EntityFrameworkCore.KNet.Infrastructure.KafkaDbContextOptionsBuilder.WithUseNameMatching(System.Boolean)
name: WithUseNameMatching(Boolean)
href: api/MASES.EntityFrameworkCore.KNet.Infrastructure.KafkaDbContextOptionsBuilder.html#MASES_EntityFrameworkCore_KNet_Infrastructure_KafkaDbContextOptionsBuilder_WithUseNameMatching_System_Boolean_