[jira] [Updated] (KAFKA-7442) forceUnmap mmap on linux when index resize

[ https://issues.apache.org/jira/browse/KAFKA-7442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 翟玉勇 updated KAFKA-7442: --- Issue Type: Bug (was: Improvement) > forceUnmap mmap on linux when index resize >

[jira] [Updated] (KAFKA-7442) forceUnmap mmap on linux when index resize

[ https://issues.apache.org/jira/browse/KAFKA-7442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 翟玉勇 updated KAFKA-7442: --- Priority: Major (was: Minor) > forceUnmap mmap on linux when index resize >

[jira] [Commented] (KAFKA-7245) Deprecate WindowStore#put(key, value)

[ https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16629739#comment-16629739 ] Panuwat Anawatmongkhon commented on KAFKA-7245: --- Ok, I will be working on this issue. By

[jira] [Updated] (KAFKA-7442) forceUnmap mmap on linux when index resize

[ https://issues.apache.org/jira/browse/KAFKA-7442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 翟玉勇 updated KAFKA-7442: --- Description: when resize OffsetIndex or TimeIndex,We should force unmap mmap for linux platform. Rather than

[jira] [Commented] (KAFKA-7444) expose connector, task IDs to SinkTasks

[ https://issues.apache.org/jira/browse/KAFKA-7444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16629489#comment-16629489 ] ASF GitHub Bot commented on KAFKA-7444: --- ryannedolan opened a new pull request #5702: KAFKA-7444:

[jira] [Updated] (KAFKA-7441) Allow LogCleanerManager.resumeCleaning() to be used concurrently

[ https://issues.apache.org/jira/browse/KAFKA-7441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7441: Priority: Blocker (was: Major) > Allow LogCleanerManager.resumeCleaning() to be used concurrently >

[jira] [Commented] (KAFKA-7434) DeadLetterQueueReporter throws NPE if transform throws NPE

[ https://issues.apache.org/jira/browse/KAFKA-7434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16629428#comment-16629428 ] Michal Borowiecki commented on KAFKA-7434: -- Submitted PR for trunk:

[jira] [Commented] (KAFKA-7434) DeadLetterQueueReporter throws NPE if transform throws NPE

[ https://issues.apache.org/jira/browse/KAFKA-7434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16629427#comment-16629427 ] ASF GitHub Bot commented on KAFKA-7434: --- mihbor opened a new pull request #5701: KAFKA-7434 fix NPE

[jira] [Commented] (KAFKA-7434) DeadLetterQueueReporter throws NPE if transform throws NPE

[ https://issues.apache.org/jira/browse/KAFKA-7434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16629413#comment-16629413 ] ASF GitHub Bot commented on KAFKA-7434: --- mihbor opened a new pull request #5700: KAFKA-7434 fix NPE

[jira] [Commented] (KAFKA-7429) Enable dynamic key/truststore update with same filename/password

[ https://issues.apache.org/jira/browse/KAFKA-7429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16629247#comment-16629247 ] ASF GitHub Bot commented on KAFKA-7429: --- rajinisivaram opened a new pull request #5699: KAFKA-7429:

[jira] [Resolved] (KAFKA-7437) Store leader epoch in offset commit metadata

[ https://issues.apache.org/jira/browse/KAFKA-7437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-7437. --- Resolution: Fixed Reviewer: Rajini Sivaram Fix Version/s: 2.1.0 > Store

[jira] [Created] (KAFKA-7444) expose connector, task IDs to SinkTasks

Ryanne Dolan created KAFKA-7444: --- Summary: expose connector, task IDs to SinkTasks Key: KAFKA-7444 URL: https://issues.apache.org/jira/browse/KAFKA-7444 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-6863) Kafka clients should try to use multiple DNS resolved IP addresses if the first one fails

[ https://issues.apache.org/jira/browse/KAFKA-6863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16629137#comment-16629137 ] Edoardo Comar commented on KAFKA-6863: -- [https://github.com/apache/kafka/pull/4987] fully revised to

[jira] [Commented] (KAFKA-7367) Streams should not create state store directories unless they are needed

[ https://issues.apache.org/jira/browse/KAFKA-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16629016#comment-16629016 ] ASF GitHub Bot commented on KAFKA-7367: --- kamalcph opened a new pull request #5696: KAFKA-7367:

[jira] [Updated] (KAFKA-7313) StopReplicaRequest should attempt to remove future replica for the partition only if future replica exists

[ https://issues.apache.org/jira/browse/KAFKA-7313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7313: Summary: StopReplicaRequest should attempt to remove future replica for the partition only if future

[jira] [Commented] (KAFKA-7437) Store leader epoch in offset commit metadata

[ https://issues.apache.org/jira/browse/KAFKA-7437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16628780#comment-16628780 ] ASF GitHub Bot commented on KAFKA-7437: --- rajinisivaram closed pull request #5689: KAFKA-7437;

[jira] [Commented] (KAFKA-6764) ConsoleConsumer behavior inconsistent when specifying --partition with --from-beginning

[ https://issues.apache.org/jira/browse/KAFKA-6764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16628748#comment-16628748 ] Suman B N commented on KAFKA-6764: -- Fixed. Pull request is [https://github.com/apache/kafka/pull/5637]

[jira] [Updated] (KAFKA-7442) forceUnmap mmap on linux when index resize

[ https://issues.apache.org/jira/browse/KAFKA-7442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 翟玉勇 updated KAFKA-7442: --- Description: when resize OffsetIndex or TimeIndex,We should force unmap mmap for linux platform. Rather than

[jira] [Updated] (KAFKA-7443) OffsetOutOfRangeException in restoring state store from changelog topic when start offset of local checkpoint is smaller than that of changelog topic

[ https://issues.apache.org/jira/browse/KAFKA-7443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linyue li updated KAFKA-7443: - Description: When restoring local state store from a changelog topic in EOS, kafka stream will

[jira] [Updated] (KAFKA-7443) OffsetOutOfRangeException in restoring state store from changelog topic when start offset of local checkpoint is smaller than that of changelog topic

[ https://issues.apache.org/jira/browse/KAFKA-7443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linyue li updated KAFKA-7443: - Labels: feather (was: patch) > OffsetOutOfRangeException in restoring state store from changelog topic

[jira] [Created] (KAFKA-7443) OffsetOutOfRangeException in restoring state store from changelog topic when start offset of local checkpoint is smaller than that of changelog topic

linyue li created KAFKA-7443: Summary: OffsetOutOfRangeException in restoring state store from changelog topic when start offset of local checkpoint is smaller than that of changelog topic Key: KAFKA-7443 URL:

[jira] [Commented] (KAFKA-7428) ConnectionStressSpec: add "action", allow multiple clients

[ https://issues.apache.org/jira/browse/KAFKA-7428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16628458#comment-16628458 ] ASF GitHub Bot commented on KAFKA-7428: --- rajinisivaram closed pull request #5668: KAFKA-7428:

[jira] [Updated] (KAFKA-7442) forceUnmap mmap on linux when index resize

[ https://issues.apache.org/jira/browse/KAFKA-7442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 翟玉勇 updated KAFKA-7442: --- Description: when resize OffsetIndex or TimeIndex,We should force unmap mmap for linux platform. Rather than

[jira] [Updated] (KAFKA-7442) forceUnmap mmap on linux when index resize

[ https://issues.apache.org/jira/browse/KAFKA-7442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 翟玉勇 updated KAFKA-7442: --- Summary: forceUnmap mmap on linux when index resize (was: forceUnmap mmap on linux) > forceUnmap mmap on linux

[jira] [Updated] (KAFKA-7442) forceUnmap mmap on linux

[ https://issues.apache.org/jira/browse/KAFKA-7442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 翟玉勇 updated KAFKA-7442: --- Description: when resize OffsetIndex or TimeIndex,We should force unmap mmap for linux platform. Rather than

[jira] [Updated] (KAFKA-7442) forceUnmap mmap on linux

[ https://issues.apache.org/jira/browse/KAFKA-7442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 翟玉勇 updated KAFKA-7442: --- Description: when resize OffsetIndex or TimeIndex,We should force unmap mmap for linux platform. Rather than

[jira] [Updated] (KAFKA-7442) forceUnmap mmap on linux

[ https://issues.apache.org/jira/browse/KAFKA-7442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 翟玉勇 updated KAFKA-7442: --- Description: when resize OffsetIndex or TimeIndex,We should force unmap mmap for linux platform. Rather than

[jira] [Created] (KAFKA-7442) forceUnmap mmap on linux

翟玉勇 created KAFKA-7442: -- Summary: forceUnmap mmap on linux Key: KAFKA-7442 URL: https://issues.apache.org/jira/browse/KAFKA-7442 Project: Kafka Issue Type: Improvement Components: log