[jira] [Commented] (KAFKA-17584) Fix incorrect synonym handling for dynamic log configurations

2024-11-05 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17895872#comment-17895872 ] Matthias J. Sax commented on KAFKA-17584: - Thanks! I'll monitor the PR and wait

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

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

[jira] [Commented] (KAFKA-17584) Fix incorrect synonym handling for dynamic log configurations

2024-11-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17895467#comment-17895467 ] Matthias J. Sax commented on KAFKA-17584: - Thanks. I tried to cherry-pick to 3.7

[jira] [Updated] (KAFKA-16955) ConcurrentModification exception thrown by KafkaStream threadState access

2024-11-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-16955: Fix Version/s: 3.7.2 > ConcurrentModification exception thrown by KafkaStream threadState

[jira] [Commented] (KAFKA-17939) Kafka Streams API exposes org.apache.kafka.common.utils.Bytes which is not part of the public API

2024-11-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17895400#comment-17895400 ] Matthias J. Sax commented on KAFKA-17939: - Hmmm... I see... That's a problem. Th

[jira] [Commented] (KAFKA-17939) Kafka Streams API exposes org.apache.kafka.common.utils.Bytes which is not part of the public API

2024-11-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17895379#comment-17895379 ] Matthias J. Sax commented on KAFKA-17939: - Why is it not part of public API? >

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

2024-11-01 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17894899#comment-17894899 ] Matthias J. Sax commented on KAFKA-17893: - Thanks. Please start a DISCUSS thread

[jira] [Updated] (KAFKA-17584) Fix incorrect synonym handling for dynamic log configurations

2024-11-01 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17584: Affects Version/s: 3.0.0 (was: 3.9.0) > Fix incorrect synonym h

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

2024-10-29 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 updated KAFKA-15344: Fix Version/s: 4.0.0 > Kafka Streams should include the message leader epoch when committi

[jira] [Updated] (KAFKA-16248) Kafka consumer should cache leader offset ranges

2024-10-29 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-16248: Fix Version/s: 4.0.0 > Kafka consumer should cache leader offset ranges >

[jira] [Commented] (KAFKA-17895) Expose KeyValueStore's approximateNumEntries as a metric

2024-10-29 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17894075#comment-17894075 ] Matthias J. Sax commented on KAFKA-17895: - Are you sure it's not collected?  My

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

2024-10-29 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-17893: --- Assignee: Peter Lee > Support record keys in the foreignKeyExtractor argument of KT

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

2024-10-29 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17894076#comment-17894076 ] Matthias J. Sax edited comment on KAFKA-17893 at 10/30/24 6:07 AM: ---

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

2024-10-29 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17894076#comment-17894076 ] Matthias J. Sax commented on KAFKA-17893: - Sure thing :)  > Support record keys

[jira] [Updated] (KAFKA-17895) Expose KeyValueStore's approximateNumEntries as a metric

2024-10-29 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17895: Labels: needs-kip (was: ) > Expose KeyValueStore's approximateNumEntries as a metric > --

[jira] [Comment Edited] (KAFKA-17895) Expose KeyValueStore's approximateNumEntries as a metric

2024-10-29 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17894075#comment-17894075 ] Matthias J. Sax edited comment on KAFKA-17895 at 10/30/24 6:05 AM: ---

[jira] [Updated] (KAFKA-17895) Expose KeyValueStore's approximateNumEntries as a metric

2024-10-29 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17895: Priority: Minor (was: Major) > Expose KeyValueStore's approximateNumEntries as a metric >

[jira] [Updated] (KAFKA-17880) Move integration test from streams module to streams/integration-tests module

2024-10-29 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17880: Component/s: streams unit tests > Move integration test from streams modu

[jira] [Updated] (KAFKA-17872) Kafka stream job does not commit offset when packets are getting ignored intentionally

2024-10-29 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17872: Labels: beginner newbie (was: ) > Kafka stream job does not commit offset when packets ar

[jira] [Commented] (KAFKA-17584) Fix incorrect synonym handling for dynamic log configurations

2024-10-25 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892989#comment-17892989 ] Matthias J. Sax commented on KAFKA-17584: - [~christo_lolov] – why is "affects ve

[jira] [Updated] (KAFKA-17600) Add nextOffsets to the ConsumerRecords

