Что такое свойство Ackdeadline на подписке и AckDeadline на подписчике в GCP Pub/sub? ⇐ C#

[Anonymous]

Я пытаюсь понять разницу между свойством Ackdeadlin в подписке и свойством Ackdeadline на подписчике. Понятно, что Ackdeadline на подписке - это период времени, после чего подписка будет отправлять сообщение подписчику. Минимальное значение составляет 10s по подписке. Я не могу понять семантику Ackdeadline на подписчике. К вашему сведению, мой использование включает в себя получение сообщения и размещение сообщений на тему Kafka. Мне все равно, если я не обрабатываю все сообщения. Мне нужно обработать последний набор сообщений, и я не знаю, является ли это устаревшим или последним сообщением без сначала разбора сообщений. Я не хочу увеличивать ackdeadline и хочу игнорировать/отбросить сообщение, если мой подписчик отстает. Спасибо! < /P>
Я попытался исследовать разницу между ackdeadline по подписке и подписчиком. Я все еще смущен, каким должно быть ценность на каждом. Моя подписка имеет следующие настройки: < /p>
public static async Task CreateSubscription(string CmeProjectId, string Topic, SubscriptionName SubscriptionId)
{
SubscriberServiceApiClient subscriberService = await SubscriberServiceApiClient.CreateAsync();
TopicName topicName = TopicName.FromProjectTopic(CmeProjectId, Topic);
try
{
//Please read common subscription properties: https://cloud.google.com/pubsub/docs/su ... properties
var subscriptionRequest = new Subscription
{
SubscriptionName = SubscriptionId,
TopicAsTopicName = topicName,
//How long are unacked messages stored. Default = 7 days, minimum = 10 minutes.
MessageRetentionDuration = new Duration
{
Seconds = (long)TimeSpan.FromMinutes(10).TotalSeconds
},
//How long do Subscriptions survive without any activity. Default value = 31 days, minimum value = 1 day
ExpirationPolicy = new ExpirationPolicy
{
Ttl = Duration.FromTimeSpan(TimeSpan.FromDays(1))
},
/*
Create a deadletter queue to discard messages if message was not ackd after 5 retries.
Do not attach a subscription to dead letter queue as we want to drop stale messages and not store them.
MaxDelivery attempts has a minimum value of 5.
*/
DeadLetterPolicy = new DeadLetterPolicy
{
MaxDeliveryAttempts = 5,
DeadLetterTopic = TopicName.FromProjectTopic(MAREX_PROJECT_ID, "dead-letter-topic").ToString()
},
//Process the message exactly once.
//Messages are not redelivered if message is acked or when message is outstanding (https://cloud.google.com/pubsub/docs/ex ... e-delivery)
EnableExactlyOnceDelivery = true
};
await subscriberService.CreateSubscriptionAsync(subscriptionRequest);
}
catch (RpcException e) when (e.Status.StatusCode == StatusCode.AlreadyExists)
{
Console.WriteLine("Subscription already exists!");
}

return subscriberService;
}
< /code>
Подписчик является следующим: < /p>
public static async Task CreateSubscriber(SubscriptionName subscriptionId)
{
SubscriberClient subscriber = await new SubscriberClientBuilder
{
SubscriptionName = subscriptionId,
Settings = new SubscriberClient.Settings
{
//Lease time before which a message must either be acknowledged or have its lease extended.
AckDeadline = TimeSpan.FromSeconds(10),

//Number of outstanding messages after which subscription won't send any messages.
//Total byte count of all outstanding messages that won't fill up available memory.
FlowControlSettings = new FlowControlSettings(maxOutstandingElementCount: 50000, maxOutstandingByteCount: 50000 * 560)
}
}.BuildAsync();
return subscriber;
}


Подробнее здесь: https://stackoverflow.com/questions/794 ... bscriber-i