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

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

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

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

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

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

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

[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-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] [Resolved] (KAFKA-8580) Compute RocksDB Metrics

2019-09-24 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: K

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

2019-09-24 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-24 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 Compone

[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-8964) Refactor Stream-Thread-level Metrics

2019-09-30 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-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 C

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

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

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

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

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

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

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

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

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

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

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

[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] [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] [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] [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-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: Sub-ta

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

2023-08-02 Thread Bruno Cadonna (Jira)
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] [Resolved] (KAFKA-15319) Upgrade rocksdb to fix CVE-2022-37434

2023-08-18 Thread Bruno Cadonna (Jira)
[ 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] [Resolved] (KAFKA-13973) block-cache-capacity metrics worth twice as much as normal

2023-09-18 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-13973. --- Resolution: Fixed > block-cache-capacity metrics worth twice as much as normal > ---

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

2023-10-04 Thread Bruno Cadonna (Jira)
[ 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] [Resolved] (KAFKA-15577) Reload4j | CVE-2022-45868

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

2023-10-17 Thread Bruno Cadonna (Jira)
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

2023-10-17 Thread Bruno Cadonna (Jira)
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] [Resolved] (KAFKA-15555) Ensure wakeups are handled correctly in PrototypeAsyncConsumer.poll()

2023-11-23 Thread Bruno Cadonna (Jira)
[ 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] [Resolved] (KAFKA-16350) StateUpdater does not init transaction after canceling task close action

2024-05-16 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-16350. --- Resolution: Fixed > StateUpdater does not init transaction after canceling task close action

[jira] [Reopened] (KAFKA-13295) Long restoration times for new tasks can lead to transaction timeouts

2024-05-30 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reopened KAFKA-13295: --- Assignee: (was: Sagar Rao) > Long restoration times for new tasks can lead to transact

[jira] [Created] (KAFKA-16903) Task should consider producer error previously occurred for different task

2024-06-06 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-16903: - Summary: Task should consider producer error previously occurred for different task Key: KAFKA-16903 URL: https://issues.apache.org/jira/browse/KAFKA-16903 Project:

[jira] [Reopened] (KAFKA-14567) Kafka Streams crashes after ProducerFencedException

2024-06-11 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reopened KAFKA-14567: --- > Kafka Streams crashes after ProducerFencedException >

[jira] [Resolved] (KAFKA-13295) Long restoration times for new tasks can lead to transaction timeouts

2024-07-01 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-13295. --- Fix Version/s: 3.8.0 Resolution: Fixed > Long restoration times for new tasks can lea

[jira] [Created] (KAFKA-17109) Reduce log message load for failed locking

2024-07-10 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-17109: - Summary: Reduce log message load for failed locking Key: KAFKA-17109 URL: https://issues.apache.org/jira/browse/KAFKA-17109 Project: Kafka Issue Type: Impr

[jira] [Created] (KAFKA-17324) Set config {{group.protocol}} to {{classic}} in Streams

2024-08-13 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-17324: - Summary: Set config {{group.protocol}} to {{classic}} in Streams Key: KAFKA-17324 URL: https://issues.apache.org/jira/browse/KAFKA-17324 Project: Kafka Iss

[jira] [Resolved] (KAFKA-14438) Throw error when consumer configured with empty/whitespace-only group.id for AsyncKafkaConsumer

2023-12-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-14438. --- Resolution: Fixed > Throw error when consumer configured with empty/whitespace-only group.id

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

2023-12-13 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reopened KAFKA-9545: -- > Flaky Test `RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted` >

[jira] [Created] (KAFKA-16017) Checkpointed offset is incorrect when task is revived and restoring

2023-12-15 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-16017: - Summary: Checkpointed offset is incorrect when task is revived and restoring Key: KAFKA-16017 URL: https://issues.apache.org/jira/browse/KAFKA-16017 Project: Kafka

[jira] [Resolved] (KAFKA-15991) Flaky new consumer test testGroupIdNotNullAndValid

2023-12-20 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-15991. --- Resolution: Fixed > Flaky new consumer test testGroupIdNotNullAndValid > ---

[jira] [Resolved] (KAFKA-16098) State updater may attempt to resume a task that is not assigned anymore

2024-01-10 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-16098. --- Resolution: Fixed > State updater may attempt to resume a task that is not assigned anymore

[jira] [Created] (KAFKA-16285) Make group metadata available when a new assignment is set in async Kafka consumer

2024-02-20 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-16285: - Summary: Make group metadata available when a new assignment is set in async Kafka consumer Key: KAFKA-16285 URL: https://issues.apache.org/jira/browse/KAFKA-16285

[jira] [Resolved] (KAFKA-16194) KafkaConsumer.groupMetadata() should be correct when first records are returned

2024-02-21 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-16194. --- Resolution: Fixed > KafkaConsumer.groupMetadata() should be correct when first records are

[jira] [Resolved] (KAFKA-9062) Handle stalled writes to RocksDB

2024-02-27 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-9062. -- Resolution: Won't Fix > Handle stalled writes to RocksDB > > >

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

2024-03-11 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reopened KAFKA-10199: --- > Separate state restoration into separate threads > ---

[jira] [Reopened] (KAFKA-15538) Client support for java regex based subscription

2024-04-10 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reopened KAFKA-15538: --- > Client support for java regex based subscription > ---

[jira] [Created] (KAFKA-17489) IllegalStateException if failed task is removed from state updater

2024-09-06 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-17489: - Summary: IllegalStateException if failed task is removed from state updater Key: KAFKA-17489 URL: https://issues.apache.org/jira/browse/KAFKA-17489 Project: Kafka

[jira] [Resolved] (KAFKA-17489) IllegalStateException if failed task is removed from state updater

2024-09-13 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-17489. --- Resolution: Fixed > IllegalStateException if failed task is removed from state updater > ---

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

[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] [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-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: https://issues.apache.org/jira/browse/KAFKA

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

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

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

[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-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-14192) Move registering and unregistering changelogs to state updater

2022-08-31 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-14192: - Summary: Move registering and unregistering changelogs to state updater Key: KAFKA-14192 URL: https://issues.apache.org/jira/browse/KAFKA-14192 Project: Kafka

[jira] [Resolved] (KAFKA-14270) Kafka Streams logs exception on startup

2022-10-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-14270. --- Resolution: Fixed > Kafka Streams logs exception on startup > --

[jira] [Created] (KAFKA-14288) Processor topology in tasks is updated with internal intermediate topics without application ID prefix

2022-10-11 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-14288: - Summary: Processor topology in tasks is updated with internal intermediate topics without application ID prefix Key: KAFKA-14288 URL: https://issues.apache.org/jira/browse/KAFKA

[jira] [Resolved] (KAFKA-13887) Running multiple instance of same stateful KafkaStreams application on single host raise Exception

2022-11-07 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-13887. --- Resolution: Not A Problem > Running multiple instance of same stateful KafkaStreams applicat

[jira] [Resolved] (KAFKA-14461) StoreQueryIntegrationTest#shouldQuerySpecificActivePartitionStores logic to check for active partitions seems brittle.

2022-12-21 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-14461. --- Resolution: Fixed > StoreQueryIntegrationTest#shouldQuerySpecificActivePartitionStores logic

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

  1   2   >