[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

[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

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

Re: Add Jira ID request

2024-09-15 Thread Matthias J. Sax
You should be all set. On 9/13/24 7:47 PM, 最红 wrote: Hi, I'd like to apply for a jira id to contribute to Kafka. Jira ID: veryfirefly Thank you

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

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

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

[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

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

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

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

[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

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

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

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

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

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

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

[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

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

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

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

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

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

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

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

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

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

[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

[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

[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

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

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

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

[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

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

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

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

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

[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

[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

[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

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

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

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

Re: New release branch 3.9

2024-09-11 Thread Matthias J. Sax
Hi Colin, we found another blocker bug: https://issues.apache.org/jira/browse/KAFKA-17527 Working on a fix. -Matthias On 9/9/24 6:51 PM, David Arthur wrote: Colin, I found a race condition in the migration while investigating a flaky test. If encountered, the migration driver will get stu

[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

Re: [DISCUSS] KIP-1065: Add "retry" return-option to ProductionExceptionHandler

2024-09-10 Thread Matthias J. Sax
s KIP and corresponding PRs asap and go for the follow-up KIPs. Thanks, Alieh On Sat, Jul 13, 2024 at 1:54 AM Matthias J. Sax wrote: After talking to a few people in-person, it seems there was concerns that KAFKA-16508 should be considered a backward incompatible change. While this KIP s

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

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

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

Re: [ANNOUNCE] New committer: Jeff Kim

2024-09-09 Thread Matthias J. Sax
Congrats! On 9/9/24 12:34 PM, José Armando García Sancio wrote: Congratulations Jeff! On Mon, Sep 9, 2024 at 11:45 AM Justine Olshan wrote: Congratulations Jeff! On Mon, Sep 9, 2024 at 8:33 AM Satish Duggana wrote: Congratulations Jeff! On Mon, 9 Sept 2024 at 18:37, Bruno Cadonna wrote

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

[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

Re: [ANNOUNCE] New Kafka PMC Member: Josep Prat

2024-09-06 Thread Matthias J. Sax
Congrats! On 9/6/24 9:40 AM, Greg Harris wrote: Congratulations! On Fri, Sep 6, 2024 at 9:39 AM Muralidhar Basani wrote: Congrats Josep. Well deserved. -Murali On Fri, 6 Sep 2024 at 18:34, Bill Bejeck wrote: Congratulations Josep, well deserved! -Bill On Fri, Sep 6, 2024 at 12:30 PM C

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

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

Re: [EXT] Re: [VOTE] KIP-1033: Add Kafka Streams exception handler for exceptions occurring during processing

2024-09-05 Thread Matthias J. Sax
, even though we're past code freeze. Please try to get it done this week, though :) best, Colin On Fri, Aug 30, 2024, at 19:03, Matthias J. Sax wrote: Guess it is a question for Colin, who is the RM for 3.9. -Matthias On 8/30/24 2:02 AM, Sebastien Viale wrote: Hi, All PRs related t

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

Re: [VOTE] KIP-1085: Fix leaking *_DOC variables in StreamsConfig

2024-09-05 Thread Matthias J. Sax
+1 (binding) On 9/5/24 06:34, Chia-Ping Tsai wrote: +1 (binding) 黃竣陽 於 2024年9月5日 週四 下午9:13寫道: Hello everyone, I would like to call for a vote on KIP-1085: < https://cwiki.apache.org/confluence/display/KAFKA/KIP-1085%3A+Fix+leaking+*_DOC+variables+in+StreamsConfig The discussion can be f

Re: [VOTE] KIP-1085: Fix leaking *_DOC variables in StreamsConfig

2024-09-05 Thread Matthias J. Sax
+1 (binding) On 9/5/24 06:34, Chia-Ping Tsai wrote: +1 (binding) 黃竣陽 於 2024年9月5日 週四 下午9:13寫道: Hello everyone, I would like to call for a vote on KIP-1085: < https://cwiki.apache.org/confluence/display/KAFKA/KIP-1085%3A+Fix+leaking+*_DOC+variables+in+StreamsConfig The discussion can be f

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

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

[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

Re: [DISCUSS] KIP-1071: Streams Rebalance Protocol

2024-09-04 Thread Matthias J. Sax
I still need to catch up on the discussion in general. But as promised, I just started KIP-1088 about the `KafkaClientSupplier` question. Looking forward to your feedback on the new KIP. I hope we can get KIP-1088 done soon, to not block this KIP. -Matthias On 9/4/24 09:52, Lucas Brutschy w

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

[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

Re: [DISCUSS] KIP-1085: Fix leaking *_DOC variables in StreamsConfig

2024-09-03 Thread Matthias J. Sax
-Matthias On 9/3/24 4:27 PM, Matthias J. Sax wrote: Thanks for the KIP. I think it's a good clean. Given that it's a simple KIP, I don't expect much more discussions; feel free to start a vote. -Matthias On 8/28/24 10:37 PM, 黃竣陽 wrote: Hi Chia-Ping they can be package-p

Re: [DISCUSS] KIP-1085: Fix leaking *_DOC variables in StreamsConfig

2024-09-03 Thread Matthias J. Sax
Thanks for the KIP. I think it's a good clean. Given that it's a simple KIP, I don't expect much more discussions; feel free to start a vote. -Matthias On 8/28/24 10:37 PM, 黃竣陽 wrote: Hi Chia-Ping they can be package-private, right? Yes, your are right, I will address there variables on

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

[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

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

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

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

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

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

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

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

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

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

Re: [VOTE] KIP-1076: Metrics for client applications a KIP-714 extension

2024-09-03 Thread Matthias J. Sax
+1 (binding) On 9/3/24 8:56 AM, Andrew Schofield wrote: Thanks for the KIP. +1 (non-binding) Andrew From: Lucas Brutschy Sent: 03 September 2024 16:02 To: dev@kafka.apache.org Subject: Re: [VOTE] KIP-1076: Metrics for client applications a KIP-714 extension

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

[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

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

[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

Re: Request to Contribute to Apache Kafka

2024-09-01 Thread Matthias J. Sax
You should be all set now. On 8/30/24 9:54 PM, Arnav Dadarya wrote: To whom it may concern, I would like permission to contribute to Apache Kafka (Creating a KIP). I have attached my Jira Id and wiki ID below: Jira ID: ardada2468 Wiki ID: ardada2468 sincerely & thanks, Arnav Dadarya

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

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

  1   2   3   4   5   6   7   8   9   10   >