Pulsar GoClient Эквивалент unacked_messages_timeout_ms (py-client)

Question

В Pulsar Python Client есть опция подписчика unacked_messages_timeout_ms для установки интервала, по истечении которого незапакованные сообщения будут доставлены повторно.

Что эквивалентно этому в Pulsar Go Client?

Python

      py_consumer = client.subscribe(
    topic='my-topic',
    subscription_name="py-subscriber",
    unacked_messages_timeout_ms=10000,
    consumer_type=pulsar.ConsumerType.Shared
    )

Голанг

      go_consumer, err := client.Subscribe(
    pulsar.ConsumerOptions{
    Topic: "my-topic",
    SubscriptionName: "go-subscriber",
    Type: pulsar.Shared,
    unacked_messages_timeout_ms ????
})

Здесь я ничего не нашел: https://pkg.go.dev/github.com/apache/pulsar-client-go/pulsar#ConsumerOptions

если его нет, как настроить интервал повторной доставки и какое значение по умолчанию?

Answer 1

«Тайм-аут незапакованных сообщений» - это устаревшая функция, которая была введена очень давно.

Совсем недавно мы добавили концепцию «отрицательных подтверждений», чтобы предоставить приложению простой способ справиться с ошибками при обработке сообщения.

Поскольку клиент Go был написан, когда уже были доступны отрицательные подтверждения, мы решили не вводить в него устаревшую функцию.