Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-28084

Pulsar unordered reader should disable retry and delete reconsume logic.

    XMLWordPrintableJSON

Details

    Description

      UnroderdPulsarSourceReader currently calls reconsume, but this feature relys on retry topic. But if retry topic is enabled the initial search will only support earliest and lates (because it will be a multiconsumer impl). We plan to delete the reconsume logic to get rid of dependency on retry topic and should disable retry.

      Attachments

        Issue Links

          Activity

            People

              syhily Yufan Sheng
              syhily Yufan Sheng
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: