[jira] [Resolved] (KAFKA-18689) NoSuchElementException in state store iterator metrics

2025-01-31 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-18689. - Resolution: Duplicate > NoSuchElementException in state store iterator metrics > ---

[jira] [Resolved] (KAFKA-18686) Flaky test StandbyTaskEOSMultiRebalanceIntegrationTest#shouldHonorEOSWhenUsingCachingAndStandbyReplicas

2025-01-31 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-18686. - Resolution: Won't Do > Flaky test > StandbyTaskEOSMultiRebalanceIntegrationTest#shouldH

[jira] [Resolved] (KAFKA-17680) StandbyTaskEOSMultiRebalanceIntegrationTest caused build failure

2025-01-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-17680. - Resolution: Cannot Reproduce We did not see this error again, and the test has 100% pass

[jira] [Resolved] (KAFKA-15944) Flaky test - verifyStore[cache=false, log=true, supplier=ROCKS_KV, kind=DSL] – org.apache.kafka.streams.integration.PositionRestartIntegrationTest

2025-01-29 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-15944. - Resolution: Cannot Reproduce This ticket is over a year old. Looking into recent test hi

[jira] [Resolved] (KAFKA-18541) Fix flaky KafkaStreamsTelemetryIntegrationTest#shouldPassCorrectMetricsDynamicInstances

2025-01-27 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-18541. - Fix Version/s: 4.1.0 Resolution: Fixed > Fix flaky > KafkaStreamsTelemetryIntegr

[jira] [Created] (KAFKA-18644) Improve type safety in DSL code

2025-01-24 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-18644: --- Summary: Improve type safety in DSL code Key: KAFKA-18644 URL: https://issues.apache.org/jira/browse/KAFKA-18644 Project: Kafka Issue Type: Task

[jira] [Resolved] (KAFKA-17114) DefaultStateUpdater::handleRuntimeException should update isRunning before calling `addToExceptionsAndFailedTasksThenClearUpdatingAndPausedTasks`

2025-01-17 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-17114. - Fix Version/s: 4.1.0 Resolution: Fixed > DefaultStateUpdater::handleRuntimeExcept

[jira] [Created] (KAFKA-18572) Update Kafka Streams metric documenation

2025-01-16 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-18572: --- Summary: Update Kafka Streams metric documenation Key: KAFKA-18572 URL: https://issues.apache.org/jira/browse/KAFKA-18572 Project: Kafka Issue Type: Ta

[jira] [Resolved] (KAFKA-18493) Fix configure :streams:integration-tests project error

2025-01-14 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-18493. - Fix Version/s: 4.1.0 Resolution: Fixed > Fix configure :streams:integration-tests

[jira] [Created] (KAFKA-18523) Improve default.replication.factor docs

2025-01-14 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-18523: --- Summary: Improve default.replication.factor docs Key: KAFKA-18523 URL: https://issues.apache.org/jira/browse/KAFKA-18523 Project: Kafka Issue Type: Tas

[jira] [Created] (KAFKA-18498) Kafka Streams main thread does not release lock

2025-01-13 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-18498: --- Summary: Kafka Streams main thread does not release lock Key: KAFKA-18498 URL: https://issues.apache.org/jira/browse/KAFKA-18498 Project: Kafka Issue T

[jira] [Created] (KAFKA-18478) RocksDBTimeOrderedKeyValueBuffer does only use serdes from config

2025-01-10 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-18478: --- Summary: RocksDBTimeOrderedKeyValueBuffer does only use serdes from config Key: KAFKA-18478 URL: https://issues.apache.org/jira/browse/KAFKA-18478 Project: Kafk

[jira] [Resolved] (KAFKA-14408) Consider enabling DEBUG log level on tests for Streams

2025-01-10 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-14408. - Resolution: Won't Fix I don't think we should do this – it would produce way too many lo

[jira] [Created] (KAFKA-18476) KafkaStreams should swallow TransactionAbortedException

2025-01-10 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-18476: --- Summary: KafkaStreams should swallow TransactionAbortedException Key: KAFKA-18476 URL: https://issues.apache.org/jira/browse/KAFKA-18476 Project: Kafka

[jira] [Resolved] (KAFKA-17825) ByteBufferDeserializaer's array size can be inconsistent with the older version

2025-01-09 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-17825. - Fix Version/s: (was: 4.0.0) (was: 3.9.1)

