[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=16806375#comment-16806375 ] hackerwin7 commented on KAFKA-8106: --- [~wlwolf87] `MaxTimestamp` I think we can not use it to validation

[jira] [Comment Edited] (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=16806363#comment-16806363 ] Ve Lee edited comment on KAFKA-8106 at 4/1/19 3:50 AM: --- {{RecordBatch =>}} {{  

[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=16806363#comment-16806363 ] Ve Lee commented on KAFKA-8106: --- {{RecordBatch =>}} {{  }}{{FirstOffset => int64}} {{  }}{{Length =>

[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=16806352#comment-16806352 ] hackerwin7 commented on KAFKA-8106: --- [~wlwolf87] Currently the the broker decompress to validate record

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16806349#comment-16806349 ] huxihx commented on KAFKA-7965: --- [~enether] Are you still working on this jira? If not, I think I could

[jira] [Comment Edited] (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=16806337#comment-16806337 ] Flower.min edited comment on KAFKA-8106 at 4/1/19 2:52 AM: --- [~hackerwin7]I

[jira] [Comment Edited] (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=16806337#comment-16806337 ] Flower.min edited comment on KAFKA-8106 at 4/1/19 2:45 AM: --- [~hackerwin7]I

[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=16806337#comment-16806337 ] Flower.min commented on KAFKA-8106: --- [~hackerwin7]I agree with idea of [~qiaochao911] , Maybe we can

[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=16806336#comment-16806336 ] Ve Lee commented on KAFKA-8106: --- [~hackerwin7] First, you have to be clear that the parameters of 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=16806334#comment-16806334 ] Flower.min commented on KAFKA-8106: --- [~junrao] Of course,we need read timestamp and offset from record

[jira] [Commented] (KAFKA-4600) Consumer proceeds on when ConsumerRebalanceListener fails

[ https://issues.apache.org/jira/browse/KAFKA-4600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16806293#comment-16806293 ] Dana Powers commented on KAFKA-4600: Right on. I've read that PR several times and fail to see how it

[jira] [Commented] (KAFKA-4600) Consumer proceeds on when ConsumerRebalanceListener fails

[ https://issues.apache.org/jira/browse/KAFKA-4600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16806244#comment-16806244 ] Guozhang Wang commented on KAFKA-4600: -- NPE inside KafkaStreams is just another observation of the

[jira] [Commented] (KAFKA-4600) Consumer proceeds on when ConsumerRebalanceListener fails

[ https://issues.apache.org/jira/browse/KAFKA-4600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16806240#comment-16806240 ] Dana Powers commented on KAFKA-4600: I don't think KAFKA-5154 is related to this issue. But maybe I'm

[jira] [Commented] (KAFKA-4600) Consumer proceeds on when ConsumerRebalanceListener fails

[ https://issues.apache.org/jira/browse/KAFKA-4600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16806234#comment-16806234 ] Guozhang Wang commented on KAFKA-4600: -- Hello [~dana.powers] The root cause is around when we should

[jira] [Commented] (KAFKA-8147) Add changelog topic configuration to KTable suppress

[ https://issues.apache.org/jira/browse/KAFKA-8147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16806221#comment-16806221 ] Maarten commented on KAFKA-8147: The version published now is short, but should be complete. I need some

[jira] [Created] (KAFKA-8178) KafkaProducer#send(ProducerRecord,Callback) may block for up to 60 seconds

Sergei Egorov created KAFKA-8178: Summary: KafkaProducer#send(ProducerRecord,Callback) may block for up to 60 seconds Key: KAFKA-8178 URL: https://issues.apache.org/jira/browse/KAFKA-8178 Project:

[jira] [Resolved] (KAFKA-7502) Cleanup KTable materialization logic in a single place

[ https://issues.apache.org/jira/browse/KAFKA-7502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin resolved KAFKA-7502. Resolution: Fixed > Cleanup KTable materialization logic in a single place >