[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=17342337#comment-17342337 ] Bruno Cadonna commented on KAFKA-12766: --- I have to admit that I blindly followed your comment

[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=17341782#comment-17341782 ] Bruno Cadonna commented on KAFKA-12766: --- I think throwing an exception is too harsh. Additionally,

[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

[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] [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] [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=17340259#comment-17340259 ] Bruno Cadonna commented on KAFKA-9009: --

[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=17340257#comment-17340257 ] Bruno Cadonna commented on KAFKA-12657: ---

[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-9009) Flaky Test kafka.integration.MetricsDuringTopicCreationDeletionTest.testMetricsDuringTopicCreateDelete

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

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

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

[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=17331171#comment-17331171 ] Bruno Cadonna commented on KAFKA-10493: --- Are you proposing to drop out-of-order records although

[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=17329387#comment-17329387 ] Bruno Cadonna commented on KAFKA-10493: --- Good point about the compaction!   {quote}Sounds like a

[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=17327212#comment-17327212 ] Bruno Cadonna commented on KAFKA-10493: --- The options that I see are: # verify the order during

[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=17320768#comment-17320768 ] Bruno Cadonna commented on KAFKA-12667: --- [~antrenta] Thank you for the ticket! This seems indeed a

[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] [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

[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: 2.7.1 > Incorrect error log on StateDirectory close >

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

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

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

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

[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

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

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

[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] [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

[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=17320051#comment-17320051 ] Bruno Cadonna commented on KAFKA-12650: --- [~mjsax] [~ableegoldman] , Thank you for reporting this

[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=17320005#comment-17320005 ] Bruno Cadonna edited comment on KAFKA-12608 at 4/13/21, 8:01 AM: - Hi

[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=17320005#comment-17320005 ] Bruno Cadonna edited comment on KAFKA-12608 at 4/13/21, 8:04 AM: - Hi

[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=17320005#comment-17320005 ] Bruno Cadonna edited comment on KAFKA-12608 at 4/13/21, 8:01 AM: - Hi

[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=17320005#comment-17320005 ] Bruno Cadonna commented on KAFKA-12608: --- Hi [~jamii], I think [~hpgrahsl] is right. Could you

[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] [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] [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=17306916#comment-17306916 ] Bruno Cadonna commented on KAFKA-12475: --- Yes, I agree with you. I mainly brought this up to have

[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=17306914#comment-17306914 ] Bruno Cadonna commented on KAFKA-12519: --- [~ableegoldman] Good catch! I was sure I did mark it as a

[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: -- Priority: Blocker (was: Major) > Consider Removing Streams Old Built-in Metrics Version >

[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=17306467#comment-17306467 ] Bruno Cadonna commented on KAFKA-12519: --- No, I would either remove the config

[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=17306348#comment-17306348 ] Bruno Cadonna commented on KAFKA-12519: --- Yes, that is correct. For AK 3.0, we could only remove

[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: -- Issue Type: Task (was: Improvement) > Consider Removing Streams Old Built-in Metrics Version

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

Bruno Cadonna created KAFKA-12519: - Summary: Consider Removing Streams Old Built-in Metrics Version Key: KAFKA-12519 URL: https://issues.apache.org/jira/browse/KAFKA-12519 Project: Kafka

[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=17306060#comment-17306060 ] Bruno Cadonna commented on KAFKA-12475: --- [~guozhang] Good point about bookkeeping.

[jira] [Commented] (KAFKA-12508) Emit-on-change tables may lose updates on error or restart in at_least_once

[ https://issues.apache.org/jira/browse/KAFKA-12508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17304925#comment-17304925 ] Bruno Cadonna commented on KAFKA-12508: --- You are right! My bad! > Emit-on-change tables may lose

[jira] [Commented] (KAFKA-12508) Emit-on-change tables may lose updates on error or restart in at_least_once

[ https://issues.apache.org/jira/browse/KAFKA-12508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17304915#comment-17304915 ] Bruno Cadonna commented on KAFKA-12508: --- [~ableegoldman], [~mimaison], and [~vvcephei], I set this

[jira] [Updated] (KAFKA-12508) Emit-on-change tables may lose updates on error or restart in at_least_once

[ https://issues.apache.org/jira/browse/KAFKA-12508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12508: -- Fix Version/s: 2.6.2 2.7.1 2.8.0 > Emit-on-change

[jira] [Commented] (KAFKA-12508) Emit-on-change tables may lose updates on error or restart in at_least_once

[ https://issues.apache.org/jira/browse/KAFKA-12508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17304894#comment-17304894 ] Bruno Cadonna commented on KAFKA-12508: --- [~nhab] Thank you for the bug report. I could reproduce

[jira] [Assigned] (KAFKA-12508) Emit-on-change tables may lose updates on error or restart in at_least_once

[ https://issues.apache.org/jira/browse/KAFKA-12508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reassigned KAFKA-12508: - Assignee: Bruno Cadonna > Emit-on-change tables may lose updates on error or restart

[jira] [Updated] (KAFKA-12508) Emit-on-change tables may lose updates on error or restart in at_least_once

[ https://issues.apache.org/jira/browse/KAFKA-12508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12508: -- Priority: Blocker (was: Major) > Emit-on-change tables may lose updates on error or restart

[jira] [Commented] (KAFKA-12384) Flaky Test ListOffsetsRequestTest.testResponseIncludesLeaderEpoch

[ https://issues.apache.org/jira/browse/KAFKA-12384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17304053#comment-17304053 ] Bruno Cadonna commented on KAFKA-12384: --- Failed again

[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=17302336#comment-17302336 ] Bruno Cadonna commented on KAFKA-12475: --- Another aspect that we need to consider here is that with

[jira] [Closed] (KAFKA-10293) fix flaky streams/streams_eos_test.py

[ https://issues.apache.org/jira/browse/KAFKA-10293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-10293. - > fix flaky streams/streams_eos_test.py > - > >

[jira] [Closed] (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:all-tabpanel ] Bruno Cadonna closed KAFKA-10287. - > fix flaky streams/streams_standby_replica_test.py >

[jira] [Closed] (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 closed KAFKA-10166. - > Excessive TaskCorruptedException seen in testing >

[jira] [Closed] (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 closed KAFKA-10148. - > Kafka Streams Restores too few Records with eos-beta Enabled >

[jira] [Closed] (KAFKA-9173) StreamsPartitionAssignor assigns partitions to only one worker

[ https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-9173. > StreamsPartitionAssignor assigns partitions to only one worker >

[jira] [Closed] (KAFKA-8263) Flaky Test MetricsIntegrationTest#testStreamMetricOfWindowStore

[ https://issues.apache.org/jira/browse/KAFKA-8263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-8263. > Flaky Test MetricsIntegrationTest#testStreamMetricOfWindowStore >

[jira] [Closed] (KAFKA-8262) Flaky Test MetricsIntegrationTest#testStreamMetric

[ https://issues.apache.org/jira/browse/KAFKA-8262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-8262. > Flaky Test MetricsIntegrationTest#testStreamMetric >

[jira] [Closed] (KAFKA-10772) java.lang.IllegalStateException: There are insufficient bytes available to read assignment from the sync-group response (actual byte size 0)

[ https://issues.apache.org/jira/browse/KAFKA-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-10772. - > java.lang.IllegalStateException: There are insufficient bytes available to > read assignment

[jira] [Closed] (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 closed KAFKA-10221. - > Backport fix for KAFKA-9603 to 2.5 > --- > >

[jira] [Closed] (KAFKA-10355) Handle accidental deletion of source-topics as exceptional failure

[ https://issues.apache.org/jira/browse/KAFKA-10355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-10355. - > Handle accidental deletion of source-topics as exceptional failure >

[jira] [Closed] (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 closed KAFKA-10179. - > State Store Passes Wrong Changelog Topic to Serde for Optimized Source Tables >

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

[ https://issues.apache.org/jira/browse/KAFKA-9924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-9924. > Add RocksDB Memory Consumption to RocksDB Metrics >

[jira] [Closed] (KAFKA-9664) Flaky Test KafkaStreamsTest#testStateThreadClose

[ https://issues.apache.org/jira/browse/KAFKA-9664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-9664. > Flaky Test KafkaStreamsTest#testStateThreadClose >

[jira] [Closed] (KAFKA-9770) Caching State Store does not Close Underlying State Store When Exception is Thrown During Flushing

[ https://issues.apache.org/jira/browse/KAFKA-9770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-9770. > Caching State Store does not Close Underlying State Store When Exception is > Thrown During

[jira] [Closed] (KAFKA-9675) RocksDB metrics reported always at zero

[ https://issues.apache.org/jira/browse/KAFKA-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-9675. > RocksDB metrics reported always at zero > --- > >

[jira] [Closed] (KAFKA-9355) RocksDB statistics are removed from JMX when EOS enabled and empty local state dir

[ https://issues.apache.org/jira/browse/KAFKA-9355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-9355. > RocksDB statistics are removed from JMX when EOS enabled and empty local > state dir >

[jira] [Closed] (KAFKA-9603) Number of open files keeps increasing in Streams application

[ https://issues.apache.org/jira/browse/KAFKA-9603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-9603. > Number of open files keeps increasing in Streams application >

[jira] [Closed] (KAFKA-9606) Document Metrics Changes from KIP-444

[ https://issues.apache.org/jira/browse/KAFKA-9606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-9606. > Document Metrics Changes from KIP-444 > - > >

[jira] [Closed] (KAFKA-8578) Add Functionality to Expose RocksDB Metrics

[ https://issues.apache.org/jira/browse/KAFKA-8578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-8578. > Add Functionality to Expose RocksDB Metrics > --- > >

[jira] [Closed] (KAFKA-8579) Expose RocksDB Metrics to JMX

[ https://issues.apache.org/jira/browse/KAFKA-8579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-8579. > Expose RocksDB Metrics to JMX > - > > Key: KAFKA-8579 >

[jira] [Commented] (KAFKA-10788) Streamlining Tests in CachingInMemoryKeyValueStoreTest

[ https://issues.apache.org/jira/browse/KAFKA-10788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17293179#comment-17293179 ] Bruno Cadonna commented on KAFKA-10788: --- [~rohitdeshaws], Thank you for looking into this! # I

[jira] [Commented] (KAFKA-12375) ReplaceStreamThread creates a new consumer with the same name as the one it's replacing

[ https://issues.apache.org/jira/browse/KAFKA-12375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17291777#comment-17291777 ] Bruno Cadonna commented on KAFKA-12375: --- I agree with [~ableegoldman] that ensuring a unique

[jira] [Commented] (KAFKA-12375) ReplaceStreamThread creates a new consumer with the same name as the one it's replacing

[ https://issues.apache.org/jira/browse/KAFKA-12375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17291220#comment-17291220 ] Bruno Cadonna commented on KAFKA-12375: --- I do not think that the

[jira] [Updated] (KAFKA-12291) Fix Ignored Upgrade Tests in streams_upgrade_test.py: test_upgrade_downgrade_brokers

[ https://issues.apache.org/jira/browse/KAFKA-12291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12291: -- Fix Version/s: 3.0.0 > Fix Ignored Upgrade Tests in streams_upgrade_test.py: >

[jira] [Resolved] (KAFKA-7271) Fix ignored test in streams_upgrade_test.py: test_upgrade_downgrade_brokers

[ https://issues.apache.org/jira/browse/KAFKA-7271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-7271. -- Resolution: Duplicate > Fix ignored test in streams_upgrade_test.py:

[jira] [Commented] (KAFKA-7271) Fix ignored test in streams_upgrade_test.py: test_upgrade_downgrade_brokers

[ https://issues.apache.org/jira/browse/KAFKA-7271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17279011#comment-17279011 ] Bruno Cadonna commented on KAFKA-7271: -- Split the ticket into two tickets: KAFKA-12292 and

[jira] [Created] (KAFKA-12292) Fix Ignored Downgrade Tests in streams_upgrade_test.py: test_upgrade_downgrade_brokers

Bruno Cadonna created KAFKA-12292: - Summary: Fix Ignored Downgrade Tests in streams_upgrade_test.py: test_upgrade_downgrade_brokers Key: KAFKA-12292 URL: https://issues.apache.org/jira/browse/KAFKA-12292

[jira] [Created] (KAFKA-12291) Fix Ignored Upgrade Tests in streams_upgrade_test.py: test_upgrade_downgrade_brokers

Bruno Cadonna created KAFKA-12291: - Summary: Fix Ignored Upgrade Tests in streams_upgrade_test.py: test_upgrade_downgrade_brokers Key: KAFKA-12291 URL: https://issues.apache.org/jira/browse/KAFKA-12291

[jira] [Updated] (KAFKA-7271) Fix ignored test in streams_upgrade_test.py: test_upgrade_downgrade_brokers

[ https://issues.apache.org/jira/browse/KAFKA-7271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-7271: - Priority: Blocker (was: Critical) > Fix ignored test in streams_upgrade_test.py:

[jira] [Updated] (KAFKA-9588) Add rocksdb event listeners in KS

[ https://issues.apache.org/jira/browse/KAFKA-9588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-9588: - Fix Version/s: (was: 3.0.0) > Add rocksdb event listeners in KS >

[jira] [Updated] (KAFKA-12184) Once the Error Classification is better update the default streams uncaught exception handler to replace threads

[ https://issues.apache.org/jira/browse/KAFKA-12184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12184: -- Fix Version/s: (was: 3.0.0) > Once the Error Classification is better update the default

[jira] [Updated] (KAFKA-9881) Verify whether RocksDBMetrics Get Measurements from RocksDB in a Unit Test instead of an Intergration Test

[ https://issues.apache.org/jira/browse/KAFKA-9881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-9881: - Fix Version/s: 2.6.0 > Verify whether RocksDBMetrics Get Measurements from RocksDB in a Unit

[jira] [Assigned] (KAFKA-9881) Verify whether RocksDBMetrics Get Measurements from RocksDB in a Unit Test instead of an Intergration Test

[ https://issues.apache.org/jira/browse/KAFKA-9881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reassigned KAFKA-9881: Assignee: Bruno Cadonna > Verify whether RocksDBMetrics Get Measurements from RocksDB in

[jira] [Closed] (KAFKA-9881) Verify whether RocksDBMetrics Get Measurements from RocksDB in a Unit Test instead of an Intergration Test

[ https://issues.apache.org/jira/browse/KAFKA-9881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-9881. > Verify whether RocksDBMetrics Get Measurements from RocksDB in a Unit Test > instead of an

[jira] [Resolved] (KAFKA-9881) Verify whether RocksDBMetrics Get Measurements from RocksDB in a Unit Test instead of an Intergration Test

[ https://issues.apache.org/jira/browse/KAFKA-9881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-9881. -- Resolution: Fixed > Verify whether RocksDBMetrics Get Measurements from RocksDB in a Unit Test

[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] [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] [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=17269434#comment-17269434 ] Bruno Cadonna edited comment on KAFKA-12230 at 1/21/21, 4:57 PM: - Hi

[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=17269434#comment-17269434 ] Bruno Cadonna commented on KAFKA-12230: --- Hi [~iponomarev], Thank you for the ticket and the PR.

[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:

[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

[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

[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: Bruno Cadonna > Flaky Test

[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=17251690#comment-17251690 ] Bruno Cadonna edited comment on KAFKA-10843 at 12/18/20, 11:02 AM: --- I

[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=17251690#comment-17251690 ] Bruno Cadonna commented on KAFKA-10843: --- I had another look at the code and I see two options

[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=17250224#comment-17250224 ] Bruno Cadonna edited comment on KAFKA-10292 at 12/16/20, 10:14 AM: ---

[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=17250224#comment-17250224 ] Bruno Cadonna commented on KAFKA-10292: --- [~chia7712] Sorry for the late reply. I think the fix

[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=17249674#comment-17249674 ] Bruno Cadonna commented on KAFKA-10843: --- [~maria_87] What do you mean exactly with "stretch

[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=17247886#comment-17247886 ] Bruno Cadonna commented on KAFKA-10843: --- [~maria_87] Thank you for the report! {{allMetadata()}}

[jira] [Comment Edited] (KAFKA-10772) java.lang.IllegalStateException: There are insufficient bytes available to read assignment from the sync-group response (actual byte size 0)

[ https://issues.apache.org/jira/browse/KAFKA-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17247142#comment-17247142 ] Bruno Cadonna edited comment on KAFKA-10772 at 12/10/20, 10:13 AM: ---

[jira] [Resolved] (KAFKA-10772) java.lang.IllegalStateException: There are insufficient bytes available to read assignment from the sync-group response (actual byte size 0)

[ https://issues.apache.org/jira/browse/KAFKA-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-10772. --- Resolution: Duplicate > java.lang.IllegalStateException: There are insufficient bytes

<    1   2   3   4   5   6   7   8   9   10   >