[jira] [Commented] (KAFKA-12519) Consider Removing Streams Old Built-in Metrics Version

[ https://issues.apache.org/jira/browse/KAFKA-12519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306914#comment-17306914 ] Bruno Cadonna commented on KAFKA-12519: --- [~ableegoldman] Good catch! I was sure I

[jira] [Commented] (KAFKA-12475) Kafka Streams breaks EOS with remote state stores

[ https://issues.apache.org/jira/browse/KAFKA-12475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306916#comment-17306916 ] Bruno Cadonna commented on KAFKA-12475: --- Yes, I agree with you. I mainly brought t

[jira] [Updated] (KAFKA-12519) Consider Removing Streams Old Built-in Metrics Version

[ https://issues.apache.org/jira/browse/KAFKA-12519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12519: -- Labels: needs-kip (was: ) > Consider Removing Streams Old Built-in Metrics Version > ---

[jira] [Assigned] (KAFKA-12519) Consider Removing Streams Old Built-in Metrics Version

[ https://issues.apache.org/jira/browse/KAFKA-12519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reassigned KAFKA-12519: - Assignee: Bruno Cadonna > Consider Removing Streams Old Built-in Metrics Version > ---

[jira] [Commented] (KAFKA-12608) Simple identity pipeline sometimes loses data

[ https://issues.apache.org/jira/browse/KAFKA-12608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17320005#comment-17320005 ] Bruno Cadonna commented on KAFKA-12608: --- Hi [~jamii], I think [~hpgrahsl] is righ

[jira] [Comment Edited] (KAFKA-12608) Simple identity pipeline sometimes loses data

[ https://issues.apache.org/jira/browse/KAFKA-12608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17320005#comment-17320005 ] Bruno Cadonna edited comment on KAFKA-12608 at 4/13/21, 8:01 AM: -

[jira] [Comment Edited] (KAFKA-12608) Simple identity pipeline sometimes loses data

[ https://issues.apache.org/jira/browse/KAFKA-12608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17320005#comment-17320005 ] Bruno Cadonna edited comment on KAFKA-12608 at 4/13/21, 8:04 AM: -

[jira] [Comment Edited] (KAFKA-12608) Simple identity pipeline sometimes loses data

[ https://issues.apache.org/jira/browse/KAFKA-12608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17320005#comment-17320005 ] Bruno Cadonna edited comment on KAFKA-12608 at 4/13/21, 8:01 AM: -

[jira] [Commented] (KAFKA-12650) NPE in InternalTopicManager#cleanUpCreatedTopics

[ https://issues.apache.org/jira/browse/KAFKA-12650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17320051#comment-17320051 ] Bruno Cadonna commented on KAFKA-12650: --- [~mjsax] [~ableegoldman] , Thank you for

[jira] [Assigned] (KAFKA-8941) Add RocksDB Metrics that Could not be Added due to RocksDB Version

[ https://issues.apache.org/jira/browse/KAFKA-8941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reassigned KAFKA-8941: Assignee: (was: Bruno Cadonna) > Add RocksDB Metrics that Could not be Added due to Ro

[jira] [Updated] (KAFKA-8941) Add RocksDB Metrics that Could not be Added due to RocksDB Version

[ https://issues.apache.org/jira/browse/KAFKA-8941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-8941: - Labels: newbie (was: ) > Add RocksDB Metrics that Could not be Added due to RocksDB Version > --

[jira] [Commented] (KAFKA-9295) KTableKTableForeignKeyInnerJoinMultiIntegrationTest#shouldInnerJoinMultiPartitionQueryable

[ https://issues.apache.org/jira/browse/KAFKA-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17320696#comment-17320696 ] Bruno Cadonna commented on KAFKA-9295: -- Documenting that I found this test failure i

[jira] [Created] (KAFKA-12666) Fix flaky kafka.server.RaftClusterTest.testCreateClusterAndCreateListDeleteTopic

Bruno Cadonna created KAFKA-12666: - Summary: Fix flaky kafka.server.RaftClusterTest.testCreateClusterAndCreateListDeleteTopic Key: KAFKA-12666 URL: https://issues.apache.org/jira/browse/KAFKA-12666 Pr

[jira] [Commented] (KAFKA-9295) KTableKTableForeignKeyInnerJoinMultiIntegrationTest#shouldInnerJoinMultiPartitionQueryable

[ https://issues.apache.org/jira/browse/KAFKA-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17320704#comment-17320704 ] Bruno Cadonna commented on KAFKA-9295: -- [~ableegoldman] Makes sense! My bad, I looke

[jira] [Comment Edited] (KAFKA-9295) KTableKTableForeignKeyInnerJoinMultiIntegrationTest#shouldInnerJoinMultiPartitionQueryable

[ https://issues.apache.org/jira/browse/KAFKA-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17320704#comment-17320704 ] Bruno Cadonna edited comment on KAFKA-9295 at 4/14/21, 5:07 AM: ---

[jira] [Updated] (KAFKA-12667) Incorrect error log on StateDirectory close

[ https://issues.apache.org/jira/browse/KAFKA-12667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12667: -- Fix Version/s: 2.7.1 > Incorrect error log on StateDirectory close > -

[jira] [Updated] (KAFKA-12667) Incorrect error log on StateDirectory close

[ https://issues.apache.org/jira/browse/KAFKA-12667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12667: -- Fix Version/s: 2.6.3 > Incorrect error log on StateDirectory close > -

[jira] [Updated] (KAFKA-12667) Incorrect error log on StateDirectory close

[ https://issues.apache.org/jira/browse/KAFKA-12667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12667: -- Fix Version/s: (was: 2.7.1) 2.7.2 > Incorrect error log on StateDirecto

[jira] [Updated] (KAFKA-12667) Incorrect error log on StateDirectory close

[ https://issues.apache.org/jira/browse/KAFKA-12667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12667: -- Priority: Major (was: Trivial) > Incorrect error log on StateDirectory close > --

[jira] [Commented] (KAFKA-12667) Incorrect error log on StateDirectory close

[ https://issues.apache.org/jira/browse/KAFKA-12667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17320768#comment-17320768 ] Bruno Cadonna commented on KAFKA-12667: --- [~antrenta] Thank you for the ticket! Thi

[jira] [Commented] (KAFKA-10493) KTable out-of-order updates are not being ignored

[ https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17327212#comment-17327212 ] Bruno Cadonna commented on KAFKA-10493: --- The options that I see are: # verify the

[jira] [Commented] (KAFKA-10493) KTable out-of-order updates are not being ignored

[ https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17329387#comment-17329387 ] Bruno Cadonna commented on KAFKA-10493: --- Good point about the compaction!   {quot

[jira] [Commented] (KAFKA-10493) KTable out-of-order updates are not being ignored

[ https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17331171#comment-17331171 ] Bruno Cadonna commented on KAFKA-10493: --- Are you proposing to drop out-of-order re

[jira] [Commented] (KAFKA-9295) KTableKTableForeignKeyInnerJoinMultiIntegrationTest#shouldInnerJoinMultiPartitionQueryable

[ https://issues.apache.org/jira/browse/KAFKA-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17339760#comment-17339760 ] Bruno Cadonna commented on KAFKA-9295: -- Failed multiple times for a PR (https://ci-

[jira] [Commented] (KAFKA-9009) Flaky Test kafka.integration.MetricsDuringTopicCreationDeletionTest.testMetricsDuringTopicCreateDelete

[ https://issues.apache.org/jira/browse/KAFKA-9009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17340118#comment-17340118 ] Bruno Cadonna commented on KAFKA-9009: -- Failed again: [https://ci-builds.apache.org

[jira] [Resolved] (KAFKA-10767) Add Unit Test cases for missing methods in ThreadCacheTest

[ https://issues.apache.org/jira/browse/KAFKA-10767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-10767. --- Resolution: Fixed > Add Unit Test cases for missing methods in ThreadCacheTest > ---

[jira] [Updated] (KAFKA-10767) Add Unit Test cases for missing methods in ThreadCacheTest

[ https://issues.apache.org/jira/browse/KAFKA-10767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-10767: -- Fix Version/s: 3.0.0 > Add Unit Test cases for missing methods in ThreadCacheTest > --

[jira] [Commented] (KAFKA-12657) Flaky Tests BlockingConnectorTest.testWorkerRestartWithBlockInConnectorStop

[ https://issues.apache.org/jira/browse/KAFKA-12657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17340257#comment-17340257 ] Bruno Cadonna commented on KAFKA-12657: --- https://ci-builds.apache.org/job/Kafka/jo

[jira] [Commented] (KAFKA-9009) Flaky Test kafka.integration.MetricsDuringTopicCreationDeletionTest.testMetricsDuringTopicCreateDelete

[ https://issues.apache.org/jira/browse/KAFKA-9009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17340259#comment-17340259 ] Bruno Cadonna commented on KAFKA-9009: -- https://ci-builds.apache.org/job/Kafka/job/k

[jira] [Resolved] (KAFKA-8897) Increase Version of RocksDB

[ https://issues.apache.org/jira/browse/KAFKA-8897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-8897. -- Resolution: Fixed > Increase Version of RocksDB > --- > >

[jira] [Updated] (KAFKA-12766) Consider Disabling WAL-related Options in RocksDB

[ https://issues.apache.org/jira/browse/KAFKA-12766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12766: -- Issue Type: Improvement (was: Test) > Consider Disabling WAL-related Options in RocksDB > ---

[jira] [Created] (KAFKA-12766) Consider Disabling WAL-related Options in RocksDB

Bruno Cadonna created KAFKA-12766: - Summary: Consider Disabling WAL-related Options in RocksDB Key: KAFKA-12766 URL: https://issues.apache.org/jira/browse/KAFKA-12766 Project: Kafka Issue Typ

[jira] [Commented] (KAFKA-12766) Consider Disabling WAL-related Options in RocksDB

[ https://issues.apache.org/jira/browse/KAFKA-12766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17341782#comment-17341782 ] Bruno Cadonna commented on KAFKA-12766: --- I think throwing an exception is too hars

[jira] [Commented] (KAFKA-12766) Consider Disabling WAL-related Options in RocksDB

[ https://issues.apache.org/jira/browse/KAFKA-12766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17342337#comment-17342337 ] Bruno Cadonna commented on KAFKA-12766: --- I have to admit that I blindly followed y

[jira] [Commented] (KAFKA-12775) StreamsPartitionAssignor / ClientState throws an exception when a new Task gets added to a KStreams Application in a Backwards-Compatible Topology Change

[ https://issues.apache.org/jira/browse/KAFKA-12775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17343328#comment-17343328 ] Bruno Cadonna commented on KAFKA-12775: --- [~nhab] Thank you for filing this ticket

[jira] [Commented] (KAFKA-12775) StreamsPartitionAssignor / ClientState throws an exception when a new Task gets added to a KStreams Application in a Backwards-Compatible Topology Change

[ https://issues.apache.org/jira/browse/KAFKA-12775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344367#comment-17344367 ] Bruno Cadonna commented on KAFKA-12775: --- [~nhab] Would upgrading all Kafka Streams

[jira] [Commented] (KAFKA-12796) Removal of deprecated classes under `streams-scala`

[ https://issues.apache.org/jira/browse/KAFKA-12796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346023#comment-17346023 ] Bruno Cadonna commented on KAFKA-12796: --- Hi [~josep.prat], Thanks for the ticket!

[jira] [Updated] (KAFKA-12796) Removal of deprecated classes under `streams-scala`

[ https://issues.apache.org/jira/browse/KAFKA-12796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12796: -- Component/s: streams > Removal of deprecated classes under `streams-scala` > -

[jira] [Updated] (KAFKA-12419) Remove Deprecated APIs of Kafka Streams in 3.0

[ https://issues.apache.org/jira/browse/KAFKA-12419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12419: -- Description: Here's a list of deprecated APIs that we have accumulated in the past, we can co

[jira] [Updated] (KAFKA-12419) Remove Deprecated APIs of Kafka Streams in 3.0

[ https://issues.apache.org/jira/browse/KAFKA-12419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12419: -- Description: Here's a list of deprecated APIs that we have accumulated in the past, we can co

[jira] [Commented] (KAFKA-12419) Remove Deprecated APIs of Kafka Streams in 3.0

[ https://issues.apache.org/jira/browse/KAFKA-12419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346057#comment-17346057 ] Bruno Cadonna commented on KAFKA-12419: --- I am not sure we can remove all of them i

[jira] [Commented] (KAFKA-12808) Remove Deprecated methods under StreamsMetrics

[ https://issues.apache.org/jira/browse/KAFKA-12808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17347372#comment-17347372 ] Bruno Cadonna commented on KAFKA-12808: --- Awesome! Thank you [~josep.prat]! I forgo

[jira] [Updated] (KAFKA-12812) Consider refactoring state store registration path

[ https://issues.apache.org/jira/browse/KAFKA-12812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12812: -- Issue Type: Improvement (was: Bug) > Consider refactoring state store registration path > ---

[jira] [Commented] (KAFKA-12812) Consider refactoring state store registration path

[ https://issues.apache.org/jira/browse/KAFKA-12812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17347422#comment-17347422 ] Bruno Cadonna commented on KAFKA-12812: --- [~guozhang] Thank you for the proposal! I

[jira] [Created] (KAFKA-12817) Make Task ID an Implementation Detail

Bruno Cadonna created KAFKA-12817: - Summary: Make Task ID an Implementation Detail Key: KAFKA-12817 URL: https://issues.apache.org/jira/browse/KAFKA-12817 Project: Kafka Issue Type: Improveme

[jira] [Commented] (KAFKA-12629) Flaky Test RaftClusterTest

[ https://issues.apache.org/jira/browse/KAFKA-12629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17349143#comment-17349143 ] Bruno Cadonna commented on KAFKA-12629: --- I confirm that I also see this test fail

[jira] [Updated] (KAFKA-12796) Removal of deprecated classes under `streams-scala`

[ https://issues.apache.org/jira/browse/KAFKA-12796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12796: -- Fix Version/s: 3.0.0 > Removal of deprecated classes under `streams-scala` > -

[jira] [Created] (KAFKA-10119) StreamsResetter fails with TimeoutException for older Brokers

Bruno Cadonna created KAFKA-10119: - Summary: StreamsResetter fails with TimeoutException for older Brokers Key: KAFKA-10119 URL: https://issues.apache.org/jira/browse/KAFKA-10119 Project: Kafka

[jira] [Assigned] (KAFKA-9991) Flaky Test KTableSourceTopicRestartIntegrationTest.shouldRestoreAndProgressWhenTopicWrittenToDuringRestorationWithEosAlphaEnabled

[ https://issues.apache.org/jira/browse/KAFKA-9991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reassigned KAFKA-9991: Assignee: Guozhang Wang > Flaky Test > KTableSourceTopicRestartIntegrationTest.shouldRest

[jira] [Updated] (KAFKA-10119) StreamsResetter fails with TimeoutException for older Brokers

[ https://issues.apache.org/jira/browse/KAFKA-10119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-10119: -- Priority: Blocker (was: Major) > StreamsResetter fails with TimeoutException for older Broker

[jira] [Created] (KAFKA-10137) Clean-up retain Duplicate logic in Window Stores

Bruno Cadonna created KAFKA-10137: - Summary: Clean-up retain Duplicate logic in Window Stores Key: KAFKA-10137 URL: https://issues.apache.org/jira/browse/KAFKA-10137 Project: Kafka Issue Type

[jira] [Assigned] (KAFKA-10148) Kafka Streams Restores too few Records with eos-beta Enabled

[ https://issues.apache.org/jira/browse/KAFKA-10148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reassigned KAFKA-10148: - Assignee: Bruno Cadonna > Kafka Streams Restores too few Records with eos-beta Enabled

[jira] [Created] (KAFKA-10148) Kafka Streams Restores too few Records with eos-beta Enabled

Bruno Cadonna created KAFKA-10148: - Summary: Kafka Streams Restores too few Records with eos-beta Enabled Key: KAFKA-10148 URL: https://issues.apache.org/jira/browse/KAFKA-10148 Project: Kafka

[jira] [Commented] (KAFKA-10119) StreamsResetter fails with TimeoutException for older Brokers

[ https://issues.apache.org/jira/browse/KAFKA-10119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17133096#comment-17133096 ] Bruno Cadonna commented on KAFKA-10119: --- [~ableegoldman] Thank you for taking care

[jira] [Updated] (KAFKA-10148) Kafka Streams Restores too few Records with eos-beta Enabled

[ https://issues.apache.org/jira/browse/KAFKA-10148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-10148: -- Description: System test {{StreamsEosTest.test_failure_and_recovery}} for eos-beta exposes a

[jira] [Updated] (KAFKA-10148) Kafka Streams Restores too few Records with eos-beta Enabled

[ https://issues.apache.org/jira/browse/KAFKA-10148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-10148: -- Description: System test {{StreamsEosTest.test_failure_and_recovery}} for eos-beta exposes a

[jira] [Updated] (KAFKA-10148) Kafka Streams Restores too few Records with eos-beta Enabled

[ https://issues.apache.org/jira/browse/KAFKA-10148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-10148: -- Description: System test {{StreamsEosTest.test_failure_and_recovery}} for eos-beta exposes a

[jira] [Updated] (KAFKA-10148) Kafka Streams Restores too few Records with eos-beta Enabled

[ https://issues.apache.org/jira/browse/KAFKA-10148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-10148: -- Description: System test {{StreamsEosTest.test_failure_and_recovery}} for eos-beta exposes a

[jira] [Updated] (KAFKA-10148) Kafka Streams Restores too few Records with eos-beta Enabled

[ https://issues.apache.org/jira/browse/KAFKA-10148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-10148: -- Description: System test {{StreamsEosTest.test_failure_and_recovery}} for eos-beta exposes a

[jira] [Updated] (KAFKA-10148) Kafka Streams Restores too few Records with eos-beta Enabled

[ https://issues.apache.org/jira/browse/KAFKA-10148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-10148: -- Description: System test {{StreamsEosTest.test_failure_and_recovery}} for eos-beta exposes a

[jira] [Updated] (KAFKA-10148) Kafka Streams Restores too few Records with eos-beta Enabled

[ https://issues.apache.org/jira/browse/KAFKA-10148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-10148: -- Description: System test {{StreamsEosTest.test_failure_and_recovery}} for eos-beta exposes a

[jira] [Updated] (KAFKA-10148) Kafka Streams Restores too few Records with eos-beta Enabled

[ https://issues.apache.org/jira/browse/KAFKA-10148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-10148: -- Description: System test {{StreamsEosTest.test_failure_and_recovery}} for eos-beta exposes a

[jira] [Updated] (KAFKA-10148) Kafka Streams Restores too few Records with eos-beta Enabled

[ https://issues.apache.org/jira/browse/KAFKA-10148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-10148: -- Description: System test {{StreamsEosTest.test_failure_and_recovery}} for eos-beta exposes a

[jira] [Created] (KAFKA-10179) State Store Passes Wrong Changelog Topic to Serde for Optimized Source Tables

Bruno Cadonna created KAFKA-10179: - Summary: State Store Passes Wrong Changelog Topic to Serde for Optimized Source Tables Key: KAFKA-10179 URL: https://issues.apache.org/jira/browse/KAFKA-10179 Proje

[jira] [Assigned] (KAFKA-10179) State Store Passes Wrong Changelog Topic to Serde for Optimized Source Tables

[ https://issues.apache.org/jira/browse/KAFKA-10179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reassigned KAFKA-10179: - Assignee: Bruno Cadonna > State Store Passes Wrong Changelog Topic to Serde for Optimiz

[jira] [Commented] (KAFKA-10179) State Store Passes Wrong Changelog Topic to Serde for Optimized Source Tables

[ https://issues.apache.org/jira/browse/KAFKA-10179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17140328#comment-17140328 ] Bruno Cadonna commented on KAFKA-10179: --- [~desai.p.rohan] While I find the idea of

[jira] [Resolved] (KAFKA-10148) Kafka Streams Restores too few Records with eos-beta Enabled

[ https://issues.apache.org/jira/browse/KAFKA-10148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-10148. --- Resolution: Fixed > Kafka Streams Restores too few Records with eos-beta Enabled >

[jira] [Assigned] (KAFKA-10166) Excessive TaskCorruptedException seen in testing

[ https://issues.apache.org/jira/browse/KAFKA-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reassigned KAFKA-10166: - Assignee: Bruno Cadonna > Excessive TaskCorruptedException seen in testing > --

[jira] [Commented] (KAFKA-10166) Excessive TaskCorruptedException seen in testing

[ https://issues.apache.org/jira/browse/KAFKA-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17144788#comment-17144788 ] Bruno Cadonna commented on KAFKA-10166: --- [~ableegoldman] I agree that splitting is

[jira] [Commented] (KAFKA-10166) Excessive TaskCorruptedException seen in testing

[ https://issues.apache.org/jira/browse/KAFKA-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17146243#comment-17146243 ] Bruno Cadonna commented on KAFKA-10166: --- [~ableegoldman] [~rhauch] Good news rega

[jira] [Updated] (KAFKA-10219) KStream API support for multiple cluster broker

[ https://issues.apache.org/jira/browse/KAFKA-10219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-10219: -- Component/s: (was: KafkaConnect) streams > KStream API support for multip

[jira] [Commented] (KAFKA-10219) KStream API support for multiple cluster broker

[ https://issues.apache.org/jira/browse/KAFKA-10219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17148407#comment-17148407 ] Bruno Cadonna commented on KAFKA-10219: --- [~sachinkurle] The current Kafka Streams

[jira] [Created] (KAFKA-10221) Backport fix for KAFKA-9603 to 2.5

Bruno Cadonna created KAFKA-10221: - Summary: Backport fix for KAFKA-9603 to 2.5 Key: KAFKA-10221 URL: https://issues.apache.org/jira/browse/KAFKA-10221 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-10221) Backport fix for KAFKA-9603 to 2.5

[ https://issues.apache.org/jira/browse/KAFKA-10221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-10221: -- Fix Version/s: 2.5.1 > Backport fix for KAFKA-9603 to 2.5 > -

[jira] [Commented] (KAFKA-10217) Move nodeLevelSensor and storeLevelSensor methods from StreamsMetricsImpl to StreamsMetrics

[ https://issues.apache.org/jira/browse/KAFKA-10217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17152030#comment-17152030 ] Bruno Cadonna commented on KAFKA-10217: --- If the goal of this ticket is to get rid

[jira] [Commented] (KAFKA-10217) Move nodeLevelSensor and storeLevelSensor methods from StreamsMetricsImpl to StreamsMetrics

[ https://issues.apache.org/jira/browse/KAFKA-10217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17152034#comment-17152034 ] Bruno Cadonna commented on KAFKA-10217: --- To use {{nodeLevelSensor()}} in {{Streams

[jira] [Assigned] (KAFKA-10221) Backport fix for KAFKA-9603 to 2.5

[ https://issues.apache.org/jira/browse/KAFKA-10221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reassigned KAFKA-10221: - Assignee: Bruno Cadonna > Backport fix for KAFKA-9603 to 2.5 > ---

[jira] [Commented] (KAFKA-10252) MeteredTimestampedKeyValueStore not setting up correct topic name for GlobalKTable associating StateStores

[ https://issues.apache.org/jira/browse/KAFKA-10252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17154406#comment-17154406 ] Bruno Cadonna commented on KAFKA-10252: --- Thank you for the bug report, [~bulbfreem

[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=17163485#comment-17163485 ] Bruno Cadonna commented on KAFKA-8037: -- I find the idea of putting records in its or

[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=17163485#comment-17163485 ] Bruno Cadonna edited comment on KAFKA-8037 at 7/23/20, 12:04 PM: --

[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=17163485#comment-17163485 ] Bruno Cadonna edited comment on KAFKA-8037 at 7/23/20, 12:21 PM: --

[jira] [Commented] (KAFKA-10287) fix flaky streams/streams_standby_replica_test.py

[ https://issues.apache.org/jira/browse/KAFKA-10287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163911#comment-17163911 ] Bruno Cadonna commented on KAFKA-10287: --- [~chia7712] Sorry, I was not aware that y

[jira] [Commented] (KAFKA-9924) Add RocksDB Memory Consumption to RocksDB Metrics

[ https://issues.apache.org/jira/browse/KAFKA-9924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17164402#comment-17164402 ] Bruno Cadonna commented on KAFKA-9924: -- The scope of this ticket was extended to not

[jira] [Commented] (KAFKA-10292) fix flaky streams/streams_broker_bounce_test.py

[ https://issues.apache.org/jira/browse/KAFKA-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17250224#comment-17250224 ] Bruno Cadonna commented on KAFKA-10292: --- [~chia7712] Sorry for the late reply. I t

[jira] [Comment Edited] (KAFKA-10292) fix flaky streams/streams_broker_bounce_test.py

[ https://issues.apache.org/jira/browse/KAFKA-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17250224#comment-17250224 ] Bruno Cadonna edited comment on KAFKA-10292 at 12/16/20, 10:14 AM: ---

[jira] [Commented] (KAFKA-10843) Kafka Streams metadataForKey method returns null but allMetadata has the details

[ https://issues.apache.org/jira/browse/KAFKA-10843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251690#comment-17251690 ] Bruno Cadonna commented on KAFKA-10843: --- I had another look at the code and I see

[jira] [Comment Edited] (KAFKA-10843) Kafka Streams metadataForKey method returns null but allMetadata has the details

[ https://issues.apache.org/jira/browse/KAFKA-10843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251690#comment-17251690 ] Bruno Cadonna edited comment on KAFKA-10843 at 12/18/20, 11:02 AM: ---

[jira] [Assigned] (KAFKA-12185) Flaky Test StoreQueryIntegrationTest#shouldQueryAllStalePartitionStores

[ https://issues.apache.org/jira/browse/KAFKA-12185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reassigned KAFKA-12185: - Assignee: Bruno Cadonna > Flaky Test StoreQueryIntegrationTest#shouldQueryAllStaleParti

[jira] [Reopened] (KAFKA-12185) Flaky Test StoreQueryIntegrationTest#shouldQueryAllStalePartitionStores

[ https://issues.apache.org/jira/browse/KAFKA-12185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reopened KAFKA-12185: --- > Flaky Test StoreQueryIntegrationTest#shouldQueryAllStalePartitionStores >

[jira] [Assigned] (KAFKA-12185) Flaky Test StoreQueryIntegrationTest#shouldQueryAllStalePartitionStores

[ https://issues.apache.org/jira/browse/KAFKA-12185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reassigned KAFKA-12185: - Assignee: (was: Bruno Cadonna) > Flaky Test StoreQueryIntegrationTest#shouldQueryAl

[jira] [Updated] (KAFKA-12223) Consider not to Treat Mixed Usage of Shared and Dedicated Block Caches among RocksDB State Stores as Illegal State

[ https://issues.apache.org/jira/browse/KAFKA-12223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12223: -- Issue Type: Improvement (was: Bug) > Consider not to Treat Mixed Usage of Shared and Dedicate

[jira] [Created] (KAFKA-12223) Consider not to Treat Mixed Usage of Shared and Dedicated Block Caches among RocksDB State Stores as Illegal State

Bruno Cadonna created KAFKA-12223: - Summary: Consider not to Treat Mixed Usage of Shared and Dedicated Block Caches among RocksDB State Stores as Illegal State Key: KAFKA-12223 URL: https://issues.apache.org/jira/

[jira] [Commented] (KAFKA-12230) Some Kafka TopologyTestDriver-based unit tests can't be run on Windows file system

[ https://issues.apache.org/jira/browse/KAFKA-12230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17269434#comment-17269434 ] Bruno Cadonna commented on KAFKA-12230: --- Hi [~iponomarev], Thank you for the tick

[jira] [Comment Edited] (KAFKA-12230) Some Kafka TopologyTestDriver-based unit tests can't be run on Windows file system

[ https://issues.apache.org/jira/browse/KAFKA-12230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17269434#comment-17269434 ] Bruno Cadonna edited comment on KAFKA-12230 at 1/21/21, 4:57 PM: -

[jira] [Updated] (KAFKA-12247) Make removeStreamThread work better with static membership

[ https://issues.apache.org/jira/browse/KAFKA-12247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12247: -- Labels: (was: streams) > Make removeStreamThread work better with static membership > --

[jira] [Updated] (KAFKA-12247) Make removeStreamThread work better with static membership

[ https://issues.apache.org/jira/browse/KAFKA-12247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12247: -- Component/s: streams > Make removeStreamThread work better with static membership > --

[jira] [Created] (KAFKA-8035) Add tests for generic bounds for KStream API

Bruno Cadonna created KAFKA-8035: Summary: Add tests for generic bounds for KStream API Key: KAFKA-8035 URL: https://issues.apache.org/jira/browse/KAFKA-8035 Project: Kafka Issue Type: Test

[jira] [Updated] (KAFKA-8035) Add tests for generic bounds for KStream API

[ https://issues.apache.org/jira/browse/KAFKA-8035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-8035: - Description: During the work on KAFKA-4217, it was discovered that some combinations of Java gen

[jira] [Updated] (KAFKA-8035) Add tests for generics in KStream API

[ https://issues.apache.org/jira/browse/KAFKA-8035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-8035: - Summary: Add tests for generics in KStream API (was: Add tests for generic bounds for KStream A

[jira] [Updated] (KAFKA-8035) Add tests for generic bounds for KStream API

[ https://issues.apache.org/jira/browse/KAFKA-8035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-8035: - Description: During the work on KAFKA-4217, it was discovered that some combinations of Java gen

<    3   4   5   6   7   8   9   10   11   >