[jira] [Reopened] (KAFKA-19230) Fail build for FunctionalInterfaceMethodChanged warning

2025-08-05 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-19230: - > Fail build for FunctionalInterfaceMethodChanged warning >

[jira] [Resolved] (KAFKA-19230) Fail build for FunctionalInterfaceMethodChanged warning

2025-08-05 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-19230. - Fix Version/s: 4.1.0 Resolution: Fixed > Fail build for FunctionalInterfaceMethod

[jira] [Created] (KAFKA-19557) Remove BrokerNotFoundException

2025-07-28 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-19557: --- Summary: Remove BrokerNotFoundException Key: KAFKA-19557 URL: https://issues.apache.org/jira/browse/KAFKA-19557 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-12281) Cleanup unused org.apache.kafka.streams.errors.BrokerNotFoundException

2025-07-28 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-12281. - Fix Version/s: 4.1.0 Resolution: Fixed > Cleanup unused org.apache.kafka.streams.

[jira] [Created] (KAFKA-19540) Fix incorrect error message

2025-07-23 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-19540: --- Summary: Fix incorrect error message Key: KAFKA-19540 URL: https://issues.apache.org/jira/browse/KAFKA-19540 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-19539) Kafka Streams should purge internal topics based on use commit request

2025-07-23 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-19539: --- Summary: Kafka Streams should purge internal topics based on use commit request Key: KAFKA-19539 URL: https://issues.apache.org/jira/browse/KAFKA-19539 Project:

[jira] [Created] (KAFKA-19537) StreamsGroupCommand should return exit code

2025-07-22 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-19537: --- Summary: StreamsGroupCommand should return exit code Key: KAFKA-19537 URL: https://issues.apache.org/jira/browse/KAFKA-19537 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-19496) Failing test: DescribeStreamsGroupTest.testDescribeMultipleStreamsGroupWithMembersAndVerboseOptions()

2025-07-13 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-19496. - Fix Version/s: 4.2.0 Resolution: Fixed > Failing test: > DescribeStreamsGroupTes

[jira] [Created] (KAFKA-19430) Don't fail on RecordCorruptedException

2025-06-23 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-19430: --- Summary: Don't fail on RecordCorruptedException Key: KAFKA-19430 URL: https://issues.apache.org/jira/browse/KAFKA-19430 Project: Kafka Issue Type: Impr

[jira] [Resolved] (KAFKA-16700) Kafka Streams: possible message loss on KTable-KTable FK Left Join

2025-06-14 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-16700. - Resolution: Fixed > Kafka Streams: possible message loss on KTable-KTable FK Left Join >

[jira] [Created] (KAFKA-19236) Auto.offset.reset "by-duration" should reset a single time

2025-05-03 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-19236: --- Summary: Auto.offset.reset "by-duration" should reset a single time Key: KAFKA-19236 URL: https://issues.apache.org/jira/browse/KAFKA-19236 Project: Kafka

[jira] [Created] (KAFKA-19230) Fail build for FunctionalInterfaceMethodChanged warning

2025-05-01 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-19230: --- Summary: Fail build for FunctionalInterfaceMethodChanged warning Key: KAFKA-19230 URL: https://issues.apache.org/jira/browse/KAFKA-19230 Project: Kafka

[jira] [Resolved] (KAFKA-19173) Add `Feature` for streams groups

2025-04-29 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-19173. - Fix Version/s: 4.1.0 Resolution: Fixed > Add `Feature` for streams groups > -

[jira] [Created] (KAFKA-19208) KStream-GlobalKTable join should not drop left-null-key record

2025-04-27 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-19208: --- Summary: KStream-GlobalKTable join should not drop left-null-key record Key: KAFKA-19208 URL: https://issues.apache.org/jira/browse/KAFKA-19208 Project: Kafka

[jira] [Created] (KAFKA-19173) Add `Feature` for streams groups

2025-04-17 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-19173: --- Summary: Add `Feature` for streams groups Key: KAFKA-19173 URL: https://issues.apache.org/jira/browse/KAFKA-19173 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-19171) Kafka Streams crashes with UnsupportedOperationException

2025-04-17 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-19171: --- Summary: Kafka Streams crashes with UnsupportedOperationException Key: KAFKA-19171 URL: https://issues.apache.org/jira/browse/KAFKA-19171 Project: Kafka

[jira] [Resolved] (KAFKA-19054) StreamThread exception handling with SHUTDOWN_APPLICATION may trigger a tight loop with MANY logs

2025-04-16 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-19054. - Fix Version/s: 4.1.0 4.0.1 Resolution: Fixed > StreamThread ex

[jira] [Resolved] (KAFKA-13747) refactor TopologyTest to test different store type with parametrized

2025-04-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-13747. - Fix Version/s: 4.1.0 Resolution: Fixed > refactor TopologyTest to test different

[jira] [Resolved] (KAFKA-19058) Running the streams/streams-scala module tests produces a streams-scala.log

