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

2019-03-04 Thread Bruno Cadonna (JIRA)
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] [Resolved] (KAFKA-8441) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenCreated

2019-05-30 Thread Bruno Cadonna (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-8441. -- Resolution: Invalid > Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenCreated

[jira] [Resolved] (KAFKA-8440) Flaky Test KStreamAggregationIntegrationTest#shouldReduceSessionWindows

2019-05-30 Thread Bruno Cadonna (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-8440. -- Resolution: Invalid > Flaky Test KStreamAggregationIntegrationTest#shouldReduceSessionWindows

[jira] [Created] (KAFKA-8441) CLONE - Flaky Test KStreamAggregationIntegrationTest#shouldReduceSessionWindows

2019-05-28 Thread Bruno Cadonna (JIRA)
Bruno Cadonna created KAFKA-8441: Summary: CLONE - Flaky Test KStreamAggregationIntegrationTest#shouldReduceSessionWindows Key: KAFKA-8441 URL: https://issues.apache.org/jira/browse/KAFKA-8441

[jira] [Created] (KAFKA-8440) Flaky Test KStreamAggregationIntegrationTest#shouldReduceSessionWindows

2019-05-28 Thread Bruno Cadonna (JIRA)
Bruno Cadonna created KAFKA-8440: Summary: Flaky Test KStreamAggregationIntegrationTest#shouldReduceSessionWindows Key: KAFKA-8440 URL: https://issues.apache.org/jira/browse/KAFKA-8440 Project: Kafka

[jira] [Resolved] (KAFKA-8497) kafka streams application takes up a lot of memory

2019-06-06 Thread Bruno Cadonna (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-8497. -- Resolution: Invalid > kafka streams application takes up a lot of memory >

[jira] [Created] (KAFKA-8602) StreamThread Dies Because Restore Consumer is not Subscribed to Any Topic

2019-06-25 Thread Bruno Cadonna (JIRA)
Bruno Cadonna created KAFKA-8602: Summary: StreamThread Dies Because Restore Consumer is not Subscribed to Any Topic Key: KAFKA-8602 URL: https://issues.apache.org/jira/browse/KAFKA-8602 Project:

[jira] [Created] (KAFKA-8580) Compute RocksDB Metrics

2019-06-21 Thread Bruno Cadonna (JIRA)
Bruno Cadonna created KAFKA-8580: Summary: Compute RocksDB Metrics Key: KAFKA-8580 URL: https://issues.apache.org/jira/browse/KAFKA-8580 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-8578) Add Sensors and Metrics to Expose RocksDB Metrics

2019-06-21 Thread Bruno Cadonna (JIRA)
Bruno Cadonna created KAFKA-8578: Summary: Add Sensors and Metrics to Expose RocksDB Metrics Key: KAFKA-8578 URL: https://issues.apache.org/jira/browse/KAFKA-8578 Project: Kafka Issue Type:

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

2019-06-21 Thread Bruno Cadonna (JIRA)
Bruno Cadonna created KAFKA-8579: Summary: Expose RocksDB Metrics to JMX Key: KAFKA-8579 URL: https://issues.apache.org/jira/browse/KAFKA-8579 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-8613) Set default grace period to 0

2019-06-28 Thread Bruno Cadonna (JIRA)
Bruno Cadonna created KAFKA-8613: Summary: Set default grace period to 0 Key: KAFKA-8613 URL: https://issues.apache.org/jira/browse/KAFKA-8613 Project: Kafka Issue Type: Improvement

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

2019-08-27 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-8579. -- Resolution: Fixed > Expose RocksDB Metrics to JMX > - > >

[jira] [Created] (KAFKA-8856) Add Streams Config for Backward-compatible Metrics

2019-09-02 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-8856: Summary: Add Streams Config for Backward-compatible Metrics Key: KAFKA-8856 URL: https://issues.apache.org/jira/browse/KAFKA-8856 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-8859) Refactor Cache-level Streams Metrics

2019-09-02 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-8859: Summary: Refactor Cache-level Streams Metrics Key: KAFKA-8859 URL: https://issues.apache.org/jira/browse/KAFKA-8859 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-8856) Add Streams Config for Backward-compatible Metrics

2019-09-11 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-8856. -- Resolution: Fixed > Add Streams Config for Backward-compatible Metrics >

[jira] [Created] (KAFKA-8906) Metrics for Key-Value, Window, and Session Stores are Inconsistent

2019-09-13 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-8906: Summary: Metrics for Key-Value, Window, and Session Stores are Inconsistent Key: KAFKA-8906 URL: https://issues.apache.org/jira/browse/KAFKA-8906 Project: Kafka

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

2019-09-11 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-8897: Summary: Increase Version of RocksDB Key: KAFKA-8897 URL: https://issues.apache.org/jira/browse/KAFKA-8897 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-8755) Stand-by Task of an Optimized Source Table Does Not Write Anything to its State Store

2019-08-05 Thread Bruno Cadonna (JIRA)
Bruno Cadonna created KAFKA-8755: Summary: Stand-by Task of an Optimized Source Table Does Not Write Anything to its State Store Key: KAFKA-8755 URL: https://issues.apache.org/jira/browse/KAFKA-8755

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

2019-08-08 Thread Bruno Cadonna (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-8578. -- Resolution: Done > Add Functionality to Expose RocksDB Metrics >

[jira] [Created] (KAFKA-8964) Refactor Stream-Thread-level Metrics

2019-10-01 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-8964: Summary: Refactor Stream-Thread-level Metrics Key: KAFKA-8964 URL: https://issues.apache.org/jira/browse/KAFKA-8964 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-8934) Introduce Instance-level Metrics

2019-09-24 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-8934: Summary: Introduce Instance-level Metrics Key: KAFKA-8934 URL: https://issues.apache.org/jira/browse/KAFKA-8934 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-8968) Refactor Task-level Metrics

2019-10-02 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-8968: Summary: Refactor Task-level Metrics Key: KAFKA-8968 URL: https://issues.apache.org/jira/browse/KAFKA-8968 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-8960) Move Task {{determineCommitId}} in {{gradle.build}} to Project Level

2019-09-29 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-8960: Summary: Move Task {{determineCommitId}} in {{gradle.build}} to Project Level Key: KAFKA-8960 URL: https://issues.apache.org/jira/browse/KAFKA-8960 Project: Kafka

[jira] [Created] (KAFKA-8977) Remove MockStreamsMetrics Since it is not a Mock

2019-10-04 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-8977: Summary: Remove MockStreamsMetrics Since it is not a Mock Key: KAFKA-8977 URL: https://issues.apache.org/jira/browse/KAFKA-8977 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-9115) Add Roll-up Throughput Sensor for Processing on Source Nodes

2019-10-30 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-9115: Summary: Add Roll-up Throughput Sensor for Processing on Source Nodes Key: KAFKA-9115 URL: https://issues.apache.org/jira/browse/KAFKA-9115 Project: Kafka

[jira] [Created] (KAFKA-9152) Improve Sensor Retrieval

2019-11-06 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-9152: Summary: Improve Sensor Retrieval Key: KAFKA-9152 URL: https://issues.apache.org/jira/browse/KAFKA-9152 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-9117) Add active-process-ratio Metric

2019-10-30 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-9117: Summary: Add active-process-ratio Metric Key: KAFKA-9117 URL: https://issues.apache.org/jira/browse/KAFKA-9117 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-9195) Use Randomized State Directory Names in Streams System Tests

2019-11-15 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-9195: Summary: Use Randomized State Directory Names in Streams System Tests Key: KAFKA-9195 URL: https://issues.apache.org/jira/browse/KAFKA-9195 Project: Kafka

[jira] [Resolved] (KAFKA-8964) Refactor Stream-Thread-level Metrics

2019-10-21 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-8964. -- Resolution: Fixed > Refactor Stream-Thread-level Metrics >

[jira] [Created] (KAFKA-9109) Get Rid of Cast from ProcessorContext to InternalProcessorContext

2019-10-29 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-9109: Summary: Get Rid of Cast from ProcessorContext to InternalProcessorContext Key: KAFKA-9109 URL: https://issues.apache.org/jira/browse/KAFKA-9109 Project: Kafka

[jira] [Created] (KAFKA-9086) Remove destroy-rate and create-rate Streams Metrics

2019-10-23 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-9086: Summary: Remove destroy-rate and create-rate Streams Metrics Key: KAFKA-9086 URL: https://issues.apache.org/jira/browse/KAFKA-9086 Project: Kafka Issue

[jira] [Created] (KAFKA-9088) Consolidate InternalMockProcessorContext and MockInternalProcessorContext

2019-10-23 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-9088: Summary: Consolidate InternalMockProcessorContext and MockInternalProcessorContext Key: KAFKA-9088 URL: https://issues.apache.org/jira/browse/KAFKA-9088 Project:

[jira] [Created] (KAFKA-9230) Change User Customizable Metrics API in StreamsMetrics interface

2019-11-26 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-9230: Summary: Change User Customizable Metrics API in StreamsMetrics interface Key: KAFKA-9230 URL: https://issues.apache.org/jira/browse/KAFKA-9230 Project: Kafka

[jira] [Created] (KAFKA-9129) Add Thread ID to the InternalProcessorContext

2019-11-01 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-9129: Summary: Add Thread ID to the InternalProcessorContext Key: KAFKA-9129 URL: https://issues.apache.org/jira/browse/KAFKA-9129 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-8580) Compute RocksDB Metrics

2019-09-25 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-8580. -- Resolution: Done > Compute RocksDB Metrics > --- > > Key:

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

2019-09-25 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-8941: Summary: Add RocksDB Metrics that Could not be Added due to RocksDB Version Key: KAFKA-8941 URL: https://issues.apache.org/jira/browse/KAFKA-8941 Project: Kafka

[jira] [Created] (KAFKA-8942) Document RocksDB metrics

2019-09-25 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-8942: Summary: Document RocksDB metrics Key: KAFKA-8942 URL: https://issues.apache.org/jira/browse/KAFKA-8942 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-8934) Introduce Instance-level Metrics

2019-10-07 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-8934. -- Fix Version/s: 2.4.0 Resolution: Fixed > Introduce Instance-level Metrics >

[jira] [Resolved] (KAFKA-9005) Kafka stream: “TopicAuthorizationException: Not authorized to access topics” for an internal state store

2019-10-10 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-9005. -- Resolution: Not A Bug > Kafka stream: “TopicAuthorizationException: Not authorized to access

[jira] [Created] (KAFKA-9013) Flaky Test MirrorConnectorsIntegrationTest#testReplication

2019-10-10 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-9013: Summary: Flaky Test MirrorConnectorsIntegrationTest#testReplication Key: KAFKA-9013 URL: https://issues.apache.org/jira/browse/KAFKA-9013 Project: Kafka

[jira] [Created] (KAFKA-9000) Flaky Test KTableKTableForeignKeyJoinIntegrationTest.doLeftJoinFromRightThenDeleteRightEntity

2019-10-08 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-9000: Summary: Flaky Test KTableKTableForeignKeyJoinIntegrationTest.doLeftJoinFromRightThenDeleteRightEntity Key: KAFKA-9000 URL: https://issues.apache.org/jira/browse/KAFKA-9000

[jira] [Created] (KAFKA-8980) Refactor State-Store-level Metrics

2019-10-04 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-8980: Summary: Refactor State-Store-level Metrics Key: KAFKA-8980 URL: https://issues.apache.org/jira/browse/KAFKA-8980 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-9030) Document Instance-level Metrics

2019-10-11 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-9030: Summary: Document Instance-level Metrics Key: KAFKA-9030 URL: https://issues.apache.org/jira/browse/KAFKA-9030 Project: Kafka Issue Type: Bug

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

2020-02-25 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-9606: Summary: Document Metrics Changes from KIP-444 Key: KAFKA-9606 URL: https://issues.apache.org/jira/browse/KAFKA-9606 Project: Kafka Issue Type: Task

[jira] [Resolved] (KAFKA-9230) Change User Customizable Metrics API in StreamsMetrics interface

2020-02-02 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-9230. -- Resolution: Fixed > Change User Customizable Metrics API in StreamsMetrics interface >

[jira] [Resolved] (KAFKA-9115) Add Roll-up Throughput Sensor for Processing on Source Nodes

2020-02-02 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-9115. -- Resolution: Fixed > Add Roll-up Throughput Sensor for Processing on Source Nodes >

[jira] [Created] (KAFKA-9480) Value for Task-level Metric process-rate is Constant Zero

2020-01-28 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-9480: Summary: Value for Task-level Metric process-rate is Constant Zero Key: KAFKA-9480 URL: https://issues.apache.org/jira/browse/KAFKA-9480 Project: Kafka

[jira] [Created] (KAFKA-9572) Sum Computation with Exactly-Once Enabled and Injected Failures Misses Some Records

2020-02-19 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-9572: Summary: Sum Computation with Exactly-Once Enabled and Injected Failures Misses Some Records Key: KAFKA-9572 URL: https://issues.apache.org/jira/browse/KAFKA-9572

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

2020-04-15 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-9664. -- Resolution: Cannot Reproduce > Flaky Test KafkaStreamsTest#testStateThreadClose >

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

2020-04-16 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-9881: Summary: Verify whether RocksDBMetrics Get Measurements from RocksDB in a Unit Test instead of a Intergration Test Key: KAFKA-9881 URL:

[jira] [Resolved] (KAFKA-9117) Add active-process-ratio Metric

2020-04-16 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-9117. -- Fix Version/s: (was: 2.6.0) Resolution: Duplicate > Add active-process-ratio Metric

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

2020-03-26 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-9770: Summary: Caching State Store does not Close Underlying State Store When Exception is Thrown During Flushing Key: KAFKA-9770 URL: https://issues.apache.org/jira/browse/KAFKA-9770

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

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

[jira] [Created] (KAFKA-9916) Materialize Table-Table Join Result to Avoid Performing Same Join Twice

2020-04-24 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-9916: Summary: Materialize Table-Table Join Result to Avoid Performing Same Join Twice Key: KAFKA-9916 URL: https://issues.apache.org/jira/browse/KAFKA-9916 Project: Kafka

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

2020-04-28 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-9924: Summary: Add RocksDB Memory Consumption to RocksDB Metrics Key: KAFKA-9924 URL: https://issues.apache.org/jira/browse/KAFKA-9924 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-9936) kafka-streams 2.5.0 missing dependency?

2020-04-30 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-9936. -- Resolution: Not A Bug > kafka-streams 2.5.0 missing dependency? >

[jira] [Resolved] (KAFKA-5948) EosIntegrationTest fails with TopicAlreadyMarkedForDeletionException

2020-05-12 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-5948. -- Resolution: Cannot Reproduce > EosIntegrationTest fails with

[jira] [Created] (KAFKA-10015) React to Unexpected Errors on Stream Threads

2020-05-18 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-10015: - Summary: React to Unexpected Errors on Stream Threads Key: KAFKA-10015 URL: https://issues.apache.org/jira/browse/KAFKA-10015 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-6039) Improve TaskAssignor to be more load balanced

2020-05-15 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-6039. -- Resolution: Duplicate > Improve TaskAssignor to be more load balanced >

[jira] [Resolved] (KAFKA-5578) Streams Task Assignor should consider the staleness of state directories when allocating tasks

2020-05-15 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-5578. -- Resolution: Duplicate > Streams Task Assignor should consider the staleness of state

[jira] [Created] (KAFKA-9738) Add Generics Type Parameters to forwarded() in MockProcessorContext

2020-03-20 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-9738: Summary: Add Generics Type Parameters to forwarded() in MockProcessorContext Key: KAFKA-9738 URL: https://issues.apache.org/jira/browse/KAFKA-9738 Project: Kafka

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

2020-05-22 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-9173. -- Fix Version/s: 2.6.0 Resolution: Fixed > StreamsPartitionAssignor assigns partitions to

[jira] [Created] (KAFKA-10484) Reduce Metrics Exposed by Streams

2020-09-15 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-10484: - Summary: Reduce Metrics Exposed by Streams Key: KAFKA-10484 URL: https://issues.apache.org/jira/browse/KAFKA-10484 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-10481) Consider Improving the Success Criteria of Streams' System Test StreamsBrokerBounceTest

2020-09-14 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-10481: - Summary: Consider Improving the Success Criteria of Streams' System Test StreamsBrokerBounceTest Key: KAFKA-10481 URL: https://issues.apache.org/jira/browse/KAFKA-10481

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

2020-09-07 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-9924. -- Resolution: Fixed > Add RocksDB Memory Consumption to RocksDB Metrics >

[jira] [Resolved] (KAFKA-9585) Flaky Test: LagFetchIntegrationTest#shouldFetchLagsDuringRebalancingWithOptimization

2020-10-05 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-9585. -- Resolution: Cannot Reproduce > Flaky Test: >

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

2020-08-25 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-10293. --- Resolution: Fixed > fix flaky streams/streams_eos_test.py >

[jira] [Created] (KAFKA-10500) Add API to Start and Stop Stream Threads

2020-09-18 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-10500: - Summary: Add API to Start and Stop Stream Threads Key: KAFKA-10500 URL: https://issues.apache.org/jira/browse/KAFKA-10500 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-10397) Do not Expose Statistics-based RocksDB Metrics If User Provides Statistics Object

2020-08-13 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-10397: - Summary: Do not Expose Statistics-based RocksDB Metrics If User Provides Statistics Object Key: KAFKA-10397 URL: https://issues.apache.org/jira/browse/KAFKA-10397

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

2020-06-30 Thread Bruno Cadonna (Jira)
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] [Created] (KAFKA-10179) State Store Passes Wrong Changelog Topic to Serde for Optimized Source Tables

2020-06-17 Thread Bruno Cadonna (Jira)
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

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

2020-06-19 Thread Bruno Cadonna (Jira)
[ 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] [Created] (KAFKA-10137) Clean-up retain Duplicate logic in Window Stores

2020-06-10 Thread Bruno Cadonna (Jira)
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

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

2020-06-08 Thread Bruno Cadonna (Jira)
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] [Created] (KAFKA-10148) Kafka Streams Restores too few Records with eos-beta Enabled

2020-06-11 Thread Bruno Cadonna (Jira)
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] [Resolved] (KAFKA-10772) java.lang.IllegalStateException: There are insufficient bytes available to read assignment from the sync-group response (actual byte size 0)

2020-12-10 Thread Bruno Cadonna (Jira)
[ 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

[jira] [Created] (KAFKA-10631) ProducerFencedException is not Handled on Offest Commit

2020-10-22 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-10631: - Summary: ProducerFencedException is not Handled on Offest Commit Key: KAFKA-10631 URL: https://issues.apache.org/jira/browse/KAFKA-10631 Project: Kafka

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

2021-01-14 Thread Bruno Cadonna (Jira)
[ 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] [Created] (KAFKA-12223) Consider not to Treat Mixed Usage of Shared and Dedicated Block Caches among RocksDB State Stores as Illegal State

2021-01-18 Thread Bruno Cadonna (Jira)
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] [Resolved] (KAFKA-9881) Verify whether RocksDBMetrics Get Measurements from RocksDB in a Unit Test instead of an Intergration Test

2021-02-02 Thread Bruno Cadonna (Jira)
[ 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] [Resolved] (KAFKA-8897) Increase Version of RocksDB

2021-05-10 Thread Bruno Cadonna (Jira)
[ 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] [Created] (KAFKA-12766) Consider Disabling WAL-related Options in RocksDB

2021-05-10 Thread Bruno Cadonna (Jira)
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] [Resolved] (KAFKA-10767) Add Unit Test cases for missing methods in ThreadCacheTest

