[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-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] [Commented] (KAFKA-15662) Implement support for clientInstanceIds in Kafka Stream

2024-09-15 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881878#comment-17881878 ] Matthias J. Sax commented on KAFKA-15662: - The only missing piece was support wi

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

2024-09-13 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881729#comment-17881729 ] Matthias J. Sax commented on KAFKA-17488: - Yes, that correct. Btw, with regard

[jira] [Commented] (KAFKA-17499) Memory leak when using ReadOnlyKeyValueStore `all()` method

2024-09-13 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881721#comment-17881721 ] Matthias J. Sax commented on KAFKA-17499: - Thanks for the follow up. Two comment

[jira] [Commented] (KAFKA-17445) Kafka streams keeps rebalancing with the following reasons

2024-09-13 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881717#comment-17881717 ] Matthias J. Sax commented on KAFKA-17445: - Setting acceptable recovery lag to ze

[jira] [Commented] (KAFKA-17299) Kafka Streams consumer stops consumption

2024-09-13 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881716#comment-17881716 ] Matthias J. Sax commented on KAFKA-17299: - [~lakshman] – feel free to open a PR

[jira] [Comment Edited] (KAFKA-16339) Remove Deprecated "transformer" methods and classes

2024-09-13 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881627#comment-17881627 ] Matthias J. Sax edited comment on KAFKA-16339 at 9/13/24 4:47 PM:

[jira] [Assigned] (KAFKA-16339) Remove Deprecated "transformer" methods and classes

2024-09-13 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-16339: --- Assignee: João Pedro Fonseca (was: Vrushank Patel) > Remove Deprecated "transforme

[jira] [Commented] (KAFKA-16339) Remove Deprecated "transformer" methods and classes

2024-09-13 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881627#comment-17881627 ] Matthias J. Sax commented on KAFKA-16339: - Seems [~vrushankpatel] did not reply

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

2024-09-13 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: Affects Version/s: 5.0.0 > Remove Deprecates APIs of Kafka Streams in 5.0 > --

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

2024-09-13 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: Fix Version/s: 5.0.0 > Make deprecated *_DOC variable private/package-private > --

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

2024-09-13 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: Affects Version/s: 5.0.0 > Make deprecated *_DOC variable private/package-private > --

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

2024-09-13 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881622#comment-17881622 ] Matthias J. Sax commented on KAFKA-17462: - Hi, thanks for your interest to contr

[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] [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] [Updated] (KAFKA-17537) Remove deprecates methods from Joined class

2024-09-13 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: Fix Version/s: 5.0.0 > Remove deprecates methods from Joined class > -

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

2024-09-13 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: Fix Version/s: 5.0.0 > Remove old PAPI methods > --- > >

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

2024-09-13 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: Fix Version/s: 5.0.0 > Remove deprecates methods JoinWindows#of and #grace > -

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

2024-09-13 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: Fix Version/s: 5.0.0 > Remove deprecated methods from DeserializationExceptionHandler as

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

2024-09-13 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: Affects Version/s: 5.0.0 > Remove deprecated methods from DeserializationExceptionHandler

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

2024-09-13 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: Fix Version/s: 5.0.0 > Removes intermediateTopicsOption from StreamsResetter > ---

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

2024-09-13 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: Affects Version/s: 5.0.0 > Remove deprecates methods from Joined class > -

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

2024-09-13 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: Affects Version/s: 5.0.0 > Remove old PAPI methods > --- > >

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

2024-09-13 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: Affects Version/s: 5.0.0 > Removed Deprecated configs from StreamsConfig > ---

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

2024-09-13 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881618#comment-17881618 ] Matthias J. Sax commented on KAFKA-17531: - We cannot work on this ticket – it's

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

2024-09-13 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17527: Fix Version/s: 3.9.0 > Kafka Streams fails with NPE for missing RecordContext > --

[jira] [Closed] (KAFKA-8666) Improve Documentation on usage of Materialized config object

2024-09-12 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax closed KAFKA-8666. -- > Improve Documentation on usage of Materialized config object > --

[jira] [Commented] (KAFKA-8666) Improve Documentation on usage of Materialized config object

2024-09-12 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881388#comment-17881388 ] Matthias J. Sax commented on KAFKA-8666: Sure. We use "Resolved" and "Closed" int

[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] [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] [Updated] (KAFKA-17538) Make deprecated *_DOC variable private/package-private

