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

The example provided in the kafkaSource documentation for topic regex subscription is incorrect

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Open
    • Major
    • Resolution: Unresolved
    • 1.20.0
    • None
    • Documentation

    Description

      https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/connectors/datastream/kafka/#topic-partition-subscription

       

      The example provided in the document has issues and will result in a compilation error. The correct example should be:

      // code placeholder
      // KafkaSource
      KafkaSource.builder().setTopicPattern(Pattern.compile("topic.*"));

      Attachments

        1. image-2024-06-18-17-47-53-525.png
          66 kB
          elon_X
        2. image-2024-06-18-17-48-38-080.png
          119 kB
          elon_X
        3. image-2024-06-18-18-41-41-212.png
          66 kB
          elon_X
        4. image-2024-06-18-18-41-53-593.png
          66 kB
          elon_X

        Issue Links

          Activity

            People

              Unassigned Unassigned
              elon elon_X
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated: