wj1918 edited a comment on pull request #8612: URL: https://github.com/apache/kafka/pull/8612#issuecomment-631579687
call for reviewers @kkonstantine @phstudy @ewencp @hachikuji should have separate commit of refactoring and bug fix. Major change block of FileStreamSourceTask.java line 66-71 : moved to FileStreamBuffer.setFilename and FileStreamBuffer.ensureOpen line 124-129: removed. poll is single threaded for this type of task. line 133-143: moved to FileStreamBuffer.extractLine ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