[jira] [Created] (KAFKA-18462) Upgrade RocksDB dependency

2025-01-09 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-18462: --- Summary: Upgrade RocksDB dependency Key: KAFKA-18462 URL: https://issues.apache.org/jira/browse/KAFKA-18462 Project: Kafka Issue Type: Task C

[jira] [Resolved] (KAFKA-18111) Add Kafka Logo to README

2025-01-08 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-18111. - Resolution: Fixed > Add Kafka Logo to README > > >

[jira] [Resolved] (KAFKA-18112) Add Kafka Logo to README

2025-01-08 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-18112. - Resolution: Fixed > Add Kafka Logo to README > > >

[jira] [Reopened] (KAFKA-4212) Add a key-value store that is a TTL persistent cache

2025-01-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-4212: > Add a key-value store that is a TTL persistent cache > --

[jira] [Reopened] (KAFKA-4273) Streams DSL - Add TTL / retention period support for intermediate topics and state stores

2025-01-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-4273: > Streams DSL - Add TTL / retention period support for intermediate topics and > state stores

[jira] [Resolved] (KAFKA-16586) Test TaskAssignorConvergenceTest failing

2025-01-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-16586. - Resolution: Cannot Reproduce Closing this old ticket. Did not see this test failing for

[jira] [Resolved] (KAFKA-8017) Narrow the scope of Streams' broker-upgrade-test

2025-01-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8017. Resolution: Invalid The streams-broker-upgrade test was delete at some point in the past. C

[jira] [Resolved] (KAFKA-7175) Make version checking logic more flexible in streams_upgrade_test.py

2025-01-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7175. Assignee: (was: Ray Chiang) Resolution: Abandoned Closing this very old ticket. S

[jira] [Resolved] (KAFKA-4479) Streams tests should pass without hardcoded Time.SYSTEM in GroupCoordinator

2025-01-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4479. Resolution: Abandoned Closing this very old ticket. Not clear if this is still a problem, o

[jira] [Resolved] (KAFKA-16502) Fix flaky EOSUncleanShutdownIntegrationTest#shouldWorkWithUncleanShutdownWipeOutStateStore

2025-01-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-16502. - Resolution: Cannot Reproduce Did not see this failing for a long time. Closing for now.

[jira] [Resolved] (KAFKA-16597) Flaky test - org.apache.kafka.streams.integration.StoreQueryIntegrationTest.shouldQuerySpecificStalePartitionStoresMultiStreamThreads()

2025-01-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-16597. - Resolution: Cannot Reproduce Did not see this failing for a long time. Closing for now.

[jira] [Resolved] (KAFKA-16377) Fix flaky HighAvailabilityTaskAssignorIntegrationTest.shouldScaleOutWithWarmupTasksAndPersistentStores

2025-01-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-16377. - Resolution: Cannot Reproduce Did not see this failing for a long time. Closing for now.

[jira] [Resolved] (KAFKA-17364) Flaky test: org.apache.kafka.streams.integration.QueryableStateIntegrationTest.shouldBeAbleQueryStandbyStateDuringRebalance()

2025-01-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-17364. - Resolution: Cannot Reproduce Did not see this failing for a long time. Closing for now.

[jira] [Created] (KAFKA-18421) Test ConsumerProtocolMigrationTest.testDowngradeFromEmptyConsumerToClassicGroupWithDowngradePolicy failed

2025-01-06 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-18421: --- Summary: Test ConsumerProtocolMigrationTest.testDowngradeFromEmptyConsumerToClassicGroupWithDowngradePolicy failed Key: KAFKA-18421 URL: https://issues.apache.org/jira/brow

[jira] [Reopened] (KAFKA-18092) TransactionsTest.testBumpTransactionalEpochWithTV2Enabled is flaky

