[jira] [Commented] (KAFKA-8106) Remove unnecessary decompression operation when logValidator do validation.

[ https://issues.apache.org/jira/browse/KAFKA-8106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16806375#comment-16806375 ] hackerwin7 commented on KAFKA-8106: --- [~wlwolf87] `MaxTimestamp` I think we can not use

[jira] [Commented] (KAFKA-8106) Remove unnecessary decompression operation when logValidator do validation.

[ https://issues.apache.org/jira/browse/KAFKA-8106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16806363#comment-16806363 ] Ve Lee commented on KAFKA-8106: --- {{RecordBatch =>}} {{  }}{{FirstOffset => int64}} {{  }}{{

[jira] [Commented] (KAFKA-8106) Remove unnecessary decompression operation when logValidator do validation.

[ https://issues.apache.org/jira/browse/KAFKA-8106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16806352#comment-16806352 ] hackerwin7 commented on KAFKA-8106: --- [~wlwolf87] Currently the the broker decompress to

[jira] [Commented] (KAFKA-8106) Remove unnecessary decompression operation when logValidator do validation.

[ https://issues.apache.org/jira/browse/KAFKA-8106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16806337#comment-16806337 ] Flower.min commented on KAFKA-8106: --- [~hackerwin7]I agree with idea of [~qiaochao911] ,

[jira] [Commented] (KAFKA-8106) Remove unnecessary decompression operation when logValidator do validation.

[ https://issues.apache.org/jira/browse/KAFKA-8106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16806336#comment-16806336 ] Ve Lee commented on KAFKA-8106: --- [~hackerwin7] First, you have to be clear that the paramet

[jira] [Commented] (KAFKA-8106) Remove unnecessary decompression operation when logValidator do validation.

[ https://issues.apache.org/jira/browse/KAFKA-8106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16806334#comment-16806334 ] Flower.min commented on KAFKA-8106: --- [~junrao] Of course,we need read timestamp and off

[jira] [Commented] (KAFKA-8106) Remove unnecessary decompression operation when logValidator do validation.

[ https://issues.apache.org/jira/browse/KAFKA-8106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16805757#comment-16805757 ] hackerwin7 commented on KAFKA-8106: --- [~junrao], can we batches for this to prevent the

[jira] [Commented] (KAFKA-8106) Remove unnecessary decompression operation when logValidator do validation.

[ https://issues.apache.org/jira/browse/KAFKA-8106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16805539#comment-16805539 ] Jun Rao commented on KAFKA-8106: [~Flower.min], one of the validation that the broker has

[jira] [Commented] (KAFKA-8106) Remove unnecessary decompression operation when logValidator do validation.

[ https://issues.apache.org/jira/browse/KAFKA-8106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16804532#comment-16804532 ] hackerwin7 commented on KAFKA-8106: --- Maybe we can put the record level validation to cl

[jira] [Commented] (KAFKA-8106) Remove unnecessary decompression operation when logValidator do validation.

[ https://issues.apache.org/jira/browse/KAFKA-8106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16804003#comment-16804003 ] hackerwin7 commented on KAFKA-8106: --- The `validateRecord()` is placed in every branch o

[jira] [Commented] (KAFKA-8106) Remove unnecessary decompression operation when logValidator do validation.

[ https://issues.apache.org/jira/browse/KAFKA-8106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16799597#comment-16799597 ] qiaochao commented on KAFKA-8106: - In the scene of inPlaceAssignment,I think the server s

[jira] [Commented] (KAFKA-8106) Remove unnecessary decompression operation when logValidator do validation.

[ https://issues.apache.org/jira/browse/KAFKA-8106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16797927#comment-16797927 ] Flower.min commented on KAFKA-8106: --- _*We only don't decompress key and value of a reco

[jira] [Commented] (KAFKA-8106) Remove unnecessary decompression operation when logValidator do validation.

[ https://issues.apache.org/jira/browse/KAFKA-8106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16797016#comment-16797016 ] Flower.min commented on KAFKA-8106: --- we suggest that removing unnecessary decompression

[jira] [Commented] (KAFKA-8106) Remove unnecessary decompression operation when logValidator do validation.

[ https://issues.apache.org/jira/browse/KAFKA-8106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16795714#comment-16795714 ] Manikumar commented on KAFKA-8106: -- [~Flower.min] Instructions for the submitting code

[jira] [Commented] (KAFKA-8106) Remove unnecessary decompression operation when logValidator do validation.

[ https://issues.apache.org/jira/browse/KAFKA-8106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16795688#comment-16795688 ] Flower.min commented on KAFKA-8106: ---  We do performance testing again with package

[jira] [Commented] (KAFKA-8106) Remove unnecessary decompression operation when logValidator do validation.

[ https://issues.apache.org/jira/browse/KAFKA-8106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16794193#comment-16794193 ] Flower.min commented on KAFKA-8106: --- I and My team modify some code of Kafka  and I nee