[jira] [Updated] (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 updated KAFKA-18195: Priority: Blocker (was: Major) > Enter "incompatible" instead of leaving incompatible ent

[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] [Commented] (KAFKA-16700) Kafka Streams: possible message loss on KTable-KTable FK Left Join

2025-03-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933720#comment-17933720 ] Matthias J. Sax commented on KAFKA-16700: - I just stubbled over this ticket, and

[jira] [Assigned] (KAFKA-18962) StateRestoreListener onBatchRestored method is called with the totalRestored on GlobalStateStore reprocess

2025-03-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-18962: --- Assignee: Florian Hussonnois > StateRestoreListener onBatchRestored method is calle

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

2025-03-11 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 reassigned KAFKA-18023: --- Assignee: Sebastien Viale > Enforcing Explicit Naming for Kafka Streams Internal To

[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-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] [Assigned] (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 reassigned KAFKA-7302: -- Assignee: (was: Vijay) > Remove Java7 examples from Streams Docs > ---

[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] [Updated] (KAFKA-2939) Make AbstractConfig.logUnused() tunable for clients

2025-03-08 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-2939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-2939: --- Labels: (was: newbie) > Make AbstractConfig.logUnused() tunable for clients > -

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

2025-03-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-18943: Description: We found a very rare edge case in Kafka Streams commit logic, that may lead t

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

2025-03-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-18943: Description: We found a very rare edge case in Kafka Streams commit logic, that may lead t

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

2025-03-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-18943: Description: We found a very rare edge case in Kafka Streams commit logic, that may lead t

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

2025-03-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-18943: Description: We found a very rare edge case in Kafka Streams commit logic, that may lead t

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

2025-03-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-18943: --- Assignee: Matthias J. Sax > Kafka Streams incorrectly commits TX during task revoka

[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] [Commented] (KAFKA-15143) MockFixedKeyProcessorContext is missing from test-utils

2025-03-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933364#comment-17933364 ] Matthias J. Sax commented on KAFKA-15143: - The only workaround might be, to use

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

2025-03-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-18913: --- Assignee: Janindu Pathirana > Consider removing state-updater feature flag > --

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

2025-03-06 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933169#comment-17933169 ] Matthias J. Sax commented on KAFKA-18913: - [~cadonna] – WDYT? Should we do this

[jira] [Updated] (KAFKA-18925) Add streams groups support in Admin.listGroups.

2025-03-05 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-18925: Component/s: streams > Add streams groups support in Admin.listGroups. > -

[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] [Updated] (KAFKA-18168) GlobalKTable does not checkpoint restored offsets until next 10K events

2025-03-02 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-18168: Affects Version/s: (was: 3.8.1) > GlobalKTable does not checkpoint restored offsets un

[jira] [Comment Edited] (KAFKA-17622) Kafka Streams Timeout During Partition Rebalance

2025-02-21 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17929081#comment-17929081 ] Matthias J. Sax edited comment on KAFKA-17622 at 2/21/25 5:36 PM:

[jira] [Comment Edited] (KAFKA-17622) Kafka Streams Timeout During Partition Rebalance

2025-02-21 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17929081#comment-17929081 ] Matthias J. Sax edited comment on KAFKA-17622 at 2/21/25 5:35 PM:

[jira] [Comment Edited] (KAFKA-13769) KTable FK join can miss records if an upstream non-key-changing operation changes key serializer

2025-02-20 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680858#comment-17680858 ] Matthias J. Sax edited comment on KAFKA-13769 at 2/21/25 2:35 AM:

[jira] [Updated] (KAFKA-16319) Wrong broker destinations for DeleteRecords requests when more than one topic is involved and the topics/partitions are led by different brokers

2025-02-20 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-16319: Component/s: admin clients (was: streams) > Wrong br

[jira] [Updated] (KAFKA-14911) Add system tests for rolling upgrade path of KIP-904

2025-02-20 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14911: Priority: Minor (was: Major) > Add system tests for rolling upgrade path of KIP-904 > ---

[jira] [Assigned] (KAFKA-14911) Add system tests for rolling upgrade path of KIP-904

2025-02-20 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-14911: --- Assignee: (was: Victoria Xia) > Add system tests for rolling upgrade path of KI

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

2025-02-20 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17928872#comment-17928872 ] Matthias J. Sax commented on KAFKA-18836: - Thanks for for agree on who works on

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

2025-02-20 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-18836: --- Assignee: Paweł Szymczyk > Make ConsumerGroupMetadata an interface > --

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

2025-02-19 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17928643#comment-17928643 ] Matthias J. Sax commented on KAFKA-18836: - Sure. :)  > Make ConsumerGroupMetada

[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] [Commented] (KAFKA-17420) Fix flaky StreamThreadTest.tearDown

2025-02-19 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17928582#comment-17928582 ] Matthias J. Sax commented on KAFKA-17420: - Just stumbled across this ticket. Loo

[jira] [Updated] (KAFKA-18826) Add Global Thread Metrics

2025-02-18 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-18826: Component/s: streams > Add Global Thread Metrics > - > >

[jira] [Commented] (KAFKA-4650) Improve test coverage org.apache.kafka.streams.kstream.internals

2025-02-18 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17928224#comment-17928224 ] Matthias J. Sax commented on KAFKA-4650: Thanks Lorcan. I'll take a look (might t

[jira] [Assigned] (KAFKA-4650) Improve test coverage org.apache.kafka.streams.kstream.internals

2025-02-18 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-4650: -- Assignee: Lorcan > Improve test coverage org.apache.kafka.streams.kstream.internals >

[jira] [Commented] (KAFKA-18196) Reuse window store for stream-stream self-join

2025-02-13 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927042#comment-17927042 ] Matthias J. Sax commented on KAFKA-18196: - Not 100% sure – guess we would need t

[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] [Updated] (KAFKA-17551) Remove ForeachProcessor

2025-02-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17551: Description: h1. *THIS TICKET CANNOT BE WORKED ON, UNTIL WE DO APACHE KAFKA 5.0 RELEASE.*

[jira] [Updated] (KAFKA-18495) Remove Invalid 'numberOfOpenFiles' Metric from RocksDB State Store

2025-02-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-18495: Description: h1. *THIS TICKET CANNOT BE WORKED ON, UNTIL WE DO APACHE KAFKA 5.0 RELEASE.*

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

2025-02-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17531: Description: h1. *THIS TICKET CANNOT BE WORKED ON, UNTIL WE DO APACHE KAFKA 5.0 RELEASE.*

[jira] [Assigned] (KAFKA-18495) Remove Invalid 'numberOfOpenFiles' Metric from RocksDB State Store

2025-02-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-18495: --- Assignee: (was: Swikar Patel) > Remove Invalid 'numberOfOpenFiles' Metric from

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

2025-02-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17538: Description: h1. *THIS TICKET CANNOT BE WORKED ON, UNTIL WE DO APACHE KAFKA 5.0 RELEASE.*

[jira] [Updated] (KAFKA-17462) Removes intermediateTopicsOption from StreamsResetter

2025-02-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17462: Description: h1. *THIS TICKET CANNOT BE WORKED ON, UNTIL WE DO APACHE KAFKA 5.0 RELEASE.*

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

2025-02-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17280: Description: h1. *THIS TICKET CANNOT BE WORKED ON, UNTIL WE DO APACHE KAFKA 5.0 RELEASE.*

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

2025-02-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17537: Description: h1. *THIS TICKET CANNOT BE WORKED ON, UNTIL WE DO APACHE KAFKA 5.0 RELEASE.*

[jira] [Updated] (KAFKA-16338) Removed Deprecated configs from StreamsConfig

2025-02-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-16338: Description: h1. *THIS TICKET CANNOT BE WORKED ON, UNTIL WE DO APACHE KAFKA 5.0 RELEASE.*

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

2025-02-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17281: Description: h1. *THIS TICKET CANNOT BE WORKED ON, UNTIL WE DO APACHE KAFKA 5.0 RELEASE.*

[jira] [Updated] (KAFKA-16337) Remove Deprecates APIs of Kafka Streams in 5.0

2025-02-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-16337: Description: h1. *THIS TICKET CANNOT BE WORKED ON, UNTIL WE DO APACHE KAFKA 5.0 RELEASE.*

[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] [Updated] (KAFKA-18765) Custom StreamsPartitioner for auto-repartitioning

2025-02-10 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-18765: Labels: needs-kip (was: ) > Custom StreamsPartitioner for auto-repartitioning > -

[jira] [Commented] (KAFKA-18713) Kafka Streams Left-Join not always emitting the last value

2025-02-10 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17925690#comment-17925690 ] Matthias J. Sax commented on KAFKA-18713: - Thanks. Sounds good. Let us know if y

[jira] [Commented] (KAFKA-18713) Kafka Streams Left-Join not always emitting the last value

2025-02-09 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17925431#comment-17925431 ] Matthias J. Sax commented on KAFKA-18713: - {quote}Can I pick this up or is it bi

[jira] [Updated] (KAFKA-18739) Group-level streams configuration

2025-02-05 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-18739: Component/s: streams > Group-level streams configuration > ---

[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] [Updated] (KAFKA-18730) Add replaying streams group state from offset topic

2025-02-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-18730: Component/s: streams > Add replaying streams group state from offset topic > -

[jira] [Commented] (KAFKA-18168) GlobalKTable does not checkpoint restored offsets until next 10K events

2025-02-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923475#comment-17923475 ] Matthias J. Sax commented on KAFKA-18168: - Yeah I know... It's in our review bac

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

2025-02-02 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923143#comment-17923143 ] Matthias J. Sax commented on KAFKA-4212: Had some more discussion with [~hartmutc

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

2025-02-02 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923144#comment-17923144 ] Matthias J. Sax commented on KAFKA-4273: Had some more discussion with [~hartmutc

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

2025-02-02 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923140#comment-17923140 ] Matthias J. Sax commented on KAFKA-18692: - Sure... Let's see how it goes. > Con

[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] [Comment Edited] (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:comment-tabpanel&focusedCommentId=17922880#comment-17922880 ] Matthias J. Sax edited comment on KAFKA-18689 at 2/1/25 12:17 AM:

[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] [Commented] (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:comment-tabpanel&focusedCommentId=17922880#comment-17922880 ] Matthias J. Sax commented on KAFKA-18689: - Thanks for filing the ticket. Yes, it

[jira] [Comment Edited] (KAFKA-17182) Consumer fetch sessions are evicted too quickly with AsyncKafkaConsumer

2025-01-31 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17922868#comment-17922868 ] Matthias J. Sax edited comment on KAFKA-17182 at 1/31/25 10:40 PM: ---

[jira] [Commented] (KAFKA-17182) Consumer fetch sessions are evicted too quickly with AsyncKafkaConsumer

2025-01-31 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17922868#comment-17922868 ] Matthias J. Sax commented on KAFKA-17182: - For details about the introduced regr

[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] [Commented] (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:comment-tabpanel&focusedCommentId=17922860#comment-17922860 ] Matthias J. Sax commented on KAFKA-18686: - The commit was reverted: [https://gi

[jira] [Comment Edited] (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:comment-tabpanel&focusedCommentId=17922856#comment-17922856 ] Matthias J. Sax edited comment on KAFKA-18686 at 1/31/25 10:15 PM: ---

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17922859#comment-17922859 ] Matthias J. Sax commented on KAFKA-18686: - Could it pin it down further. The con

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17922856#comment-17922856 ] Matthias J. Sax commented on KAFKA-18686: - When the test fails, we see it "hang"

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17922852#comment-17922852 ] Matthias J. Sax commented on KAFKA-18686: - I believe it was introduced via [http

[jira] [Updated] (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 updated KAFKA-18686: Component/s: streams unit tests > Flaky test > StandbyTaskEOSMultiRebala

[jira] [Assigned] (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 reassigned KAFKA-18686: --- Assignee: Matthias J. Sax > Flaky test > StandbyTaskEOSMultiRebalanceIntegrationTe

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17922813#comment-17922813 ] Matthias J. Sax commented on KAFKA-18686: - The test had 100% pass rate until yes

[jira] [Commented] (KAFKA-18168) GlobalKTable does not checkpoint restored offsets until next 10K events

2025-01-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17922521#comment-17922521 ] Matthias J. Sax commented on KAFKA-18168: - Thanks. Will put it into my review ba

[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] [Commented] (KAFKA-18168) GlobalKTable does not checkpoint restored offsets until next 10K events

2025-01-29 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17922174#comment-17922174 ] Matthias J. Sax commented on KAFKA-18168: - {quote}But then the question that I h

[jira] [Commented] (KAFKA-10844) groupBy without shuffling

2025-01-29 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17922176#comment-17922176 ] Matthias J. Sax commented on KAFKA-10844: - Yes, nobody works on this. It's up fo

[jira] [Commented] (KAFKA-13152) Replace "buffered.records.per.partition" & "cache.max.bytes.buffering" with "{statestore.cache}/{input.buffer}.max.bytes"

2025-01-29 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17922172#comment-17922172 ] Matthias J. Sax commented on KAFKA-13152: - There is more. The feature itself is

[jira] [Commented] (KAFKA-18168) GlobalKTable does not checkpoint restored offsets until next 10K events

2025-01-28 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17921970#comment-17921970 ] Matthias J. Sax commented on KAFKA-18168: - Hey, thanks for getting back. All goo

[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] [Updated] (KAFKA-17131) Cleanup `ProcessorContext` usage

2025-01-24 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17131: Description: We did replace `Processor` and related classes with `api.Processor` et al. –

[jira] [Updated] (KAFKA-17178) Update KTable.transformValues to new Processor API

2025-01-24 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17178: Labels: kip (was: need-kip) > Update KTable.transformValues to new Processor API > --

[jira] [Updated] (KAFKA-17131) Cleanup `ProcessorContext` usage

2025-01-24 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17131: Labels: kip (was: needs-kip) > Cleanup `ProcessorContext` usage > ---

[jira] [Updated] (KAFKA-17178) Update KTable.transformValues to new Processor API

2025-01-24 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17178: Description: The original Processor API was replace by a type-safe version using `Record`

[jira] [Assigned] (KAFKA-17178) Update KTable.transformValues to new Processor API

2025-01-24 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-17178: --- Assignee: Matthias J. Sax (was: A. Sophie Blee-Goldman) > Update KTable.transformV

[jira] [Updated] (KAFKA-18626) Support for windows that are more flexible to late arriving data

2025-01-22 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-18626: Labels: kip (was: ) > Support for windows that are more flexible to late arriving data >

[jira] [Updated] (KAFKA-18621) Add StreamsCoordinatorRecordHelpers

2025-01-22 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-18621: Component/s: streams > Add StreamsCoordinatorRecordHelpers > -

[jira] [Commented] (KAFKA-18369) State updater's *-ratio metrics are incorrect

2025-01-21 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17915826#comment-17915826 ] Matthias J. Sax commented on KAFKA-18369: - Did not think about it in detail... –

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

2025-01-21 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17915808#comment-17915808 ] Matthias J. Sax commented on KAFKA-18572: - Sure! Thanks for picking it up. > Up

[jira] [Comment Edited] (KAFKA-18369) State updater's *-ratio metrics are incorrect

2025-01-21 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17915761#comment-17915761 ] Matthias J. Sax edited comment on KAFKA-18369 at 1/21/25 4:54 PM:

[jira] [Commented] (KAFKA-18369) State updater's *-ratio metrics are incorrect

2025-01-21 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17915761#comment-17915761 ] Matthias J. Sax commented on KAFKA-18369: - Well, if we have two summed window, w

[jira] [Updated] (KAFKA-8862) Misleading exception message for non-existant partition

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

[jira] [Assigned] (KAFKA-8862) Misleading exception message for non-existant partition

2025-01-21 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8862: -- Assignee: Matthias J. Sax (was: Tom Bentley) > Misleading exception message for non-e

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17914285#comment-17914285 ] Matthias J. Sax commented on KAFKA-17114: - Oh. My mistake... Sorry. When you re-

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

2025-01-17 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 reassigned KAFKA-17402: --- Assignee: Matthias J. Sax > Test failure: DefaultStateUpdaterTest.shouldGetTasksFro

  1   2   3   4   5   6   7   8   9   10   >