2025-01-06 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-18092: - Just failed again (two time in a row) on [https://github.com/apache/kafka/pull/18402]  > T

[jira] [Resolved] (KAFKA-10578) Convert KTable to a KStream using the previous value

2025-01-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10578. - Resolution: Abandoned Closing this ticket. The KIP discussion did not lead to a resoluti

[jira] [Resolved] (KAFKA-6953) [Streams] Schedulable KTable as Graph source (for minimizing aggregation pressure)

2025-01-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6953. Resolution: Abandoned > [Streams] Schedulable KTable as Graph source (for minimizing aggreg

[jira] [Resolved] (KAFKA-4437) Incremental Batch Processing for Kafka Streams

2025-01-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4437. Resolution: Abandoned > Incremental Batch Processing for Kafka Streams > --

[jira] [Resolved] (KAFKA-15299) Support left stream-table join on foreign key

2025-01-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-15299. - Resolution: Incomplete Closing this ticket as "incomplete". The KIP discussion did not

[jira] [Resolved] (KAFKA-4212) Add a key-value store that is a TTL persistent cache

2025-01-02 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4212. Fix Version/s: 2.1.0 Resolution: Fixed > Add a key-value store that is a TTL persist

[jira] [Resolved] (KAFKA-4273) Streams DSL - Add TTL / retention period support for intermediate topics and state stores

2025-01-02 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4273. Fix Version/s: 2.1.0 Resolution: Fixed > Streams DSL - Add TTL / retention period su

[jira] [Created] (KAFKA-18344) Consider to distinguish between multiple "positions"

2024-12-23 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-18344: --- Summary: Consider to distinguish between multiple "positions" Key: KAFKA-18344 URL: https://issues.apache.org/jira/browse/KAFKA-18344 Project: Kafka Is

[jira] [Resolved] (KAFKA-12829) Remove Deprecated methods can classes of old Processor API

2024-12-19 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-12829. - Resolution: Fixed > Remove Deprecated methods can classes of old Processor API > ---

[jira] [Resolved] (KAFKA-12822) Remove Deprecated APIs of Kafka Streams in 4.0

2024-12-19 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-12822. - Resolution: Fixed > Remove Deprecated APIs of Kafka Streams in 4.0 > ---

[jira] [Resolved] (KAFKA-13662) Migrate DeserializationExceptionHandler to latest ProcessorContext API

2024-12-17 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-13662. - Resolution: Won't Fix With https://issues.apache.org/jira/browse/KAFKA-16448, we depreca

[jira] [Resolved] (KAFKA-9566) ProcessorContextImpl#forward throws NullPointerException if invoked from DeserializationExceptionHandler

2024-12-17 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9566. Fix Version/s: 3.9.0 Resolution: Fixed Since 3.9 release, the method taking `Process

[jira] [Resolved] (KAFKA-4713) Processors cannot call public methods on ProcessorContext from the init method

2024-12-17 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4713. Resolution: Won't Fix In AK 2.7, we introduces the new `api.Processor` with new `api.Proce

[jira] [Resolved] (KAFKA-12825) Remove Deprecated method StreamsBuilder#addGlobalStore

2024-12-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-12825. - Resolution: Duplicate > Remove Deprecated method StreamsBuilder#addGlobalStore > ---

[jira] [Reopened] (KAFKA-12825) Remove Deprecated method StreamsBuilder#addGlobalStore

2024-12-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-12825: - > Remove Deprecated method StreamsBuilder#addGlobalStore > -

[jira] [Resolved] (KAFKA-12831) Remove Deprecated method StateStore#init

2024-12-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-12831. - Resolution: Duplicate > Remove Deprecated method StateStore#init > -

[jira] [Reopened] (KAFKA-12831) Remove Deprecated method StateStore#init

2024-12-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-12831: - > Remove Deprecated method StateStore#init > > >

[jira] [Resolved] (KAFKA-18015) Add duration based offset reset option for Kafka Streams

2024-12-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-18015. - Resolution: Fixed > Add duration based offset reset option for Kafka Streams > -

[jira] [Created] (KAFKA-18193) Kafka Streams `CloseOptions` should not have a public constructor

2024-12-09 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-18193: --- Summary: Kafka Streams `CloseOptions` should not have a public constructor Key: KAFKA-18193 URL: https://issues.apache.org/jira/browse/KAFKA-18193 Project: Kafk

[jira] [Resolved] (KAFKA-16018) KafkaStreams can go into a zombie state if UncaughtExceptionHandler is specified via the deprecated method

2024-12-09 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-16018. - Resolution: Won't Do Kafka 4.0 is around the corner. Closing this. > KafkaStreams can g

[jira] [Resolved] (KAFKA-12843) KIP-740 follow up: clean up TaskMetadata

2024-12-08 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-12843. - Resolution: Duplicate (was: Fixed) > KIP-740 follow up: clean up TaskMetadata > ---

[jira] [Resolved] (KAFKA-17893) Support record keys in the foreignKeyExtractor argument of KTable foreign join

2024-12-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-17893. - Fix Version/s: 4.0.0 Resolution: Fixed > Support record keys in the foreignKeyExt

[jira] [Created] (KAFKA-18088) Add consumer metric about paused partitions

2024-11-25 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-18088: --- Summary: Add consumer metric about paused partitions Key: KAFKA-18088 URL: https://issues.apache.org/jira/browse/KAFKA-18088 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-18038) Flaky StreamThreadTest shouldLogAndRecordSkippedRecordsForInvalidTimestamps

2024-11-21 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-18038. - Fix Version/s: 4.0.0 Resolution: Fixed > Flaky StreamThreadTest shouldLogAndRecor

[jira] [Resolved] (KAFKA-12689) Remove deprecated EOS configs

2024-11-19 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-12689. - Resolution: Fixed Covered by https://github.com/apache/kafka/pull/17170 > Remove deprec

[jira] [Resolved] (KAFKA-17805) Deprecate named topologies

2024-11-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-17805. - Resolution: Fixed > Deprecate named topologies > -- > >

[jira] [Resolved] (KAFKA-7108) "Exactly-once" stream breaks production exception handler contract

2024-11-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7108. Resolution: Duplicate > "Exactly-once" stream breaks production exception handler contract

[jira] [Resolved] (KAFKA-16331) Remove Deprecated EOSv1

2024-11-06 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-16331. - Resolution: Fixed > Remove Deprecated EOSv1 > --- > >

[jira] [Resolved] (KAFKA-12827) Remove Deprecated method KafkaStreams#setUncaughtExceptionHandler

2024-11-05 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-12827. - Resolution: Fixed > Remove Deprecated method KafkaStreams#setUncaughtExceptionHandler >

[jira] [Resolved] (KAFKA-17114) DefaultStateUpdater::handleRuntimeException should update isRunning before calling `addToExceptionsAndFailedTasksThenClearUpdatingAndPausedTasks`

2024-10-22 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-17114. - Resolution: Cannot Reproduce We did push some fixed for related tickets. Closing this fo

[jira] [Reopened] (KAFKA-9323) Refactor Streams' upgrade system tests

2024-10-22 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-9323: > Refactor Streams' upgrade system tests > --- > >

[jira] [Resolved] (KAFKA-9323) Refactor Streams' upgrade system tests

2024-10-22 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9323. Resolution: Fixed > Refactor Streams' upgrade system tests > -

[jira] [Resolved] (KAFKA-17402) Test failure: DefaultStateUpdaterTest.shouldGetTasksFromRestoredActiveTasks expected: <2> but was: <3>

2024-10-22 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-17402. - Resolution: Cannot Reproduce We did put out some fixes for related tickets. Closing this

[jira] [Resolved] (KAFKA-16336) Remove Deprecated metric standby-process-ratio

2024-10-17 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-16336. - Resolution: Invalid > Remove Deprecated metric standby-process-ratio > -

[jira] [Resolved] (KAFKA-17697) Fix flaky DefaultStateUpdaterTest.shouldRestoreSingleActiveStatefulTask

2024-10-16 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-17697. - Fix Version/s: 4.0.0 Resolution: Fixed > Fix flaky DefaultStateUpdaterTest.should

[jira] [Reopened] (KAFKA-17697) Fix flaky DefaultStateUpdaterTest.shouldRestoreSingleActiveStatefulTask

2024-10-16 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-17697: - > Fix flaky DefaultStateUpdaterTest.shouldRestoreSingleActiveStatefulTask >

[jira] [Resolved] (KAFKA-17408) Fix flaky testShouldCountClicksPerRegionWithNamedRepartitionTopic

2024-10-02 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-17408. - Resolution: Won't Fix Seem the root cause if the issue is some ZK connectivity issue. Gi

[jira] [Resolved] (KAFKA-6197) Difficult to get to the Kafka Streams javadocs

2024-09-28 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6197. Fix Version/s: 4.0.0 Resolution: Fixed > Difficult to get to the Kafka Streams javad

[jira] [Created] (KAFKA-17649) Remove none-StateUpdater Code

2024-09-28 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-17649: --- Summary: Remove none-StateUpdater Code Key: KAFKA-17649 URL: https://issues.apache.org/jira/browse/KAFKA-17649 Project: Kafka Issue Type: Task

[jira] [Created] (KAFKA-17558) Cleanup Kafka Streams integration tests

2024-09-16 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-17558: --- Summary: Cleanup Kafka Streams integration tests Key: KAFKA-17558 URL: https://issues.apache.org/jira/browse/KAFKA-17558 Project: Kafka Issue Type: Tes

[jira] [Created] (KAFKA-17551) Remove ForeachProcessor

2024-09-13 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-17551: --- Summary: Remove ForeachProcessor Key: KAFKA-17551 URL: https://issues.apache.org/jira/browse/KAFKA-17551 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-17427) Fix leaking *_DOC variables in StreamsConfig

2024-09-12 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-17427. - Fix Version/s: 4.0.0 Resolution: Fixed > Fix leaking *_DOC variables in StreamsCo

[jira] [Created] (KAFKA-17538) Make deprecated *_DOC variable private/package-privste

2024-09-12 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-17538: --- Summary: Make deprecated *_DOC variable private/package-privste Key: KAFKA-17538 URL: https://issues.apache.org/jira/browse/KAFKA-17538 Project: Kafka

[jira] [Created] (KAFKA-17537) Remove deprecates methods from Joined class

2024-09-12 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-17537: --- Summary: Remove deprecates methods from Joined class Key: KAFKA-17537 URL: https://issues.apache.org/jira/browse/KAFKA-17537 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-17253) Remove leaking getter methods in Joined helper class

2024-09-12 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-17253. - Fix Version/s: 4.0.0 Resolution: Fixed > Remove leaking getter methods in Joined

[jira] [Resolved] (KAFKA-16332) Remove Deprecated builder methods for Time/Session/Join/SlidingWindows

2024-09-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-16332. - Resolution: Fixed > Remove Deprecated builder methods for Time/Session/Join/SlidingWindo

[jira] [Created] (KAFKA-17531) Remove deprecates methods JoinWindows#of and #grace

2024-09-11 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-17531: --- Summary: Remove deprecates methods JoinWindows#of and #grace Key: KAFKA-17531 URL: https://issues.apache.org/jira/browse/KAFKA-17531 Project: Kafka Iss

[jira] [Created] (KAFKA-17527) Kafka Streams fails with NPE for missing RecordContext

2024-09-11 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-17527: --- Summary: Kafka Streams fails with NPE for missing RecordContext Key: KAFKA-17527 URL: https://issues.apache.org/jira/browse/KAFKA-17527 Project: Kafka

[jira] [Created] (KAFKA-17488) Cleanup (test) code for Kafka Streams "metric version"

2024-09-05 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-17488: --- Summary: Cleanup (test) code for Kafka Streams "metric version" Key: KAFKA-17488 URL: https://issues.apache.org/jira/browse/KAFKA-17488 Project: Kafka

[jira] [Created] (KAFKA-17485) Replace KafkaClientSupplier with KafkaClientInterceptor

2024-09-04 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-17485: --- Summary: Replace KafkaClientSupplier with KafkaClientInterceptor Key: KAFKA-17485 URL: https://issues.apache.org/jira/browse/KAFKA-17485 Project: Kafka

[jira] [Resolved] (KAFKA-16502) Fix flaky EOSUncleanShutdownIntegrationTest#shouldWorkWithUncleanShutdownWipeOutStateStore

2024-09-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-16502. - Resolution: Fixed > Fix flaky > EOSUncleanShutdownIntegrationTest#shouldWorkWithUnclean

[jira] [Reopened] (KAFKA-16502) Fix flaky EOSUncleanShutdownIntegrationTest#shouldWorkWithUncleanShutdownWipeOutStateStore

2024-09-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-16502: - > Fix flaky > EOSUncleanShutdownIntegrationTest#shouldWorkWithUncleanShutdownWipeOutStateSt

[jira] [Resolved] (KAFKA-17467) Flaky test shouldStayDeadAfterTwoCloses org.apache.kafka.streams.processor.internals.GlobalStreamThreadTest

2024-09-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-17467. - Resolution: Duplicate > Flaky test shouldStayDeadAfterTwoCloses > org.apache.kafka.stre

[jira] [Created] (KAFKA-17474) Flaky tests in GlobalStreamThreadTest

2024-09-03 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-17474: --- Summary: Flaky tests in GlobalStreamThreadTest Key: KAFKA-17474 URL: https://issues.apache.org/jira/browse/KAFKA-17474 Project: Kafka Issue Type: Test

[jira] [Resolved] (KAFKA-12826) Remove Deprecated Class Serdes (Streams)

2024-08-31 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-12826. - Resolution: Fixed > Remove Deprecated Class Serdes (Streams) > -

[jira] [Resolved] (KAFKA-16335) Remove Deprecated method on StreamPartitioner

2024-08-26 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-16335. - Resolution: Fixed > Remove Deprecated method on StreamPartitioner >

[jira] [Created] (KAFKA-17427) Fix leaking *_DOC variables in StreamsConfig

2024-08-26 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-17427: --- Summary: Fix leaking *_DOC variables in StreamsConfig Key: KAFKA-17427 URL: https://issues.apache.org/jira/browse/KAFKA-17427 Project: Kafka Issue Type

[jira] [Resolved] (KAFKA-17216) StreamsConfig STATE_DIR_CONFIG

2024-08-25 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-17216. - Resolution: Invalid Cf the reply on GitHub – caused by version miss-match. > StreamsCon

[jira] [Resolved] (KAFKA-16329) Remove Deprecated Task/ThreadMetadata classes and related methods

2024-08-22 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-16329. - Resolution: Fixed > Remove Deprecated Task/ThreadMetadata classes and related methods >

[jira] [Resolved] (KAFKA-16334) Remove Deprecated command line option from reset tool

2024-08-22 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-16334. - Resolution: Fixed > Remove Deprecated command line option from reset tool >

[jira] [Resolved] (KAFKA-17371) Flaky test in DefaultTaskExecutorTest.shouldUnassignTaskWhenRequired

2024-08-22 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-17371. - Fix Version/s: 4.0.0 Resolution: Fixed > Flaky test in DefaultTaskExecutorTest.sh

[jira] [Resolved] (KAFKA-12833) Remove Deprecated methods under TopologyTestDriver

2024-08-22 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-12833. - Resolution: Duplicate > Remove Deprecated methods under TopologyTestDriver > ---

[jira] [Resolved] (KAFKA-16333) Removed Deprecated methods KTable#join

2024-08-22 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-16333. - Resolution: Fixed > Removed Deprecated methods KTable#join > ---

[jira] [Created] (KAFKA-17281) Remove old PAPI methods

2024-08-06 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-17281: --- Summary: Remove old PAPI methods Key: KAFKA-17281 URL: https://issues.apache.org/jira/browse/KAFKA-17281 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-17280) Remove deprecated methods from DeserializationExceptionHandler as ProductionExceptionHandler

2024-08-06 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-17280: --- Summary: Remove deprecated methods from DeserializationExceptionHandler as ProductionExceptionHandler Key: KAFKA-17280 URL: https://issues.apache.org/jira/browse/KAFKA-17280

[jira] [Resolved] (KAFKA-12828) Remove Deprecated methods under KeyQueryMetadata

2024-08-06 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-12828. - Resolution: Fixed > Remove Deprecated methods under KeyQueryMetadata > -

[jira] [Resolved] (KAFKA-15896) Flaky test: shouldQuerySpecificStalePartitionStores() – org.apache.kafka.streams.integration.StoreQueryIntegrationTest

2024-08-06 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-15896. - Resolution: Cannot Reproduce > Flaky test: shouldQuerySpecificStalePartitionStores() –

[jira] [Created] (KAFKA-17253) Remove leaking getter methods in Joined helper class

2024-08-03 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-17253: --- Summary: Remove leaking getter methods in Joined helper class Key: KAFKA-17253 URL: https://issues.apache.org/jira/browse/KAFKA-17253 Project: Kafka Is

[jira] [Created] (KAFKA-17251) KafkaStreams.cleanup() semantics unclear

2024-08-02 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-17251: --- Summary: KafkaStreams.cleanup() semantics unclear Key: KAFKA-17251 URL: https://issues.apache.org/jira/browse/KAFKA-17251 Project: Kafka Issue Type: Im

[jira] [Created] (KAFKA-17224) Make ForeachProcessor internal

2024-07-30 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-17224: --- Summary: Make ForeachProcessor internal Key: KAFKA-17224 URL: https://issues.apache.org/jira/browse/KAFKA-17224 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-17215) Remove get-prefix for all getters

2024-07-29 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-17215: --- Summary: Remove get-prefix for all getters Key: KAFKA-17215 URL: https://issues.apache.org/jira/browse/KAFKA-17215 Project: Kafka Issue Type: Improveme

  1   2   3   4   5   6   7   8   9   10   >