Details
-
Task
-
Status: Closed
-
Minor
-
Resolution: Fixed
-
None
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
- links to