int? DefaultConsumerInstances { get; }| Type | +Description | +
|---|---|
| Nullable<Int32> | ++ |
bool UseCompactedReplicator { get; }| Type | +Description | +
|---|---|
| Boolean | ++ |
public virtual int? DefaultConsumerInstances { get; }| Type | +Description | +
|---|---|
| Nullable<Int32> | ++ |
public virtual bool UseCompactedReplicator { get; }| Type | +Description | +
|---|---|
| Boolean | ++ |
public virtual KafkaOptionsExtension WithCompactedReplicator(bool useCompactedReplicator = false)| Type | +Name | +Description | +
|---|---|---|
| Boolean | +useCompactedReplicator | ++ |
| Type | +Description | +
|---|---|
| KafkaOptionsExtension | ++ |
public virtual KafkaOptionsExtension WithDefaultConsumerInstances(int? defaultConsumerInstances = null)| Type | +Name | +Description | +
|---|---|---|
| Nullable<Int32> | +defaultConsumerInstances | ++ |
| Type | +Description | +
|---|---|
| KafkaOptionsExtension | ++ |
public virtual int? DefaultConsumerInstances { get; }| Type | +Description | +
|---|---|
| Nullable<Int32> | ++ |
public virtual bool UseCompactedReplicator { get; }| Type | +Description | +
|---|---|
| Boolean | ++ |
public class KafkaDbContext : DbContextpublic KafkaDbContext()public KafkaDbContext(DbContextOptions options)| Type | +Name | +Description | +
|---|---|---|
| DbContextOptions | +options | ++ |
public string ApplicationId { get; set; }public virtual string ApplicationId { get; set; }Database consumr instances used in conjunction with UseCompactedReplicator
+public virtual int? DefaultConsumerInstances { get; set; }| Type | +Description | +
|---|---|
| Nullable<Int32> | ++ |
public int DefaultNumPartitions { get; set; }public virtual int DefaultNumPartitions { get; set; }Use MASES.KNet.Replicator.KNetCompactedReplicator`2 instead of Apache Kafka Streams
+public virtual bool UseCompactedReplicator { get; set; }| Type | +Description | +
|---|---|
| Boolean | ++ |
public bool UsePersistentStorage { get; set; }public virtual bool UsePersistentStorage { get; set; }| Type | +Name | +Description | +
|---|---|---|
| Boolean | +useCompactedReplicator | +If true then MASES.KNet.Replicator.KNetCompactedReplicator`2 will be used instead of Apache Kafka Streams. + |
+
| Type | +Description | +
|---|---|
| KafkaDbContextOptionsBuilder | +The same builder instance so that multiple calls can be chained. + |
+
See Using DbContextOptions, and +The EF Core Kafka database provider for more information and examples.
+Defines the default number of consumer instances to be used in conjunction with WithCompactedReplicator(Boolean)
+public virtual KafkaDbContextOptionsBuilder WithDefaultConsumerInstances(int? defaultConsumerInstances = null)| Type | +Name | +Description | +
|---|---|---|
| Nullable<Int32> | +defaultConsumerInstances | +The default number of consumer instances to be used in conjunction with WithCompactedReplicator(Boolean) + |
+
| Type | +Description | +
|---|---|
| KafkaDbContextOptionsBuilder | +The same builder instance so that multiple calls can be chained. + |
+
See Using DbContextOptions, and +The EF Core Kafka database provider for more information and examples.
public static int? ConsumerInstances(this IEntityType entityType, KafkaOptionsExtension options)| Type | +Name | +Description | +
|---|---|---|
| IEntityType | +entityType | ++ |
| KafkaOptionsExtension | +options | ++ |
| Type | +Description | +
|---|---|
| Nullable<Int32> | ++ |
object[] Deserialize(string arg)| Type | +Name | +Description | +
|---|---|---|
| String | +arg | ++ |
| Type | +Description | +
|---|---|
| Object[] | ++ |
TKey Deserialize<TKey>(string arg)| Type | +Name | +Description | +
|---|---|---|
| String | +arg | ++ |
| Type | +Description | +
|---|---|
| TKey | ++ |
| Name | +Description | +
|---|---|
| TKey | ++ |
string Serialize(params object[] args)| Type | +Name | +Description | +
|---|---|---|
| Object[] | +args | ++ |
| Type | +Description | +
|---|---|
| String | ++ |
string Serialize<TKey>(TKey key)| Type | +Name | +Description | +
|---|---|---|
| TKey | +key | ++ |
| Type | +Description | +
|---|---|
| String | ++ |
| Name | +Description | +
|---|---|
| TKey | ++ |
public object[] Deserialize(string arg)| Type | +Name | +Description | +
|---|---|---|
| String | +arg | ++ |
| Type | +Description | +
|---|---|
| Object[] | ++ |
public TKey Deserialize<TKey>(string arg)| Type | +Name | +Description | +
|---|---|---|
| String | +arg | ++ |
| Type | +Description | +
|---|---|
| TKey | ++ |
| Name | +Description | +
|---|---|
| TKey | ++ |
public string Serialize(params object[] args)| Type | +Name | +Description | +
|---|---|---|
| Object[] | +args | ++ |
| Type | +Description | +
|---|---|
| String | ++ |
public string Serialize<TKey>(TKey key)| Type | +Name | +Description | +
|---|---|---|
| TKey | +key | ++ |
| Type | +Description | +
|---|---|
| String | ++ |
| Name | +Description | +
|---|---|
| TKey | ++ |
IKNetCompactedReplicator<string, string> CreateCompactedReplicator(IEntityType entityType)| Type | +Name | +Description | +
|---|---|---|
| IEntityType | +entityType | ++ |
| Type | +Description | +
|---|---|
| MASES.KNet.Replicator.IKNetCompactedReplicator<String, String> | ++ |
IEnumerable<Future<RecordMetadata>> Commit(IEnumerable<ProducerRecord<string, string>> records)IEnumerable<Future<RecordMetadata>> Commit(IEnumerable<IKafkaRowBag> records)| IEnumerable<Org.Apache.Kafka.Clients.Producer.ProducerRecord<String, String>> | +IEnumerable<IKafkaRowBag> | records |
| Org.Apache.Kafka.Clients.Producer.ProducerRecord<String, String> | +IKafkaRowBag |
| Org.Apache.Kafka.Clients.Producer.ProducerRecord<String, String> | +IKafkaRowBag |
| Org.Apache.Kafka.Clients.Producer.ProducerRecord<String, String> | +IKafkaRowBag |
public virtual IKNetCompactedReplicator<string, string> CreateCompactedReplicator(IEntityType entityType)| Type | +Name | +Description | +
|---|---|---|
| IEntityType | +entityType | ++ |
| Type | +Description | +
|---|---|
| MASES.KNet.Replicator.IKNetCompactedReplicator<String, String> | ++ |
public virtual void Dispose()public void Dispose()public virtual IEnumerable<Future<RecordMetadata>> Commit(IEnumerable<ProducerRecord<string, string>> records)public virtual IEnumerable<Future<RecordMetadata>> Commit(IEnumerable<IKafkaRowBag> records)| System.Collections.IEnumerable<Org.Apache.Kafka.Clients.Producer.ProducerRecord<String, String>> | +System.Collections.IEnumerable<IKafkaRowBag> | records |
| Org.Apache.Kafka.Clients.Producer.ProducerRecord<String, String> | +IKafkaRowBag |
| Org.Apache.Kafka.Clients.Producer.ProducerRecord<String, String> | +IKafkaRowBag |
public virtual void Dispose()public virtual ProducerRecord<string, string> Update(IUpdateEntry entry)public virtual IKafkaRowBag Update(IUpdateEntry entry)| Org.Apache.Kafka.Clients.Producer.ProducerRecord<String, String> | +IKafkaRowBag |