2024-09-12 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: Summary: Make deprecated *_DOC variable private/package-private (was: Make deprecated *_D

[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-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] [Updated] (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 updated KAFKA-17427: Description: StreamsConfigs has two variables per config, one for the config name and one

[jira] [Updated] (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 updated KAFKA-17427: Labels: kip (was: needs-kip) > Fix leaking *_DOC variables in StreamsConfig > ---

[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] [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-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] [Updated] (KAFKA-12829) Remove Deprecated methods can classes of old Processor API

2024-09-11 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 updated KAFKA-12829: Description: The following methods were deprecated in version 2.7: * org.apache.kafka.str

[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] [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] [Comment Edited] (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:comment-tabpanel&focusedCommentId=17881126#comment-17881126 ] Matthias J. Sax edited comment on KAFKA-16332 at 9/11/24 9:01 PM:

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17881126#comment-17881126 ] Matthias J. Sax commented on KAFKA-16332: - Filed https://issues.apache.org/jira/

[jira] [Updated] (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 updated KAFKA-16332: Description: Deprecated in 3.0: [https://cwiki.apache.org/confluence/display/KAFKA/KIP-63

[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-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] [Commented] (KAFKA-17524) StreamThreadTest shouldReturnErrorIfProducerInstanceIdNotInitialized hanging

2024-09-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881115#comment-17881115 ] Matthias J. Sax commented on KAFKA-17524: - My PR is not really a fix yet, so let

[jira] [Assigned] (KAFKA-17524) StreamThreadTest shouldReturnErrorIfProducerInstanceIdNotInitialized hanging

2024-09-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-17524: --- Assignee: (was: Matthias J. Sax) > StreamThreadTest shouldReturnErrorIfProducer

[jira] [Updated] (KAFKA-17524) StreamThreadTest shouldReturnErrorIfProducerInstanceIdNotInitialized hanging

2024-09-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17524: Component/s: streams unit tests > StreamThreadTest shouldReturnErrorIfPro

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

2024-09-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-17527: --- Assignee: Matthias J. Sax > Kafka Streams fails with NPE for missing RecordContext

[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-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] [Updated] (KAFKA-17515) Fix flaky RestoreIntegrationTest.shouldInvokeUserDefinedGlobalStateRestoreListener

2024-09-10 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17515: Component/s: streams unit tests > Fix flaky > RestoreIntegrationTest.sho

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

2024-09-09 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17880468#comment-17880468 ] Matthias J. Sax commented on KAFKA-17488: - Sure. Thanks for you interest. > Cle

[jira] [Updated] (KAFKA-17503) The poll-idle-ratio-avg consumer metric is calculated incorrectly

2024-09-09 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17503: Component/s: clients consumer > The poll-idle-ratio-avg consumer metric i

[jira] [Commented] (KAFKA-13588) We should consolidate `changelogFor` methods to simplify the generation of internal topic names

2024-09-09 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17880465#comment-17880465 ] Matthias J. Sax commented on KAFKA-13588: - Thanks! > We should consolidate `cha

[jira] [Updated] (KAFKA-17057) Add "retry" option to ProductionExceptionHandler

2024-09-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17057: Description: With KAFKA-16508 we changed the KS behavior to call the ProductionExceptionH

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

2024-09-06 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17489: Affects Version/s: 3.8.0 > IllegalStateException if failed task is removed from state upda

[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] [Updated] (KAFKA-17486) Fix failed test RestoreIntegrationTest.shouldInvokeUserDefinedGlobalStateRestoreListener

2024-09-05 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17486: Component/s: streams unit tests > Fix failed test > RestoreIntegrationTe

[jira] [Commented] (KAFKA-17487) Race in GlobalStreamThread initialization

2024-09-05 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17879611#comment-17879611 ] Matthias J. Sax commented on KAFKA-17487: - :) > Race in GlobalStreamThread init

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

2024-09-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-17485: --- Assignee: Matthias J. Sax > Replace KafkaClientSupplier with KafkaClientInterceptor

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

2024-09-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17485: Description: Kafka Streams currently support the `KafkaClientSupplier` interface which al

[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] [Updated] (KAFKA-17057) Add "retry" option to ProductionExceptionHandler

2024-09-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17057: Labels: kip (was: ) > Add "retry" option to ProductionExceptionHandler >

[jira] [Commented] (KAFKA-16339) Remove Deprecated "transformer" methods and classes

2024-09-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17879057#comment-17879057 ] Matthias J. Sax commented on KAFKA-16339: - [~vrushankpatel] – when do you plan t

[jira] [Commented] (KAFKA-15344) Kafka Streams should include the message leader epoch when committing offsets

2024-09-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17879025#comment-17879025 ] Matthias J. Sax commented on KAFKA-15344: - Should we close this one, in favor of

[jira] [Assigned] (KAFKA-15344) Kafka Streams should include the message leader epoch when committing offsets

2024-09-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-15344: --- Assignee: Alieh Saeedi (was: Lucas Brutschy) > Kafka Streams should include the me

[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] [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-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] [Assigned] (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 reassigned KAFKA-16502: --- Assignee: (was: Matthias J. Sax) > Fix flaky > EOSUncleanShutdownIntegrationTe

[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] [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] [Assigned] (KAFKA-17474) Flaky tests in GlobalStreamThreadTest

2024-09-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-17474: --- Assignee: Matthias J. Sax > Flaky tests in GlobalStreamThreadTest > ---

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

2024-09-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17879010#comment-17879010 ] Matthias J. Sax commented on KAFKA-17474: - Did find [https://github.com/apache/

[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] [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] [Commented] (KAFKA-16332) Remove Deprecated builder methods for Time/Session/Join/SlidingWindows

2024-09-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878923#comment-17878923 ] Matthias J. Sax commented on KAFKA-16332: - Not sure – somebody needs to pickup K

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

2024-09-02 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878633#comment-17878633 ] Matthias J. Sax commented on KAFKA-16332: - I think we should keep the old JoinWi

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

2024-09-02 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: Labels: (was: needs-kip) > Removes intermediateTopicsOption from StreamsResetter > -

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

2024-09-01 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: Since the removal of the #through method in Jira: https://issues.apache.org/

[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-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] [Updated] (KAFKA-12829) Remove Deprecated methods can classes of old Processor API

2024-08-29 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 updated KAFKA-12829: Description: The following methods were deprecated in version 2.7: * org.apache.kafka.str

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

2024-08-28 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 updated KAFKA-12829: Description: The following methods were deprecated in version 2.7: * org.apache.kafka.str

[jira] [Comment Edited] (KAFKA-15443) Upgrade RocksDB dependency

2024-08-28 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877552#comment-17877552 ] Matthias J. Sax edited comment on KAFKA-15443 at 8/28/24 10:35 PM: ---

[jira] [Commented] (KAFKA-15443) Upgrade RocksDB dependency

2024-08-28 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877552#comment-17877552 ] Matthias J. Sax commented on KAFKA-15443: - The latest version of RocksDB is 9.5.

[jira] [Updated] (KAFKA-15443) Upgrade RocksDB dependency

2024-08-28 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-15443: Priority: Blocker (was: Major) > Upgrade RocksDB dependency > --

[jira] [Assigned] (KAFKA-15443) Upgrade RocksDB dependency

2024-08-28 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-15443: --- Assignee: Matthias J. Sax > Upgrade RocksDB dependency > --

[jira] [Updated] (KAFKA-15443) Upgrade RocksDB dependency

2024-08-28 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-15443: Fix Version/s: 4.0.0 > Upgrade RocksDB dependency > -- > >

[jira] [Commented] (KAFKA-15303) Foreign key joins no longer triggered by events on the right side of the join after deployment with a new compatible Avro schema

2024-08-28 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877478#comment-17877478 ] Matthias J. Sax commented on KAFKA-15303: - Thanks. That is very valuable feedbac

[jira] [Commented] (KAFKA-12834) Remove Deprecated method MockProcessorContext#setTimestamp

2024-08-28 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877477#comment-17877477 ] Matthias J. Sax commented on KAFKA-12834: - No, we can do this now for 4.0 releas

[jira] [Commented] (KAFKA-17380) Kafka Streams few partition stuck in processing - fixed after restart

2024-08-27 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877195#comment-17877195 ] Matthias J. Sax commented on KAFKA-17380: - Thanks for filing a ticket [~rohitbob

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

2024-08-27 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 reassigned KAFKA-17427: --- Assignee: 黃竣陽 > Fix leaking *_DOC variables in StreamsConfig >

[jira] [Updated] (KAFKA-17429) TopologyTestDriver.close() : The processor is already closed when cache is activated on state store

2024-08-27 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17429: Component/s: streams-test-utils (was: unit tests) > TopologyTestDrive

[jira] [Commented] (KAFKA-17429) TopologyTestDriver.close() : The processor is already closed when cache is activated on state store

2024-08-27 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877082#comment-17877082 ] Matthias J. Sax commented on KAFKA-17429: - Thanks. After digging into this a lit

  1   2   3   4   5   6   7   8   9   10   >