[jira] [Updated] (KAFKA-8270) Kafka retention hour is not working

[ https://issues.apache.org/jira/browse/KAFKA-8270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangtao Liu updated KAFKA-8270: Description: Kafka log cannot be deleted after the configured retention hours (12 hours for log

[jira] [Updated] (KAFKA-8270) Kafka retention hour is not working

[ https://issues.apache.org/jira/browse/KAFKA-8270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangtao Liu updated KAFKA-8270: Priority: Major (was: Critical) > Kafka retention hour is not working >

[jira] [Updated] (KAFKA-8270) Kafka retention hour is not working

[ https://issues.apache.org/jira/browse/KAFKA-8270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangtao Liu updated KAFKA-8270: Issue Type: Bug (was: Improvement) > Kafka retention hour is not working >

[jira] [Updated] (KAFKA-8270) Kafka retention hour is not working

[ https://issues.apache.org/jira/browse/KAFKA-8270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangtao Liu updated KAFKA-8270: Component/s: (was: consumer) log > Kafka retention hour is not working >

[jira] [Created] (KAFKA-8270) Kafka retention hour is not working

Jiangtao Liu created KAFKA-8270: --- Summary: Kafka retention hour is not working Key: KAFKA-8270 URL: https://issues.apache.org/jira/browse/KAFKA-8270 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-8270) Kafka retention hour is not working

[ https://issues.apache.org/jira/browse/KAFKA-8270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangtao Liu updated KAFKA-8270: Labels: storage (was: performance) > Kafka retention hour is not working >

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16822619#comment-16822619 ] Matthias J. Sax commented on KAFKA-5998: [~mparthas] "log-cleaner" is actually not the right term

[jira] [Comment Edited] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16822610#comment-16822610 ] Matthias J. Sax edited comment on KAFKA-5998 at 4/21/19 3:52 AM: -

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16822614#comment-16822614 ] Mohan Parthasarathy commented on KAFKA-5998: [~mjsax] Initially my understanding was that

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16822610#comment-16822610 ] Matthias J. Sax commented on KAFKA-5998: [~mparthas] It there are state stores, on commit, the

[jira] [Comment Edited] (KAFKA-8030) Flaky Test TopicCommandWithAdminClientTest#testDescribeUnderMinIsrPartitionsMixed

[ https://issues.apache.org/jira/browse/KAFKA-8030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16822608#comment-16822608 ] Matthias J. Sax edited comment on KAFKA-8030 at 4/21/19 2:01 AM: - Might

[jira] [Commented] (KAFKA-8030) Flaky Test TopicCommandWithAdminClientTest#testDescribeUnderMinIsrPartitionsMixed

[ https://issues.apache.org/jira/browse/KAFKA-8030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16822608#comment-16822608 ] Matthias J. Sax commented on KAFKA-8030: Might be related. > Flaky Test >

[jira] [Created] (KAFKA-8269) Flaky Test TopicCommandWithAdminClientTest#testDescribeUnderMinIsrPartitionsMixed

Matthias J. Sax created KAFKA-8269: -- Summary: Flaky Test TopicCommandWithAdminClientTest#testDescribeUnderMinIsrPartitionsMixed Key: KAFKA-8269 URL: https://issues.apache.org/jira/browse/KAFKA-8269

[jira] [Commented] (KAFKA-8245) Flaky Test DeleteConsumerGroupsTest#testDeleteCmdAllGroups

[ https://issues.apache.org/jira/browse/KAFKA-8245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16822606#comment-16822606 ] Matthias J. Sax commented on KAFKA-8245:

[jira] [Commented] (KAFKA-8059) Flaky Test DynamicConnectionQuotaTest #testDynamicConnectionQuota

[ https://issues.apache.org/jira/browse/KAFKA-8059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16822605#comment-16822605 ] Matthias J. Sax commented on KAFKA-8059:

[jira] [Commented] (KAFKA-8073) Transient failure in kafka.api.UserQuotaTest.testThrottledProducerConsumer

[ https://issues.apache.org/jira/browse/KAFKA-8073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16822604#comment-16822604 ] Matthias J. Sax commented on KAFKA-8073:

[jira] [Commented] (KAFKA-7994) Improve Stream-Time for rebalances and restarts

[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16822589#comment-16822589 ] Richard Yu commented on KAFKA-7994: --- Oh, I'm fine doing some digging though. I might try to take a hack

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16822564#comment-16822564 ] Ted Yu commented on KAFKA-5998: --- One doubt I had after reading recent comments is that, if the state

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16822563#comment-16822563 ] Mohan Parthasarathy commented on KAFKA-5998: When are these checkpoint files created ? I

[jira] [Resolved] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window

[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-7895. Resolution: Fixed > Ktable supress operator emitting more than one record for the same key per >

[jira] [Commented] (KAFKA-3729) Auto-configure non-default SerDes passed alongside the topology builder

[ https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16822540#comment-16822540 ] ASF GitHub Bot commented on KAFKA-3729: --- mjsax commented on pull request #6461: [KAFKA-3729]

[jira] [Commented] (KAFKA-8073) Transient failure in kafka.api.UserQuotaTest.testThrottledProducerConsumer

[ https://issues.apache.org/jira/browse/KAFKA-8073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16822538#comment-16822538 ] Matthias J. Sax commented on KAFKA-8073: One more: 

[jira] [Assigned] (KAFKA-8248) Producer may fail IllegalStateException

[ https://issues.apache.org/jira/browse/KAFKA-8248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8248: -- Assignee: Jason Gustafson (was: Matthias J. Sax) > Producer may fail

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16822537#comment-16822537 ] Matthias J. Sax commented on KAFKA-5998: [~drshade] Instead of using the PID to separate the

[jira] [Commented] (KAFKA-7994) Improve Stream-Time for rebalances and restarts

[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16822535#comment-16822535 ] Matthias J. Sax commented on KAFKA-7994: It's a little unclear how to tackle the issue atm, and

[jira] [Resolved] (KAFKA-4332) kafka.api.UserQuotaTest.testThrottledProducerConsumer transient unit test failure

[ https://issues.apache.org/jira/browse/KAFKA-4332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4332. Resolution: Duplicate > kafka.api.UserQuotaTest.testThrottledProducerConsumer transient

[jira] [Commented] (KAFKA-8073) Transient failure in kafka.api.UserQuotaTest.testThrottledProducerConsumer

[ https://issues.apache.org/jira/browse/KAFKA-8073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16822532#comment-16822532 ] Matthias J. Sax commented on KAFKA-8073: Failed again: 

[jira] [Created] (KAFKA-8268) Flaky Test SaslSslAdminClientIntegrationTest#testSeekAfterDeleteRecords

Matthias J. Sax created KAFKA-8268: -- Summary: Flaky Test SaslSslAdminClientIntegrationTest#testSeekAfterDeleteRecords Key: KAFKA-8268 URL: https://issues.apache.org/jira/browse/KAFKA-8268 Project:

[jira] [Commented] (KAFKA-8245) Flaky Test DeleteConsumerGroupsTest#testDeleteCmdAllGroups

[ https://issues.apache.org/jira/browse/KAFKA-8245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16822531#comment-16822531 ] Matthias J. Sax commented on KAFKA-8245: Failed again: 

[jira] [Commented] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window

[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16822470#comment-16822470 ] ASF GitHub Bot commented on KAFKA-7895: --- bbejeck commented on pull request #6536: KAFKA-7895: fix

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16822446#comment-16822446 ] Ted Yu commented on KAFKA-5998: --- I wonder if we can use a file, which records reference count (for

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16822395#comment-16822395 ] Tom Wells commented on KAFKA-5998: -- I've confirmed the issue is related to multiple processes sharing

[jira] [Commented] (KAFKA-8248) Producer may fail IllegalStateException

[ https://issues.apache.org/jira/browse/KAFKA-8248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16822391#comment-16822391 ] ASF GitHub Bot commented on KAFKA-8248: --- hachikuji commented on pull request #6613: KAFKA-8248;