Class KafkaTransportOptions
Namespace: Cephalon.Behaviors.Messaging.Options
Assembly: Cephalon.Behaviors.Messaging.dll
Configuration options for the Kafka messaging transport binding.
public sealed class KafkaTransportOptionsInheritance
Section titled “Inheritance”object ← KafkaTransportOptions
Inherited Members
Section titled “Inherited Members”object.Equals(object?), object.Equals(object?, object?), object.GetHashCode(), object.GetType(), object.ReferenceEquals(object?, object?), object.ToString()
Properties
Section titled “Properties”AutoOffsetReset
Section titled “ AutoOffsetReset”Gets or sets the auto offset reset policy applied when no committed offset exists.
Default:
public AutoOffsetReset AutoOffsetReset { get; set; }Property Value
Section titled “Property Value”AutoOffsetReset
BootstrapServers
Section titled “ BootstrapServers”Gets or sets the Kafka bootstrap servers (comma-separated host:port pairs).
Default: “localhost:9092”.
public string BootstrapServers { get; set; }Property Value
Section titled “Property Value”EnableAutoCommit
Section titled “ EnableAutoCommit”Gets or sets a value indicating whether Kafka auto-commit is enabled. Default: false — offsets are committed manually after successful dispatch.
public bool EnableAutoCommit { get; set; }Property Value
Section titled “Property Value”GroupId
Section titled “ GroupId”Gets or sets the consumer group id. Default: “cephalon-behaviors”.
public string GroupId { get; set; }Property Value
Section titled “Property Value”Gets or sets the Kafka topic to subscribe to. When null, defaults to the behavior id.
public string? Topic { get; set; }