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

Document FlinkKafkaProducer behaviour for Kafka versions > 0.11

    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Closed
    • Priority: Minor
    • Resolution: Fixed
    • Affects Version/s: 1.5.0
    • Fix Version/s: None
    • Component/s: Connectors / Kafka
    • Labels:
      None

      Description

      FlinkKafkaProducer for Kafka 0.11 uses reflection to work around API limitations of the Kafka client. Using reflection breaks with newer versions of the Kafka client (due to internal changes of the client).

      The documentation does not mention newer Kafka versions. We should add the following notes:

      • Only package Kafka connector with kafka.version property set to 0.11..
      • Mention that it is possible to use the 0.11 connector with newer versions of Kafka as the protocol seems to be backwards compatible (double check that this is correct)

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                xleesf leesf
                Reporter:
                uce Ufuk Celebi
              • Votes:
                0 Vote for this issue
                Watchers:
                5 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: