Чтение из PubSubIO: от темы против подписки

Question

Я видел в каком-то примере код, который, кажется, читает непосредственно из темы?

PubsubIO.readStrings().fromTopic(fullTopic))

Есть ли различия между этим и

PubsubIO.readStrings().fromSubscription(fullTopic))

(у меня всегда было впечатление, что вам нужна подписка на тему ...)

edit: добавление ссылки на пример с использованием fromTopic

Answer 1

Да, есть различия. Обратите внимание, что метод fromSubscription принимает путь к подписке, а не путь к теме. Если использовать fromTopic, то будет создана новая подписка. В результате любые сообщения, опубликованные до запуска кода, не будут прочитаны. Новая подписка также будет создаваться при каждом запуске кода.

Напротив, fromSubscription использует существующую подписку, что означает, что сообщения, опубликованные в любое время после создания подписки, будут прочитаны. Если задание останавливается и возвращается, считывание может продолжаться с того места, на котором оно было остановлено.