2025-04-02 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-19058. - Fix Version/s: 4.1.0 Resolution: Fixed > Running the streams/streams-scala module

[jira] [Created] (KAFKA-19052) Document how to query versioned stores/KTables

2025-03-28 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-19052: --- Summary: Document how to query versioned stores/KTables Key: KAFKA-19052 URL: https://issues.apache.org/jira/browse/KAFKA-19052 Project: Kafka Issue Ty

[jira] [Created] (KAFKA-19035) Ensure DLQ can be tested using TTD

2025-03-24 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-19035: --- Summary: Ensure DLQ can be tested using TTD Key: KAFKA-19035 URL: https://issues.apache.org/jira/browse/KAFKA-19035 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-18195) Enter "incompatible" instead of leaving incompatible entires blank in Kafka Streams broker compatibility matrix

2025-03-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-18195. - Fix Version/s: 4.0.0 Resolution: Fixed > Enter "incompatible" instead of leaving

[jira] [Resolved] (KAFKA-9148) Consider forking RocksDB for Streams

2025-03-09 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9148. Resolution: Won't Fix Don't think it's a good idea to folk RocksDB to begin with... Also th

[jira] [Created] (KAFKA-18950) Allow to "shift" window-start anchor for Tumbling/Hopping windows

2025-03-09 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-18950: --- Summary: Allow to "shift" window-start anchor for Tumbling/Hopping windows Key: KAFKA-18950 URL: https://issues.apache.org/jira/browse/KAFKA-18950 Project: Kafk

[jira] [Resolved] (KAFKA-7079) ValueTransformerWithKeySupplier is not mentioned in the documentation

2025-03-09 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7079. Resolution: Won't Fix > ValueTransformerWithKeySupplier is not mentioned in the documentati

[jira] [Resolved] (KAFKA-7302) Remove Java7 examples from Streams Docs

2025-03-09 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7302. Fix Version/s: 4.0.0 Resolution: Fixed I believe we did do this cleanup during 4.0.0

[jira] [Resolved] (KAFKA-8871) Allow timestamp manipulation in ValueTransformerWithKey

2025-03-09 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8871. Resolution: Won't Fix With the new type-safe PAPI (v2) `ValueTransformerWithKey` is going t

[jira] [Resolved] (KAFKA-18023) Enforcing Explicit Naming for Kafka Streams Internal Topics (KIP-1111)

2025-03-09 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-18023. - Fix Version/s: 4.1.0 Resolution: Fixed > Enforcing Explicit Naming for Kafka Stre

[jira] [Created] (KAFKA-18943) Kafka Streams incorrectly commits TX during task revokation

2025-03-07 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-18943: --- Summary: Kafka Streams incorrectly commits TX during task revokation Key: KAFKA-18943 URL: https://issues.apache.org/jira/browse/KAFKA-18943 Project: Kafka

[jira] [Created] (KAFKA-18913) Consider removing state-updater feature flag

2025-03-03 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-18913: --- Summary: Consider removing state-updater feature flag Key: KAFKA-18913 URL: https://issues.apache.org/jira/browse/KAFKA-18913 Project: Kafka Issue Type

[jira] [Created] (KAFKA-18836) Make ConsumerGroupMetadata an interface

2025-02-19 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-18836: --- Summary: Make ConsumerGroupMetadata an interface Key: KAFKA-18836 URL: https://issues.apache.org/jira/browse/KAFKA-18836 Project: Kafka Issue Type: Imp

[jira] [Created] (KAFKA-18785) Add emitStrategy for co-grouped windowed aggrgation

2025-02-12 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-18785: --- Summary: Add emitStrategy for co-grouped windowed aggrgation Key: KAFKA-18785 URL: https://issues.apache.org/jira/browse/KAFKA-18785 Project: Kafka Iss

[jira] [Created] (KAFKA-18771) Flaky test KRaftClusterTest .testDescribeQuorumRequestToControllers

2025-02-10 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-18771: --- Summary: Flaky test KRaftClusterTest .testDescribeQuorumRequestToControllers Key: KAFKA-18771 URL: https://issues.apache.org/jira/browse/KAFKA-18771 Project: Ka

[jira] [Created] (KAFKA-18731) KStream-GlobalKTabel ValueJoinerWithKey passed incorrect key

2025-02-04 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-18731: --- Summary: KStream-GlobalKTabel ValueJoinerWithKey passed incorrect key Key: KAFKA-18731 URL: https://issues.apache.org/jira/browse/KAFKA-18731 Project: Kafka

[jira] [Created] (KAFKA-18692) Consider to unify KStreamImpl "repartitionRequired" with GraphNode "keyChangingOperation"

2025-02-01 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-18692: --- Summary: Consider to unify KStreamImpl "repartitionRequired" with GraphNode "keyChangingOperation" Key: KAFKA-18692 URL: https://issues.apache.org/jira/browse/KAFKA-18692

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

  1   2   3   4   5   6   7   8   9   10   >