Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-15819 Add more StateFun Kafka ingress features that are already available in FlinkKafkaConsumer
  3. FLINK-15821

Allow configuring Kafka partition / topic discovery in StateFun Kafka ingress

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Closed
    • Major
    • Resolution: Duplicate
    • statefun-2.0.0
    • None
    • Stateful Functions

    Description

      This is already implemented in the FlinkKafkaConsumer, so it would only be a matter of exposing it through Stateful Function's Kafka ingress.

      Proposed API:

      KafkaIngressBuilder#withTopics(java.util.regex.Pattern regexPattern)
KafkaIngressBuilder#enableDiscovery(java.time.Duration discoveryInterval)

      Attachments

        Issue Links

          is duplicated by

          Improvement - An improvement or enhancement to an existing feature or task. FLINK-22554 Support Kafka Topic Patterns in Kafka Ingress

          • Not a Priority -
          • Open

          Activity

            People

              Unassigned Unassigned
              tzulitai Tzu-Li (Gordon) Tai
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: