[jira] [Updated] (KAFKA-13973) block-cache-capacity metrics worth twice as much as normal

[ https://issues.apache.org/jira/browse/KAFKA-13973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-13973: -- Fix Version/s: 3.7.0 > block-cache-capacity metrics worth twice as much as normal > --

[jira] [Resolved] (KAFKA-10199) Separate state restoration into separate threads

[ https://issues.apache.org/jira/browse/KAFKA-10199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-10199. --- Resolution: Done > Separate state restoration into separate threads > --

[jira] [Updated] (KAFKA-10199) Separate state restoration into separate threads

[ https://issues.apache.org/jira/browse/KAFKA-10199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-10199: -- Fix Version/s: 3.7.0 > Separate state restoration into separate threads >

[jira] [Commented] (KAFKA-15577) Reload4j | CVE-2022-45868

[ https://issues.apache.org/jira/browse/KAFKA-15577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773985#comment-17773985 ] Bruno Cadonna commented on KAFKA-15577: --- The vulnerability is in the H2 database e

[jira] [Resolved] (KAFKA-15577) Reload4j | CVE-2022-45868

[ https://issues.apache.org/jira/browse/KAFKA-15577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-15577. --- Resolution: Not A Problem > Reload4j | CVE-2022-45868 > - > >

[jira] [Created] (KAFKA-15624) Reconsider synchronisation of methods in RocksDBStore

Bruno Cadonna created KAFKA-15624: - Summary: Reconsider synchronisation of methods in RocksDBStore Key: KAFKA-15624 URL: https://issues.apache.org/jira/browse/KAFKA-15624 Project: Kafka Issue

[jira] [Created] (KAFKA-15625) Do not flush global state store at each commit

Bruno Cadonna created KAFKA-15625: - Summary: Do not flush global state store at each commit Key: KAFKA-15625 URL: https://issues.apache.org/jira/browse/KAFKA-15625 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-15624) Reconsider synchronisation of methods in RocksDBStore

[ https://issues.apache.org/jira/browse/KAFKA-15624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-15624: -- Labels: (was: streams) > Reconsider synchronisation of methods in RocksDBStore > ---

[jira] [Updated] (KAFKA-15624) Reconsider synchronisation of methods in RocksDBStore

[ https://issues.apache.org/jira/browse/KAFKA-15624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-15624: -- Component/s: streams > Reconsider synchronisation of methods in RocksDBStore > ---

[jira] [Resolved] (KAFKA-6498) Add RocksDB statistics via Streams metrics

[ https://issues.apache.org/jira/browse/KAFKA-6498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-6498. -- Resolution: Done > Add RocksDB statistics via Streams metrics > ---

[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: - Fix Version/s: 3.2.0 > Add RocksDB Metrics that Could not be Added due to RocksDB Version > -

[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: -- Priority: Critical (was: Blocker) > Fix Ignored Upgrade Tests in streams_upgrade_test.py: >

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17439095#comment-17439095 ] Bruno Cadonna commented on KAFKA-12291: --- [~dajac] I downgraded it to Critical. Sor

[jira] [Commented] (KAFKA-13009) Metrics recorder is re-initialised with different task

[ https://issues.apache.org/jira/browse/KAFKA-13009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17454070#comment-17454070 ] Bruno Cadonna commented on KAFKA-13009: --- [~fpestke] I am very sorry I've missed yo

[jira] [Comment Edited] (KAFKA-13009) Metrics recorder is re-initialised with different task

[ https://issues.apache.org/jira/browse/KAFKA-13009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17454070#comment-17454070 ] Bruno Cadonna edited comment on KAFKA-13009 at 12/6/21, 3:13 PM: -

[jira] [Assigned] (KAFKA-10199) Separate state restoration into separate threads

[ https://issues.apache.org/jira/browse/KAFKA-10199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reassigned KAFKA-10199: - Assignee: Bruno Cadonna (was: Guozhang Wang) > Separate state restoration into separat

[jira] [Commented] (KAFKA-13500) Consider adding a dedicated standby consumer

[ https://issues.apache.org/jira/browse/KAFKA-13500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17456480#comment-17456480 ] Bruno Cadonna commented on KAFKA-13500: --- I am planning to maintain also the standb

[jira] [Commented] (KAFKA-13600) Rebalances while streams is in degraded state can cause stores to be reassigned and restore from scratch

[ https://issues.apache.org/jira/browse/KAFKA-13600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480081#comment-17480081 ] Bruno Cadonna commented on KAFKA-13600: --- [~tim.patterson] I checked the assignor c

[jira] [Commented] (KAFKA-13600) Rebalances while streams is in degraded state can cause stores to be reassigned and restore from scratch

[ https://issues.apache.org/jira/browse/KAFKA-13600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17485343#comment-17485343 ] Bruno Cadonna commented on KAFKA-13600: --- [~tim.patterson] To come up with a perfec

[jira] [Resolved] (KAFKA-13599) Upgrade RocksDB to 6.27.3

[ https://issues.apache.org/jira/browse/KAFKA-13599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-13599. --- Resolution: Resolved > Upgrade RocksDB to 6.27.3 > - > >

[jira] [Commented] (KAFKA-13638) Slow KTable update when forwarding multiple values from transformer

[ https://issues.apache.org/jira/browse/KAFKA-13638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17486510#comment-17486510 ] Bruno Cadonna commented on KAFKA-13638: --- Hi [~Lejon], Could you try to run your t

[jira] [Comment Edited] (KAFKA-13638) Slow KTable update when forwarding multiple values from transformer

[ https://issues.apache.org/jira/browse/KAFKA-13638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17486510#comment-17486510 ] Bruno Cadonna edited comment on KAFKA-13638 at 2/3/22, 2:09 PM: --

[jira] [Commented] (KAFKA-13638) Slow KTable update when forwarding multiple values from transformer

[ https://issues.apache.org/jira/browse/KAFKA-13638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17486557#comment-17486557 ] Bruno Cadonna commented on KAFKA-13638: --- [~Lejon] Could you also try with https:/

[jira] [Commented] (KAFKA-13638) Slow KTable update when forwarding multiple values from transformer

[ https://issues.apache.org/jira/browse/KAFKA-13638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17486578#comment-17486578 ] Bruno Cadonna commented on KAFKA-13638: --- [~Lejon]Thank you a lot for the testing!

[jira] [Commented] (KAFKA-14922) kafka-streams-application-reset deletes topics not belonging to specified application-id

[ https://issues.apache.org/jira/browse/KAFKA-14922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17714484#comment-17714484 ] Bruno Cadonna commented on KAFKA-14922: --- I see. We could add a warning with the l

[jira] [Commented] (KAFKA-14981) Set `group.instance.id` in streams consumer so that rebalance will not happen if a instance is restarted

[ https://issues.apache.org/jira/browse/KAFKA-14981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17727427#comment-17727427 ] Bruno Cadonna commented on KAFKA-14981: --- I have the same feeling as [~ableegoldman

[jira] [Comment Edited] (KAFKA-15072) Flaky test MirrorConnectorsIntegrationExactlyOnceTest.testReplicationWithEmptyPartition

[ https://issues.apache.org/jira/browse/KAFKA-15072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17731344#comment-17731344 ] Bruno Cadonna edited comment on KAFKA-15072 at 6/11/23 1:05 PM: --

[jira] [Commented] (KAFKA-15072) Flaky test MirrorConnectorsIntegrationExactlyOnceTest.testReplicationWithEmptyPartition

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

[jira] [Commented] (KAFKA-15020) integration.kafka.server.FetchFromFollowerIntegrationTest.testRackAwareRangeAssignor test is flaky

[ https://issues.apache.org/jira/browse/KAFKA-15020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17731526#comment-17731526 ] Bruno Cadonna commented on KAFKA-15020: --- I encountered the same build failure as [

[jira] [Commented] (KAFKA-15052) Fix flaky test QuorumControllerTest.testBalancePartitionLeaders()

[ https://issues.apache.org/jira/browse/KAFKA-15052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17731528#comment-17731528 ] Bruno Cadonna commented on KAFKA-15052: --- I also encountered this here: https://ci

[jira] [Commented] (KAFKA-15072) Flaky test MirrorConnectorsIntegrationExactlyOnceTest.testReplicationWithEmptyPartition

[ https://issues.apache.org/jira/browse/KAFKA-15072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17731529#comment-17731529 ] Bruno Cadonna commented on KAFKA-15072: --- I encountered a failure of {{MirrorConne

[jira] [Commented] (KAFKA-12679) Rebalancing a restoring or running task may cause directory livelocking with newly created task

[ https://issues.apache.org/jira/browse/KAFKA-12679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17732032#comment-17732032 ] Bruno Cadonna commented on KAFKA-12679: --- [~Andras Hatvani] Lucas' PR solves the is

[jira] [Commented] (KAFKA-15187) Add headers to partition method.

[ https://issues.apache.org/jira/browse/KAFKA-15187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17742812#comment-17742812 ] Bruno Cadonna commented on KAFKA-15187: --- I added you to the contributor group. Now

[jira] [Commented] (KAFKA-15187) Add headers to partition method.

[ https://issues.apache.org/jira/browse/KAFKA-15187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17742814#comment-17742814 ] Bruno Cadonna commented on KAFKA-15187: --- In the PR, I see that you want to change

[jira] [Commented] (KAFKA-15193) Allow choosing Platform specific rocksDBJNI jar

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

[jira] [Commented] (KAFKA-15193) Allow choosing Platform specific rocksDBJNI jar

[ https://issues.apache.org/jira/browse/KAFKA-15193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17743865#comment-17743865 ] Bruno Cadonna commented on KAFKA-15193: --- This reduction would only apply to Kafka

[jira] [Updated] (KAFKA-15297) Cache flush order might not be topological order

[ https://issues.apache.org/jira/browse/KAFKA-15297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-15297: -- Attachment: minimal_example.png > Cache flush order might not be topological order >

[jira] [Created] (KAFKA-15297) Cache flush order might not be topological order

Bruno Cadonna created KAFKA-15297: - Summary: Cache flush order might not be topological order Key: KAFKA-15297 URL: https://issues.apache.org/jira/browse/KAFKA-15297 Project: Kafka Issue Typ

[jira] [Updated] (KAFKA-15297) Cache flush order might not be topological order

[ https://issues.apache.org/jira/browse/KAFKA-15297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-15297: -- Description: The flush order of the state store caches in Kafka Streams might not correspond

[jira] [Updated] (KAFKA-15297) Cache flush order might not be topological order

[ https://issues.apache.org/jira/browse/KAFKA-15297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-15297: -- Description: The flush order of the state store caches in Kafka Streams might not correspond

[jira] [Updated] (KAFKA-15297) Cache flush order might not be topological order

[ https://issues.apache.org/jira/browse/KAFKA-15297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-15297: -- Description: The flush order of the state store caches in Kafka Streams might not correspond

[jira] [Updated] (KAFKA-15297) Cache flush order might not be topological order

[ https://issues.apache.org/jira/browse/KAFKA-15297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-15297: -- Description: The flush order of the state store caches in Kafka Streams might not correspond

[jira] [Commented] (KAFKA-15297) Cache flush order might not be topological order

[ https://issues.apache.org/jira/browse/KAFKA-15297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750622#comment-17750622 ] Bruno Cadonna commented on KAFKA-15297: --- [~ableegoldman] You can observe the flush

[jira] [Updated] (KAFKA-15297) Cache flush order might not be topological order

[ https://issues.apache.org/jira/browse/KAFKA-15297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-15297: -- Description: The flush order of the state store caches in Kafka Streams might not correspond

[jira] [Comment Edited] (KAFKA-15297) Cache flush order might not be topological order

[ https://issues.apache.org/jira/browse/KAFKA-15297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750622#comment-17750622 ] Bruno Cadonna edited comment on KAFKA-15297 at 8/3/23 8:09 AM: ---

[jira] [Comment Edited] (KAFKA-15297) Cache flush order might not be topological order

[ https://issues.apache.org/jira/browse/KAFKA-15297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750622#comment-17750622 ] Bruno Cadonna edited comment on KAFKA-15297 at 8/3/23 8:10 AM: ---

[jira] [Updated] (KAFKA-15297) Cache flush order might not be topological order

[ https://issues.apache.org/jira/browse/KAFKA-15297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-15297: -- Description: The flush order of the state store caches in Kafka Streams might not correspond

[jira] [Commented] (KAFKA-15297) Cache flush order might not be topological order

[ https://issues.apache.org/jira/browse/KAFKA-15297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17751932#comment-17751932 ] Bruno Cadonna commented on KAFKA-15297: --- [~guozhang] Yes, I agree the issue is whe

[jira] [Resolved] (KAFKA-15319) Upgrade rocksdb to fix CVE-2022-37434

[ https://issues.apache.org/jira/browse/KAFKA-15319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-15319. --- Resolution: Fixed > Upgrade rocksdb to fix CVE-2022-37434 >

[jira] [Updated] (KAFKA-15765) Remove task level metric "commit-latency"

[ https://issues.apache.org/jira/browse/KAFKA-15765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-15765: -- Priority: Major (was: Blocker) > Remove task level metric "commit-latency" >

[jira] [Updated] (KAFKA-15765) Remove task level metric "commit-latency"

[ https://issues.apache.org/jira/browse/KAFKA-15765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-15765: -- Fix Version/s: 3.7.0 (was: 4.0.0) > Remove task level metric "commit-la

[jira] [Commented] (KAFKA-15865) Ensure consumer.poll() execute autocommit callback

[ https://issues.apache.org/jira/browse/KAFKA-15865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17788376#comment-17788376 ] Bruno Cadonna commented on KAFKA-15865: --- This seems to be blocked on KAFKA-15327 s

[jira] [Assigned] (KAFKA-15281) Implement the groupMetadata Consumer API

[ https://issues.apache.org/jira/browse/KAFKA-15281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reassigned KAFKA-15281: - Assignee: Bruno Cadonna (was: Kirk True) > Implement the groupMetadata Consumer API >

[jira] [Resolved] (KAFKA-15555) Ensure wakeups are handled correctly in PrototypeAsyncConsumer.poll()

[ https://issues.apache.org/jira/browse/KAFKA-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-1. --- Resolution: Fixed > Ensure wakeups are handled correctly in PrototypeAsyncConsumer.poll() >

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

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

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

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

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

[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] [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] [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&focusedCommentId=17279011#comment-17279011 ] Bruno Cadonna commented on KAFKA-7271: -- Split the ticket into two tickets: KAFKA-122

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

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

[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&focusedCommentId=17291220#comment-17291220 ] Bruno Cadonna commented on KAFKA-12375: --- I do not think that the {{java.util.Concu

[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&focusedCommentId=17291777#comment-17291777 ] Bruno Cadonna commented on KAFKA-12375: --- I agree with [~ableegoldman] that ensurin

[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&focusedCommentId=17293179#comment-17293179 ] Bruno Cadonna commented on KAFKA-10788: --- [~rohitdeshaws], Thank you for looking in

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

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

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

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

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

[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&focusedCommentId=17304053#comment-17304053 ] Bruno Cadonna commented on KAFKA-12384: --- Failed again https://ci-builds.apache.o

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

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

[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&focusedCommentId=17304894#comment-17304894 ] Bruno Cadonna commented on KAFKA-12508: --- [~nhab] Thank you for the bug report. I c

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

[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&focusedCommentId=17304915#comment-17304915 ] Bruno Cadonna commented on KAFKA-12508: --- [~ableegoldman], [~mimaison], and [~vvcep

[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&focusedCommentId=17304925#comment-17304925 ] Bruno Cadonna commented on KAFKA-12508: --- You are right! My bad! > Emit-on-change

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

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

[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

<    5   6   7   8   9   10   11   >