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

Non-null check for bootstrapServers field is incorrect in KafkaSink

    XMLWordPrintableJSON

Details

    Description

      If the user-supplied kafkaProducerConfig contains bootstrapServers information, there is no need to define the value of this field separately through the setBootstrapServers method. Obviously, the current code doesn't notice this.

       

      Perhaps we can check bootstrapServers as follows:

       

      Or check bootstrapServers like KafkaSourceBuilder.

       

       

      Attachments

        1. image-2022-04-11-18-11-18-576.png
          214 kB
          Zhengqi Zhang
        2. image-2022-04-11-18-17-48-514.png
          223 kB
          Zhengqi Zhang

        Issue Links

          Activity

            People

              Tony Giao Zhengqi Zhang
              Tony Giao Zhengqi Zhang
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: