Public API

Ksql.Linq Public API (current)

Derived from PublicAPI.Shipped/Unshipped. Types + members (properties/methods/fields).

Ksql.Linq.Configuration.Abstractions.KafkaSubscriptionOptions

• Ksql.Linq.Configuration.Abstractions.KafkaSubscriptionOptions.#ctor

Ksql.Linq.Configuration.DefaultValueBinder

• Ksql.Linq.Configuration.DefaultValueBinder.ApplyDefaults(System.Object)

Ksql.Linq.Configuration.Messaging.ConsumerSection

• Ksql.Linq.Configuration.Messaging.ConsumerSection.AdditionalProperties
• Ksql.Linq.Configuration.Messaging.ConsumerSection.AutoCommitIntervalMs
• Ksql.Linq.Configuration.Messaging.ConsumerSection.AutoOffsetReset
• Ksql.Linq.Configuration.Messaging.ConsumerSection.EnableAutoCommit
• Ksql.Linq.Configuration.Messaging.ConsumerSection.FetchMaxBytes
• Ksql.Linq.Configuration.Messaging.ConsumerSection.FetchMaxWaitMs
• Ksql.Linq.Configuration.Messaging.ConsumerSection.FetchMinBytes
• Ksql.Linq.Configuration.Messaging.ConsumerSection.GroupId
• Ksql.Linq.Configuration.Messaging.ConsumerSection.HeartbeatIntervalMs
• Ksql.Linq.Configuration.Messaging.ConsumerSection.IsolationLevel
• Ksql.Linq.Configuration.Messaging.ConsumerSection.MaxPollIntervalMs
• Ksql.Linq.Configuration.Messaging.ConsumerSection.MaxPollRecords
• Ksql.Linq.Configuration.Messaging.ConsumerSection.PartitionAssignmentStrategy
• Ksql.Linq.Configuration.Messaging.ConsumerSection.SessionTimeoutMs

Ksql.Linq.Configuration.Messaging.ProducerSection

• Ksql.Linq.Configuration.Messaging.ProducerSection.Acks
• Ksql.Linq.Configuration.Messaging.ProducerSection.AdditionalProperties
• Ksql.Linq.Configuration.Messaging.ProducerSection.BatchNumMessages
• Ksql.Linq.Configuration.Messaging.ProducerSection.BatchSize
• Ksql.Linq.Configuration.Messaging.ProducerSection.BufferMemory
• Ksql.Linq.Configuration.Messaging.ProducerSection.CompressionType
• Ksql.Linq.Configuration.Messaging.ProducerSection.DeliveryTimeoutMs
• Ksql.Linq.Configuration.Messaging.ProducerSection.EnableIdempotence
• Ksql.Linq.Configuration.Messaging.ProducerSection.LingerMs
• Ksql.Linq.Configuration.Messaging.ProducerSection.MaxInFlightRequestsPerConnection
• Ksql.Linq.Configuration.Messaging.ProducerSection.Partitioner
• Ksql.Linq.Configuration.Messaging.ProducerSection.Retries
• Ksql.Linq.Configuration.Messaging.ProducerSection.RetryBackoffMs

Ksql.Linq.Configuration.Messaging.TopicCreationSection

• Ksql.Linq.Configuration.Messaging.TopicCreationSection.Configs
• Ksql.Linq.Configuration.Messaging.TopicCreationSection.EnableAutoCreation
• Ksql.Linq.Configuration.Messaging.TopicCreationSection.NumPartitions
• Ksql.Linq.Configuration.Messaging.TopicCreationSection.ReplicationFactor

Ksql.Linq.Configuration.Messaging.TopicSection

• Ksql.Linq.Configuration.Messaging.TopicSection.Consumer
• Ksql.Linq.Configuration.Messaging.TopicSection.Creation
• Ksql.Linq.Configuration.Messaging.TopicSection.Producer
• Ksql.Linq.Configuration.Messaging.TopicSection.TopicName

Ksql.Linq.Core.Abstractions.DeserializationErrorPolicy

• Ksql.Linq.Core.Abstractions.DeserializationErrorPolicy.DLQ
• Ksql.Linq.Core.Abstractions.DeserializationErrorPolicy.Retry
• Ksql.Linq.Core.Abstractions.DeserializationErrorPolicy.Skip

Ksql.Linq.Core.Abstractions.EntityAccessMode

• Ksql.Linq.Core.Abstractions.EntityAccessMode.ReadOnly
• Ksql.Linq.Core.Abstractions.EntityAccessMode.ReadWrite
• Ksql.Linq.Core.Abstractions.EntityAccessMode.WriteOnly

Ksql.Linq.KsqlDbResponse

• Ksql.Linq.KsqlDbResponse.ErrorCode
• Ksql.Linq.KsqlDbResponse.ErrorDetail
• Ksql.Linq.KsqlDbResponse.IsSuccess
• Ksql.Linq.KsqlDbResponse.Message