2024-10-25 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17600: Description: KIP-1094 [https://cwiki.apache.org/confluence/display/KAFKA/KIP-1094%3A+Add+a

[jira] [Updated] (KAFKA-17869) Tests for clients ensuring KIP-1076 doesn't affect existing metrics

2024-10-24 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17869: Component/s: admin clients consumer prod

[jira] [Commented] (KAFKA-17857) Move AbstractResetIntegrationTest and subclasses to tools

2024-10-24 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892629#comment-17892629 ] Matthias J. Sax commented on KAFKA-17857: - I thinks it's fine to move the integr

[jira] [Updated] (KAFKA-17600) Add nextOffsets to the ConsumerRecords

2024-10-24 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17600: Labels: kip (was: ) > Add nextOffsets to the ConsumerRecords > --

[jira] [Commented] (KAFKA-17455) `TaskCorruptedException` After Client Quota Throttling

2024-10-23 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892293#comment-17892293 ] Matthias J. Sax commented on KAFKA-17455: - Should we update this ticket "compone

[jira] [Updated] (KAFKA-17455) `TaskCorruptedException` After Client Quota Throttling

2024-10-23 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17455: Component/s: producer (was: streams) > `TaskCorruptedException` Afte

[jira] [Updated] (KAFKA-17854) add tests for `ReadOnlyWindowStoreStub#fetch(null, null ...)`

2024-10-22 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17854: Component/s: streams unit tests > add tests for `ReadOnlyWindowStoreStub#

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

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

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

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

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

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

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

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

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

2024-10-22 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17891978#comment-17891978 ] Matthias J. Sax commented on KAFKA-17499: - It was never confirmed as a bug (and

[jira] [Commented] (KAFKA-14922) kafka-streams-application-reset deletes topics not belonging to specified application-id

2024-10-21 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17891703#comment-17891703 ] Matthias J. Sax commented on KAFKA-14922: - Sure. Done. You could have just self-

[jira] [Assigned] (KAFKA-14922) kafka-streams-application-reset deletes topics not belonging to specified application-id

2024-10-21 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-14922: --- Assignee: Devanshi Khatsuriya > kafka-streams-application-reset deletes topics not

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

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

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

2024-10-17 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890761#comment-17890761 ] Matthias J. Sax commented on KAFKA-16336: - Thanks. Let's close this ticket. > R

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

2024-10-16 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-17697: --- Assignee: Bruno Cadonna (was: Yu-Lin Chen) > Fix flaky DefaultStateUpdaterTest.sho

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

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

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

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

[jira] [Updated] (KAFKA-17810) Update Jetty to 9.4.56

2024-10-16 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17810: Priority: Blocker (was: Major) > Update Jetty to 9.4.56 > -- > >

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

2024-10-16 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890265#comment-17890265 ] Matthias J. Sax edited comment on KAFKA-16336 at 10/16/24 11:18 PM: --

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

2024-10-16 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890265#comment-17890265 ] Matthias J. Sax commented on KAFKA-16336: - I did some digging and could not find

[jira] [Assigned] (KAFKA-16567) Add New Stream Metrics based on KIP-869

2024-10-16 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-16567: --- Assignee: Guozhang Wang > Add New Stream Metrics based on KIP-869 > ---

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

2024-10-16 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-6197: -- Assignee: Devanshi Khatsuriya > Difficult to get to the Kafka Streams javadocs > -

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

2024-10-16 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890141#comment-17890141 ] Matthias J. Sax commented on KAFKA-16337: - Yes, this is all for 5.0. None of the

[jira] [Updated] (KAFKA-17789) State updater stuck when starting with empty state folder

2024-10-15 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17789: Fix Version/s: (was: 4.0.0) > State updater stuck when starting with empty state folde

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

2024-10-15 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17889890#comment-17889890 ] Matthias J. Sax commented on KAFKA-17462: - See my last comment: {quote}For this

[jira] [Assigned] (KAFKA-17600) Add nextOffsets to the ConsumerRecords

2024-10-15 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-17600: --- Assignee: Alieh Saeedi > Add nextOffsets to the ConsumerRecords > -

[jira] [Updated] (KAFKA-17731) Kafka consumer client sometimes elapses wait time for terminating telemetry push

2024-10-09 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17731: Fix Version/s: 3.7.2 3.8.1 3.9.1 > Kafka consumer cl

[jira] [Updated] (KAFKA-17731) Kafka consumer client sometimes elapses wait time for terminating telemetry push

2024-10-09 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17731: Priority: Blocker (was: Major) > Kafka consumer client sometimes elapses wait time for te

[jira] [Updated] (KAFKA-17692) Remove KafkaServer references in streams tests

2024-10-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17692: Component/s: streams unit tests > Remove KafkaServer references in stream

[jira] [Commented] (KAFKA-14922) kafka-streams-application-reset deletes topics not belonging to specified application-id

2024-10-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17887030#comment-17887030 ] Matthias J. Sax commented on KAFKA-14922: - We did label it for newbies for reaso

[jira] [Commented] (KAFKA-14922) kafka-streams-application-reset deletes topics not belonging to specified application-id

2024-10-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17886820#comment-17886820 ] Matthias J. Sax commented on KAFKA-14922: - That's fair points – guess, we can di

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

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

[jira] [Commented] (KAFKA-17580) Java 21 spurious compilation failure in streams:compileTestJava

2024-10-02 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17886504#comment-17886504 ] Matthias J. Sax commented on KAFKA-17580: - [~davidarthur] – did we see this more

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

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

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

2024-10-01 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17886245#comment-17886245 ] Matthias J. Sax commented on KAFKA-17649: - [~linu] – thanks for your interest on

[jira] [Updated] (KAFKA-12823) Remove Deprecated method KStream#through

2024-09-28 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12823: Description: The method through in Java and Scala class KStream was deprecated in version

[jira] [Updated] (KAFKA-12823) Remove Deprecated method KStream#through

2024-09-28 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12823: Component/s: kip > Remove Deprecated method KStream#through >

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

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

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

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

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

2024-09-28 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885605#comment-17885605 ] Matthias J. Sax commented on KAFKA-16336: - [~frankvicky] – We had more discussio

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

2024-09-26 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885180#comment-17885180 ] Matthias J. Sax commented on KAFKA-16339: - I think it's best to do the PRs linea

[jira] [Commented] (KAFKA-16394) ForeignKey LEFT join propagates null value on foreignKey change

2024-09-26 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885177#comment-17885177 ] Matthias J. Sax commented on KAFKA-16394: - Unfortunately not... But thanks for t

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

2024-09-26 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 edited comment on KAFKA-17445 at 9/27/24 12:35 AM: ---

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

2024-09-26 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885185#comment-17885185 ] Matthias J. Sax commented on KAFKA-17445: - Thanks for the feedback. Sounds you a

[jira] [Commented] (KAFKA-14922) kafka-streams-application-reset deletes topics not belonging to specified application-id

2024-09-26 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885183#comment-17885183 ] Matthias J. Sax commented on KAFKA-14922: - > Is it possible to check if an appli

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

2024-09-26 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885182#comment-17885182 ] Matthias J. Sax commented on KAFKA-17558: - Sure thing :) – Thanks for your inter

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

2024-09-26 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-17558: --- Assignee: zhengke zhou > Cleanup Kafka Streams integration tests >

[jira] [Comment Edited] (KAFKA-14922) kafka-streams-application-reset deletes topics not belonging to specified application-id

2024-09-26 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17879612#comment-17879612 ] Matthias J. Sax edited comment on KAFKA-14922 at 9/27/24 12:30 AM: ---

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

2024-09-26 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885181#comment-17885181 ] Matthias J. Sax commented on KAFKA-16339: - Just realize that you did already ope

[jira] [Updated] (KAFKA-17609) Convert Kafka Streams system tests to use KRaft

2024-09-26 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17609: Fix Version/s: 4.0.0 > Convert Kafka Streams system tests to use KRaft > -

[jira] [Updated] (KAFKA-17609) Convert Kafka Streams system tests to use KRaft

2024-09-26 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17609: Priority: Blocker (was: Major) > Convert Kafka Streams system tests to use KRaft > --

[jira] [Updated] (KAFKA-17609) Convert Kafka Streams system tests to use KRaft

2024-09-26 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17609: Component/s: streams system tests > Convert Kafka Streams system tests to

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

2024-09-26 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17622: Component/s: streams > Kafka Streams Timeout During Partition Rebalance > ---

[jira] [Updated] (KAFKA-17600) Add nextOffsets to the ConsumerRecords

2024-09-24 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17600: Component/s: clients consumer > Add nextOffsets to the ConsumerRecords >

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

2024-09-22 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883631#comment-17883631 ] Matthias J. Sax commented on KAFKA-17551: - Thanks for your interest to contribut

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

  1   2   3   4   5   6   7   8   9   10   >