Я изучил политики истечения срока действия и TTL для сообщений и очередей, но не уверен, что это лучший способ выполнить то, что я пытаюсь сделать.
В идеале, когда мой потребитель подключается к моему отправителю, я хочу пропустить все старые, непринятые сообщения и получать только сообщения, отправленные после подключения. В Kafka это было достигнуто путем настройки потребителя на поиск очереди до конца, прежде чем начать потребление большего количества сообщений. Прямого эквивалента RabbitMQ для этой функции, похоже, не существовало, но я должен представить, что есть более эффективный способ добиться этого, не делая TTL или истечение срока для сообщений очень короткими.
Как использовать только сообщения, полученные после подключения к производителю RabbitMQ?
