def METHOD_NAME():
    """Test consuming simple messages from a Pulsar topic with PulsarIODataset.
    NOTE: After the pulsar standalone is setup during the testing phase, 6 messages
    (D0, D1, ..., D5) are sent to the `test` topic.
    """
    dataset = tfio.experimental.streaming.PulsarIODataset(
        service_url="pulsar://localhost:6650",
        topic="test",
        subscription="subscription-0",
        timeout=default_pulsar_timeout,
    )
    assert np.all(
        [k.numpy() for (k, _) in dataset] == [("D" + str(i)).encode() for i in range(6)]
    )