2021-05-06 Thread Bruno Cadonna (Jira)
[ 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] [Created] (KAFKA-12817) Make Task ID an Implementation Detail

2021-05-20 Thread Bruno Cadonna (Jira)
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:

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

2021-06-01 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-12519. --- Resolution: Fixed > Consider Removing Streams Old Built-in Metrics Version >

[jira] [Created] (KAFKA-13010) Flaky test org.apache.kafka.streams.integration.TaskMetadataIntegrationTest.shouldReportCorrectCommittedOffsetInformation()

2021-06-29 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-13010: - Summary: Flaky test org.apache.kafka.streams.integration.TaskMetadataIntegrationTest.shouldReportCorrectCommittedOffsetInformation() Key: KAFKA-13010 URL:

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

2021-03-22 Thread Bruno Cadonna (Jira)
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] [Created] (KAFKA-12666) Fix flaky kafka.server.RaftClusterTest.testCreateClusterAndCreateListDeleteTopic

2021-04-13 Thread Bruno Cadonna (Jira)
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] [Created] (KAFKA-12292) Fix Ignored Downgrade Tests in streams_upgrade_test.py: test_upgrade_downgrade_brokers

2021-02-04 Thread Bruno Cadonna (Jira)
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

2021-02-04 Thread Bruno Cadonna (Jira)
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] [Resolved] (KAFKA-7271) Fix ignored test in streams_upgrade_test.py: test_upgrade_downgrade_brokers

