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

FlinkKafkaInternalProducer should be @Internal annotation ?

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Reopened
    • Not a Priority
    • Resolution: Unresolved
    • 1.11.2
    • None
    • Connectors / Kafka
    • None

    Description

      Hello,

      Seems like [ FlinkKafkaInternalProducer|https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/FlinkKafkaInternalProducer.java] should be marked as @Internal instead of @PublicEvolving?

      If it should be modified, I would be happy to make the change.

      Thank you for the clarification!

      Attachments

        Issue Links

          is a clone of

          Improvement - An improvement or enhancement to an existing feature or task. FLINK-19591 Missing @Internal annotation SimpleJdbcConnectionProvider

          • Minor - Minor loss of function, or other problem where easy workaround is present.
          • Closed

          Activity

            People

              Unassigned Unassigned
              klden Kenzyme Le
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated: