...
| Code Block | ||
|---|---|---|
| ||
var _producerConfig = new ProducerConfig
{
BootstrapServers = bootstrapServer, // initiates list of brokers
EnableDeliveryReports = true, //enabled notifications to delivery reports
ClientId = Dns.GetHostName(), // client identifier
// retry settings:
Acks = Acks.All, // Receive acknowledgement from all sync replicas
MessageSendMaxRetries = 3, // Number of times to retry before giving up
RetryBackoffMs = 1000, // Duration to retry before next attempt
// Set to true if you don't want to reorder messages on retry
EnableIdempotence = true
}; |
ConsumerConfig Object has to be instantiated with the proper settings to build a reliable consumer.
| Code Block | ||
|---|---|---|
| ||
var _consumerConfig = new ConsumerConfig
{
BootstrapServers = bootstrapServer,// initiates list of brokers
EnableAutoCommit = false, // No Automatically and periodically commit offsets in the background.
EnableAutoOffsetStore = false,//No Automatically store offset of last message provided to application
MaxPollIntervalMs = 300000,//Maximum allowed time between calls to consume messages
GroupId = "default",
// Read messages from start if no commit exists.
AutoOffsetReset = AutoOffsetReset.Earliest
}; |