2021-02-04 Thread Bruno Cadonna (Jira)
[ 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] [Created] (KAFKA-13287) Upgrade RocksDB to 6.22.1.1

2021-09-09 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-13287: - Summary: Upgrade RocksDB to 6.22.1.1 Key: KAFKA-13287 URL: https://issues.apache.org/jira/browse/KAFKA-13287 Project: Kafka Issue Type: Task

[jira] [Resolved] (KAFKA-13287) Upgrade RocksDB to 6.22.1.1

2021-09-13 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-13287. --- Resolution: Fixed > Upgrade RocksDB to 6.22.1.1 > --- > >

[jira] [Created] (KAFKA-13094) Session windows do not consider user-specified grace when computing retention time for changelog

2021-07-15 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-13094: - Summary: Session windows do not consider user-specified grace when computing retention time for changelog Key: KAFKA-13094 URL:

[jira] [Resolved] (KAFKA-13229) KIP-761: implement a total blocked time metric in Kafka Streams

2021-09-27 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-13229. --- Resolution: Fixed > KIP-761: implement a total blocked time metric in Kafka Streams >

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

2021-11-03 Thread Bruno Cadonna (Jira)
[ 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] [Resolved] (KAFKA-12260) PartitionsFor should not return null value

2022-02-25 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-12260. --- Resolution: Fixed > PartitionsFor should not return null value >

[jira] [Created] (KAFKA-13672) Flaky test kafka.server.DynamicBrokerReconfigurationTest.testThreadPoolResize()

2022-02-16 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-13672: - Summary: Flaky test kafka.server.DynamicBrokerReconfigurationTest.testThreadPoolResize() Key: KAFKA-13672 URL: https://issues.apache.org/jira/browse/KAFKA-13672

[jira] [Resolved] (KAFKA-13542) Utilize the new Consumer#enforceRebalance(reason) API in Streams

2022-02-28 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-13542. --- Resolution: Fixed > Utilize the new Consumer#enforceRebalance(reason) API in Streams >

[jira] [Resolved] (KAFKA-13666) Tests should not ignore exceptions for supported OS

2022-02-18 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-13666. --- Resolution: Fixed > Tests should not ignore exceptions for supported OS >

  1   2   >