[jira] [Resolved] (KAFKA-9538) Flaky Test `testResetOffsetsExportImportPlan`

[ https://issues.apache.org/jira/browse/KAFKA-9538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9538. Resolution: Fixed > Flaky Test `testResetOffsetsExportImportPlan` > ---

[jira] [Commented] (KAFKA-9538) Flaky Test `testResetOffsetsExportImportPlan`

[ https://issues.apache.org/jira/browse/KAFKA-9538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035959#comment-17035959 ] ASF GitHub Bot commented on KAFKA-9538: --- hachikuji commented on pull request #6561:

[jira] [Commented] (KAFKA-9504) Memory leak in KafkaMetrics registered to MBean

[ https://issues.apache.org/jira/browse/KAFKA-9504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035930#comment-17035930 ] Ismael Juma commented on KAFKA-9504: I believe this was fixed in the 2.4 branch (and

[jira] [Comment Edited] (KAFKA-9504) Memory leak in KafkaMetrics registered to MBean

[ https://issues.apache.org/jira/browse/KAFKA-9504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035929#comment-17035929 ] Junyong Li edited comment on KAFKA-9504 at 2/13/20 5:31 AM: M

[jira] [Comment Edited] (KAFKA-9504) Memory leak in KafkaMetrics registered to MBean

[ https://issues.apache.org/jira/browse/KAFKA-9504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035929#comment-17035929 ] Junyong Li edited comment on KAFKA-9504 at 2/13/20 5:29 AM: M

[jira] [Commented] (KAFKA-9504) Memory leak in KafkaMetrics registered to MBean

[ https://issues.apache.org/jira/browse/KAFKA-9504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035929#comment-17035929 ] Junyong Li commented on KAFKA-9504: --- Maybe I found the cause: KafkaConsumerMetrics and

[jira] [Commented] (KAFKA-9533) ValueTransform forwards `null` values

[ https://issues.apache.org/jira/browse/KAFKA-9533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035927#comment-17035927 ] Michael Viamari commented on KAFKA-9533: Sure. I can take a look at it. Before I

[jira] [Assigned] (KAFKA-9545) Flaky Test `RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted`

[ https://issues.apache.org/jira/browse/KAFKA-9545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9545: -- Assignee: Boyang Chen > Flaky Test `RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDele

[jira] [Commented] (KAFKA-6834) log cleaner should handle the case when the size of a message set is larger than the max message size

[ https://issues.apache.org/jira/browse/KAFKA-6834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035922#comment-17035922 ] zhangzhisheng commented on KAFKA-6834: -- kafka2.12_0.11.0.3 log clean tread stoped，th

[jira] [Commented] (KAFKA-9441) Refactor commit logic

[ https://issues.apache.org/jira/browse/KAFKA-9441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035875#comment-17035875 ] ASF GitHub Bot commented on KAFKA-9441: --- mjsax commented on pull request #8105: KAF

[jira] [Comment Edited] (KAFKA-9541) Flaky Test DescribeConsumerGroupTest#testDescribeGroupMembersWithShortInitializationTimeout

[ https://issues.apache.org/jira/browse/KAFKA-9541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035028#comment-17035028 ] huxihx edited comment on KAFKA-9541 at 2/13/20 2:14 AM: Occasiona

[jira] [Commented] (KAFKA-7061) Enhanced log compaction

[ https://issues.apache.org/jira/browse/KAFKA-7061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035829#comment-17035829 ] Senthilnathan Muthusamy commented on KAFKA-7061: Opened PR - rebased with

[jira] [Commented] (KAFKA-7061) Enhanced log compaction

[ https://issues.apache.org/jira/browse/KAFKA-7061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035828#comment-17035828 ] ASF GitHub Bot commented on KAFKA-7061: --- senthilm-ms commented on pull request #752

[jira] [Created] (KAFKA-9545) Flaky Test `RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted`

Jason Gustafson created KAFKA-9545: -- Summary: Flaky Test `RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted` Key: KAFKA-9545 URL: https://issues.apache.org/jira/browse/KAFKA-9545 Project:

[jira] [Updated] (KAFKA-9475) Replace transaction abortion scheduler with a delayed queue

[ https://issues.apache.org/jira/browse/KAFKA-9475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9475: --- Labels: (was: help-wanted) > Replace transaction abortion scheduler with a delayed queue >

[jira] [Resolved] (KAFKA-9204) ReplaceField transformation fails when encountering tombstone event

[ https://issues.apache.org/jira/browse/KAFKA-9204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-9204. -- Fix Version/s: 2.4.1 2.3.2 2.5.0 2.2.3

[jira] [Updated] (KAFKA-9475) Replace transaction abortion scheduler with a delayed queue

[ https://issues.apache.org/jira/browse/KAFKA-9475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9475: --- Labels: help-wanted (was: ) > Replace transaction abortion scheduler with a delayed queue >

[jira] [Assigned] (KAFKA-9475) Replace transaction abortion scheduler with a delayed queue

[ https://issues.apache.org/jira/browse/KAFKA-9475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9475: -- Assignee: (was: Boyang Chen) > Replace transaction abortion scheduler with a delayed queue

[jira] [Commented] (KAFKA-9544) Flaky Test `KafkaAdminClientTest.testDefaultApiTimeoutOverride`

[ https://issues.apache.org/jira/browse/KAFKA-9544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035767#comment-17035767 ] ASF GitHub Bot commented on KAFKA-9544: --- hachikuji commented on pull request #8101:

[jira] [Created] (KAFKA-9544) Flaky Test `KafkaAdminClientTest.testDefaultApiTimeoutOverride`

Jason Gustafson created KAFKA-9544: -- Summary: Flaky Test `KafkaAdminClientTest.testDefaultApiTimeoutOverride` Key: KAFKA-9544 URL: https://issues.apache.org/jira/browse/KAFKA-9544 Project: Kafka

[jira] [Commented] (KAFKA-9204) ReplaceField transformation fails when encountering tombstone event

[ https://issues.apache.org/jira/browse/KAFKA-9204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035764#comment-17035764 ] ASF GitHub Bot commented on KAFKA-9204: --- rhauch commented on pull request #7731: KA

[jira] [Resolved] (KAFKA-9192) NullPointerException if field in schema not present in value

[ https://issues.apache.org/jira/browse/KAFKA-9192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-9192. -- Fix Version/s: 2.4.1 2.3.2 2.5.0 2.2.3

[jira] [Resolved] (KAFKA-9417) Integration test for new EOS model with vanilla Producer and Consumer

[ https://issues.apache.org/jira/browse/KAFKA-9417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-9417. -- Resolution: Fixed > Integration test for new EOS model with vanilla Producer and Consumer > ---

[jira] [Updated] (KAFKA-9417) Integration test for new EOS model with vanilla Producer and Consumer

[ https://issues.apache.org/jira/browse/KAFKA-9417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-9417: - Fix Version/s: 2.5.0 > Integration test for new EOS model with vanilla Producer and Consumer > --

[jira] [Commented] (KAFKA-9192) NullPointerException if field in schema not present in value

[ https://issues.apache.org/jira/browse/KAFKA-9192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035732#comment-17035732 ] ASF GitHub Bot commented on KAFKA-9192: --- rhauch commented on pull request #7733: KA

[jira] [Commented] (KAFKA-9521) Flaky Test DeleteConsumerGroupsTest#testDeleteCmdEmptyGroup

[ https://issues.apache.org/jira/browse/KAFKA-9521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035693#comment-17035693 ] Matthias J. Sax commented on KAFKA-9521: Different test method but same error mes

[jira] [Updated] (KAFKA-9521) Flaky Test DeleteConsumerGroupsTest#testDeleteCmdEmptyGroup

[ https://issues.apache.org/jira/browse/KAFKA-9521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9521: --- Component/s: unit tests > Flaky Test DeleteConsumerGroupsTest#testDeleteCmdEmptyGroup > -

[jira] [Commented] (KAFKA-9530) Flaky Test kafka.admin.DescribeConsumerGroupTest.testDescribeGroupWithShortInitializationTimeout

[ https://issues.apache.org/jira/browse/KAFKA-9530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035692#comment-17035692 ] Matthias J. Sax commented on KAFKA-9530: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-9538) Flaky Test `testResetOffsetsExportImportPlan`

[ https://issues.apache.org/jira/browse/KAFKA-9538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035691#comment-17035691 ] Matthias J. Sax commented on KAFKA-9538: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-9541) Flaky Test DescribeConsumerGroupTest#testDescribeGroupMembersWithShortInitializationTimeout

[ https://issues.apache.org/jira/browse/KAFKA-9541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035690#comment-17035690 ] Matthias J. Sax commented on KAFKA-9541: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-8110) Flaky Test DescribeConsumerGroupTest#testDescribeMembersWithConsumersWithoutAssignedPartitions

[ https://issues.apache.org/jira/browse/KAFKA-8110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035689#comment-17035689 ] Matthias J. Sax commented on KAFKA-8110: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-9417) Integration test for new EOS model with vanilla Producer and Consumer

[ https://issues.apache.org/jira/browse/KAFKA-9417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035688#comment-17035688 ] ASF GitHub Bot commented on KAFKA-9417: --- guozhangwang commented on pull request #80

[jira] [Commented] (KAFKA-9530) Flaky Test kafka.admin.DescribeConsumerGroupTest.testDescribeGroupWithShortInitializationTimeout

[ https://issues.apache.org/jira/browse/KAFKA-9530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035684#comment-17035684 ] Matthias J. Sax commented on KAFKA-9530: [https://builds.apache.org/job/kafka-pr-

[jira] [Resolved] (KAFKA-6607) Kafka Streams lag not zero when input topic transactional

[ https://issues.apache.org/jira/browse/KAFKA-6607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6607. Fix Version/s: 2.5.0 Resolution: Fixed > Kafka Streams lag not zero when input topic

[jira] [Updated] (KAFKA-6607) Kafka Streams lag not zero when input topic transactional

[ https://issues.apache.org/jira/browse/KAFKA-6607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6607: --- Description: When an input topic for a Kafka Streams application is written using transactio

[jira] [Updated] (KAFKA-6607) Kafka Streams lag not zero when input topic transactional

[ https://issues.apache.org/jira/browse/KAFKA-6607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6607: --- Description: When an input topic for a Kafka Streams application is written using transactio

[jira] [Updated] (KAFKA-6607) Kafka Streams lag not zero when input topic transactional

[ https://issues.apache.org/jira/browse/KAFKA-6607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6607: --- Component/s: (was: clients) > Kafka Streams lag not zero when input topic transactional >

[jira] [Updated] (KAFKA-6607) Kafka Streams lag not zero when input topic transactional

[ https://issues.apache.org/jira/browse/KAFKA-6607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6607: --- Summary: Kafka Streams lag not zero when input topic transactional (was: Consumer Client and

[jira] [Commented] (KAFKA-6607) Consumer Client and Kafka Streams lag not zero when input topic transactional

[ https://issues.apache.org/jira/browse/KAFKA-6607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035681#comment-17035681 ] ASF GitHub Bot commented on KAFKA-6607: --- mjsax commented on pull request #8091: KAF

[jira] [Resolved] (KAFKA-9499) Improve deletion process by batching more aggressively

[ https://issues.apache.org/jira/browse/KAFKA-9499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9499. Fix Version/s: 2.5.0 Resolution: Fixed > Improve deletion process by batching more a

[jira] [Commented] (KAFKA-9499) Improve deletion process by batching more aggressively

[ https://issues.apache.org/jira/browse/KAFKA-9499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035658#comment-17035658 ] ASF GitHub Bot commented on KAFKA-9499: --- hachikuji commented on pull request #8053:

[jira] [Commented] (KAFKA-8187) State store record loss across multiple reassignments when using standby tasks

[ https://issues.apache.org/jira/browse/KAFKA-8187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035614#comment-17035614 ] ASF GitHub Bot commented on KAFKA-8187: --- mjsax commented on pull request #6849: KAF

[jira] [Updated] (KAFKA-9535) Metadata not updated when consumer encounters FENCED_LEADER_EPOCH

[ https://issues.apache.org/jira/browse/KAFKA-9535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9535: --- Affects Version/s: (was: 2.5.0) (was: 2.4.0) > Metadata not up

[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&focusedCommentId=17035598#comment-17035598 ] ASF GitHub Bot commented on KAFKA-8073: --- chia7712 commented on pull request #8098:

[jira] [Commented] (KAFKA-9542) ZSTD Compression Not Working

[ https://issues.apache.org/jira/browse/KAFKA-9542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035594#comment-17035594 ] Lucas Bradstreet commented on KAFKA-9542: - Hi Prashant, Can you please check whe

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

[ https://issues.apache.org/jira/browse/KAFKA-8073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai reassigned KAFKA-8073: - Assignee: Chia-Ping Tsai > Transient failure in kafka.api.UserQuotaTest.testThrottledPro

[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&focusedCommentId=1703#comment-1703 ] Matthias J. Sax commented on KAFKA-7965: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-8037) KTable restore may load bad data

[ https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035541#comment-17035541 ] Sophie Blee-Goldman commented on KAFKA-8037: Ha, yes good catch I'll fix the

[jira] [Comment Edited] (KAFKA-8037) KTable restore may load bad data

[ https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034746#comment-17034746 ] Sophie Blee-Goldman edited comment on KAFKA-8037 at 2/12/20 5:38 PM: --

[jira] [Commented] (KAFKA-4084) automated leader rebalance causes replication downtime for clusters with too many partitions

[ https://issues.apache.org/jira/browse/KAFKA-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035517#comment-17035517 ] Evan Williams commented on KAFKA-4084: -- [~sql_consulting] [~junrao] FYI, I implemen

[jira] [Comment Edited] (KAFKA-4084) automated leader rebalance causes replication downtime for clusters with too many partitions

[ https://issues.apache.org/jira/browse/KAFKA-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035517#comment-17035517 ] Evan Williams edited comment on KAFKA-4084 at 2/12/20 5:08 PM:

[jira] [Commented] (KAFKA-9517) KTable Joins Without Materialized Argument Yield Results That Further Joins NPE On

[ https://issues.apache.org/jira/browse/KAFKA-9517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035500#comment-17035500 ] John Roesler commented on KAFKA-9517: - Hi [~psnively], Just another quick update: no

[jira] [Created] (KAFKA-9543) Consumer offset reset after new segment rolling

Rafał Boniecki created KAFKA-9543: - Summary: Consumer offset reset after new segment rolling Key: KAFKA-9543 URL: https://issues.apache.org/jira/browse/KAFKA-9543 Project: Kafka Issue Type: B

[jira] [Commented] (KAFKA-9533) ValueTransform forwards `null` values

[ https://issues.apache.org/jira/browse/KAFKA-9533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035407#comment-17035407 ] Bruno Cadonna commented on KAFKA-9533: -- [~mviamari] Would you be interested in fixin

[jira] [Created] (KAFKA-9542) ZSTD Compression Not Working

Prashant created KAFKA-9542: --- Summary: ZSTD Compression Not Working Key: KAFKA-9542 URL: https://issues.apache.org/jira/browse/KAFKA-9542 Project: Kafka Issue Type: Bug Components: compre

[jira] [Commented] (KAFKA-8037) KTable restore may load bad data

[ https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035215#comment-17035215 ] Patrik Kleindl commented on KAFKA-8037: --- [~ableegoldman] Interesting proposal. At 2

[jira] [Issue Comment Deleted] (KAFKA-9455) Consider using TreeMap for in-memory stores of Streams

[ https://issues.apache.org/jira/browse/KAFKA-9455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck updated KAFKA-9455: Comment: was deleted (was: [~guozhang] I have one more question What do you think about splitting a Windo