Uploaded image for project: 'Apache Hudi'
  1. Apache Hudi
  2. HUDI-1062

Remove unnecessary maxEvent check and add some log in KafkaOffsetGen

    XMLWordPrintableJSON

Details

    Description

      //code
      maxEventsToReadFromKafka = (maxEventsToReadFromKafka == Long.MAX_VALUE || maxEventsToReadFromKafka == Integer.MAX_VALUE)
          ? Config.maxEventsFromKafkaSource : maxEventsToReadFromKafka;
      

      this line is unnecessary, we‘d better remove it.

      besides, when the source limit is not configured, it will take maxEventsToReadFromKafka(50M) as the default value, we can give a log to notify the user.

      Attachments

        Issue Links

          Activity

            People

              Trevorzhang Trevorzhang
              wangxianghu#1 wangxianghu#1
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: