我怎样才能阅读所有主题？

Question

当我创建消费者时

consumer = pulsar.Client(
            PULSAR_URL,
            authentication=AuthenticationOauth2(params)
        ).subscribe(
            topic=PULSAR_TOPIC,
            subscription_name=PULSAR_SUBSCRIPTION_NAME
        )

无法从头读取所有消息，也无法读取所有未读取的消息，只能读取创建消费者后创建的消息。

问题是关于如何设置消费者以便阅读之前所有未读的消息。

谢谢

Answer 1

可以在subscribe方法中指定initial_position来设置消费者订阅主题时的初始位置。它可以是：InitialPosition.Earliest 或 InitialPosition.Latest。默认值：最新

所以在你的情况下，如果你想从最早的可用消息开始，那么你会想要这样的东西：

consumer = pulsar.Client(
        PULSAR_URL,
        authentication=AuthenticationOauth2(params)
    ).subscribe(
        topic=PULSAR_TOPIC,
        subscription_name=PULSAR_SUBSCRIPTION_NAME,
        initial_position=InitialPosition.Earliest
    )

希望对您有所帮助！

我怎样才能阅读所有主题？

How can I read all topic?

python

apache-pulsar

pulsar

python-pulsar