[jira] [Commented] (KAFKA-13014) KAFKA-Stream stucked when the offset is no more existing

[ https://issues.apache.org/jira/browse/KAFKA-13014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17380048#comment-17380048 ] Matthias J. Sax commented on KAFKA-13014: - Could you resolve the issue by bouncing the Kafka

[jira] [Comment Edited] (KAFKA-13032) Impossible stacktrace

[ https://issues.apache.org/jira/browse/KAFKA-13032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17380020#comment-17380020 ] Matthias J. Sax edited comment on KAFKA-13032 at 7/13/21, 4:26 PM: ---

[jira] [Commented] (KAFKA-13032) Impossible stacktrace

[ https://issues.apache.org/jira/browse/KAFKA-13032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17380020#comment-17380020 ] Matthias J. Sax commented on KAFKA-13032: - Looking into the code, it seems that your

[jira] [Updated] (KAFKA-13036) Replace EasyMock and PowerMock with Mockito for RocksDBMetricsRecorderTest

[ https://issues.apache.org/jira/browse/KAFKA-13036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13036: Component/s: unit tests streams > Replace EasyMock and PowerMock with

[jira] [Resolved] (KAFKA-8613) Make grace period mandatory

[ https://issues.apache.org/jira/browse/KAFKA-8613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8613. Resolution: Fixed > Make grace period mandatory > --- > >

[jira] [Updated] (KAFKA-9559) Change the default "default serde" from ByteArraySerde to null

[ https://issues.apache.org/jira/browse/KAFKA-9559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9559: --- Description: The current default "default serde" is not particularly useful, and in almost

[jira] [Updated] (KAFKA-9559) Change the default "default serde" from ByteArraySerde to null

[ https://issues.apache.org/jira/browse/KAFKA-9559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9559: --- Labels: kip (was: needs-kip) > Change the default "default serde" from ByteArraySerde to

[jira] [Commented] (KAFKA-12984) Cooperative sticky assignor can get stuck with invalid SubscriptionState input metadata

[ https://issues.apache.org/jira/browse/KAFKA-12984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17368353#comment-17368353 ] Matthias J. Sax commented on KAFKA-12984: - [~ableegoldman] – is KS affected by this issue? Even

[jira] [Commented] (KAFKA-12972) KStreams - Rebalance not happening after new consumer member joins group

[ https://issues.apache.org/jira/browse/KAFKA-12972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366745#comment-17366745 ] Matthias J. Sax commented on KAFKA-12972: - Is your application stateful? How long did you wait?

[jira] [Commented] (KAFKA-12718) SessionWindows are closed too early

[ https://issues.apache.org/jira/browse/KAFKA-12718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17365846#comment-17365846 ] Matthias J. Sax commented on KAFKA-12718: - For flaky tests that fail more recently, we create

[jira] [Commented] (KAFKA-12718) SessionWindows are closed too early

[ https://issues.apache.org/jira/browse/KAFKA-12718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17365248#comment-17365248 ] Matthias J. Sax commented on KAFKA-12718: - Not sure what you mean. Just looked at your PR (and

[jira] [Commented] (KAFKA-9897) Flaky Test StoreQueryIntegrationTest#shouldQuerySpecificActivePartitionStores

[ https://issues.apache.org/jira/browse/KAFKA-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17365048#comment-17365048 ] Matthias J. Sax commented on KAFKA-9897:

[jira] [Updated] (KAFKA-12951) Infinite loop while restoring a GlobalKTable

[ https://issues.apache.org/jira/browse/KAFKA-12951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12951: Affects Version/s: (was: 2.7.1) (was: 2.8.0)

[jira] [Created] (KAFKA-12960) WindowStore and SessionStore do not enforce strict retention time

Matthias J. Sax created KAFKA-12960: --- Summary: WindowStore and SessionStore do not enforce strict retention time Key: KAFKA-12960 URL: https://issues.apache.org/jira/browse/KAFKA-12960 Project:

[jira] [Commented] (KAFKA-12401) Flaky Test FeatureCommandTest#testUpgradeAllFeaturesSuccess

[ https://issues.apache.org/jira/browse/KAFKA-12401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364507#comment-17364507 ] Matthias J. Sax commented on KAFKA-12401: -

[jira] [Commented] (KAFKA-12629) Failing Test: RaftClusterTest

[ https://issues.apache.org/jira/browse/KAFKA-12629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364362#comment-17364362 ] Matthias J. Sax commented on KAFKA-12629: - Failed two more times -

[jira] [Commented] (KAFKA-12678) Flaky Test CustomQuotaCallbackTest.testCustomQuotaCallback

[ https://issues.apache.org/jira/browse/KAFKA-12678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364360#comment-17364360 ] Matthias J. Sax commented on KAFKA-12678: - Failed again:

[jira] [Updated] (KAFKA-12951) Infinite loop while restoring a GlobalKTable

[ https://issues.apache.org/jira/browse/KAFKA-12951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12951: Description: We encountered an issue a few time in some of our Kafka Streams application.

[jira] [Updated] (KAFKA-12951) Infinite loop while restoring a GlobalKTable

[ https://issues.apache.org/jira/browse/KAFKA-12951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12951: Description: We encountered an issue a few time in some of our Kafka Streams application.

[jira] [Updated] (KAFKA-12951) Infinite loop while restoring a GlobalKTable

[ https://issues.apache.org/jira/browse/KAFKA-12951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12951: Affects Version/s: 2.8.0 2.7.1 > Infinite loop while restoring a

[jira] [Assigned] (KAFKA-12951) Infinite loop while restoring a GlobalKTable

[ https://issues.apache.org/jira/browse/KAFKA-12951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-12951: --- Assignee: Matthias J. Sax > Infinite loop while restoring a GlobalKTable >

[jira] [Updated] (KAFKA-12950) Replace EasyMock and PowerMock with Mockito for KafkaStreamsTest

[ https://issues.apache.org/jira/browse/KAFKA-12950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12950: Component/s: unit tests streams > Replace EasyMock and PowerMock with

[jira] [Updated] (KAFKA-12914) StreamSourceNode.toString() throws with StreamsBuilder.stream(Pattern) ctor

[ https://issues.apache.org/jira/browse/KAFKA-12914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12914: Fix Version/s: 2.8.1 > StreamSourceNode.toString() throws with

[jira] [Updated] (KAFKA-12943) Bug in Kafka Streams Documentation (Aggregating)

[ https://issues.apache.org/jira/browse/KAFKA-12943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12943: Component/s: streams documentation > Bug in Kafka Streams Documentation

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

[ https://issues.apache.org/jira/browse/KAFKA-7302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363432#comment-17363432 ] Matthias J. Sax commented on KAFKA-7302: Add you to the list of contributors. You can know

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

[ https://issues.apache.org/jira/browse/KAFKA-7302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-7302: -- Assignee: Vijay > Remove Java7 examples from Streams Docs >

[jira] [Updated] (KAFKA-6435) Application Reset Tool might delete incorrect internal topics

[ https://issues.apache.org/jira/browse/KAFKA-6435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6435: --- Labels: bug help-wanted kip newbie (was: bug help-wanted needs-kip newbie) > Application

[jira] [Updated] (KAFKA-10434) Remove deprecated methods on WindowStore

[ https://issues.apache.org/jira/browse/KAFKA-10434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10434: Labels: (was: needs-kip) > Remove deprecated methods on WindowStore >

[jira] [Commented] (KAFKA-10091) Improve task idling

[ https://issues.apache.org/jira/browse/KAFKA-10091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361941#comment-17361941 ] Matthias J. Sax commented on KAFKA-10091: - I thought this is completed and shipped with 2.8.0 ?

[jira] [Updated] (KAFKA-12849) Consider migrating TaskMetadata to interface with internal implementation

[ https://issues.apache.org/jira/browse/KAFKA-12849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12849: Description: In KIP-740 we had to go through a deprecation cycle in order to change the

[jira] [Updated] (KAFKA-12849) Consider migrating TaskMetadata to interface with internal implementation

[ https://issues.apache.org/jira/browse/KAFKA-12849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12849: Labels: kip newbie newbie++ (was: needs-kip newbie newbie++) > Consider migrating

[jira] [Commented] (KAFKA-12851) Flaky Test RaftEventSimulationTest.canMakeProgressIfMajorityIsReachable

[ https://issues.apache.org/jira/browse/KAFKA-12851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361312#comment-17361312 ] Matthias J. Sax commented on KAFKA-12851: - Failed again. > Flaky Test

[jira] [Created] (KAFKA-12935) Flaky Test RestoreIntegrationTest.shouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore

Matthias J. Sax created KAFKA-12935: --- Summary: Flaky Test RestoreIntegrationTest.shouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore Key: KAFKA-12935 URL:

[jira] [Commented] (KAFKA-9897) Flaky Test StoreQueryIntegrationTest#shouldQuerySpecificActivePartitionStores

[ https://issues.apache.org/jira/browse/KAFKA-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361180#comment-17361180 ] Matthias J. Sax commented on KAFKA-9897: Different test, but same sympton:

[jira] [Commented] (KAFKA-12377) Flaky Test SaslAuthenticatorTest#testSslClientAuthRequiredForSaslSslListener

[ https://issues.apache.org/jira/browse/KAFKA-12377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361177#comment-17361177 ] Matthias J. Sax commented on KAFKA-12377: - Failed again. > Flaky Test

[jira] [Commented] (KAFKA-8940) Flaky Test SmokeTestDriverIntegrationTest.shouldWorkWithRebalance

[ https://issues.apache.org/jira/browse/KAFKA-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361176#comment-17361176 ] Matthias J. Sax commented on KAFKA-8940: Failed again. > Flaky Test

[jira] [Commented] (KAFKA-12933) Flaky test ReassignPartitionsIntegrationTest.testReassignmentWithAlterIsrDisabled

[ https://issues.apache.org/jira/browse/KAFKA-12933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361174#comment-17361174 ] Matthias J. Sax commented on KAFKA-12933: - Failed a second time. > Flaky test >

[jira] [Created] (KAFKA-12933) Flaky test ReassignPartitionsIntegrationTest.testReassignmentWithAlterIsrDisabled

Matthias J. Sax created KAFKA-12933: --- Summary: Flaky test ReassignPartitionsIntegrationTest.testReassignmentWithAlterIsrDisabled Key: KAFKA-12933 URL: https://issues.apache.org/jira/browse/KAFKA-12933

[jira] [Commented] (KAFKA-12925) prefixScan missing from intermediate interfaces

[ https://issues.apache.org/jira/browse/KAFKA-12925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17360548#comment-17360548 ] Matthias J. Sax commented on KAFKA-12925: - Thanks [~sagarrao]! Maybe the easiest way is to

[jira] [Updated] (KAFKA-4327) Move Reset Tool from core to streams

[ https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4327: --- Description: This is a follow up on https://issues.apache.org/jira/browse/KAFKA-4008

[jira] [Commented] (KAFKA-4327) Move Reset Tool from core to streams

[ https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17360468#comment-17360468 ] Matthias J. Sax commented on KAFKA-4327: As 3.0 KIP deadline passed today, I think we need to

[jira] [Updated] (KAFKA-4327) Move Reset Tool from core to streams

[ https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4327: --- Labels: kip (was: needs-kip) > Move Reset Tool from core to streams >

[jira] [Commented] (KAFKA-12925) prefixScan missing from intermediate interfaces

[ https://issues.apache.org/jira/browse/KAFKA-12925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17360467#comment-17360467 ] Matthias J. Sax commented on KAFKA-12925: - [~sagarrao] [~cadonna] [~guozhang] – I had a quick

[jira] [Commented] (KAFKA-12657) Flaky Tests BlockingConnectorTest.testWorkerRestartWithBlockInConnectorStop

[ https://issues.apache.org/jira/browse/KAFKA-12657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17360461#comment-17360461 ] Matthias J. Sax commented on KAFKA-12657: -

[jira] [Commented] (KAFKA-9009) Flaky Test kafka.integration.MetricsDuringTopicCreationDeletionTest.testMetricsDuringTopicCreateDelete

[ https://issues.apache.org/jira/browse/KAFKA-9009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17360462#comment-17360462 ] Matthias J. Sax commented on KAFKA-9009: Any progress? Failed gain: 

[jira] [Updated] (KAFKA-7342) Migrate streams modules to JUnit 5

[ https://issues.apache.org/jira/browse/KAFKA-7342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7342: --- Component/s: unit tests > Migrate streams modules to JUnit 5 >

[jira] [Updated] (KAFKA-12924) Replace EasyMock and PowerMock with Mockito in streams module(metrics)

[ https://issues.apache.org/jira/browse/KAFKA-12924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12924: Component/s: unit tests streams > Replace EasyMock and PowerMock with

[jira] [Assigned] (KAFKA-12914) StreamSourceNode.toString() throws with StreamsBuilder.stream(Pattern) ctor

[ https://issues.apache.org/jira/browse/KAFKA-12914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-12914: --- Assignee: Matthias J. Sax > StreamSourceNode.toString() throws with

[jira] [Resolved] (KAFKA-12912) fdgfdgfg

[ https://issues.apache.org/jira/browse/KAFKA-12912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-12912. - Resolution: Invalid > fdgfdgfg > > > Key: KAFKA-12912 >

[jira] [Commented] (KAFKA-12870) RecordAccumulator stuck in a flushing state

[ https://issues.apache.org/jira/browse/KAFKA-12870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17359447#comment-17359447 ] Matthias J. Sax commented on KAFKA-12870: - Could this be related to

[jira] [Assigned] (KAFKA-12909) Allow users to opt-into spurious left/outer stream-stream join improvement

[ https://issues.apache.org/jira/browse/KAFKA-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-12909: --- Assignee: Matthias J. Sax > Allow users to opt-into spurious left/outer

[jira] [Created] (KAFKA-12909) Allow users to opt-into spurious left/outer stream-stream join improvement

Matthias J. Sax created KAFKA-12909: --- Summary: Allow users to opt-into spurious left/outer stream-stream join improvement Key: KAFKA-12909 URL: https://issues.apache.org/jira/browse/KAFKA-12909

[jira] [Updated] (KAFKA-8613) Make grace period mandatory

[ https://issues.apache.org/jira/browse/KAFKA-8613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8613: --- Description: Currently, the grace period is set to retention time if the grace period is not

[jira] [Updated] (KAFKA-8613) Make grace period mandatory

[ https://issues.apache.org/jira/browse/KAFKA-8613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8613: --- Summary: Make grace period mandatory (was: Set default grace period to 0) > Make grace

[jira] [Updated] (KAFKA-9929) Support reverse iterator on WindowStore

[ https://issues.apache.org/jira/browse/KAFKA-9929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9929: --- Description: KIP-617:

[jira] [Updated] (KAFKA-9929) Support reverse iterator on WindowStore

[ https://issues.apache.org/jira/browse/KAFKA-9929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9929: --- Labels: kip (was: needs-kip) > Support reverse iterator on WindowStore >

[jira] [Commented] (KAFKA-12629) Failing Test: RaftClusterTest

[ https://issues.apache.org/jira/browse/KAFKA-12629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17356149#comment-17356149 ] Matthias J. Sax commented on KAFKA-12629: - Sweet! Failed again:

[jira] [Updated] (KAFKA-10493) KTable out-of-order updates are not being ignored

[ https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10493: Fix Version/s: (was: 3.0.0) 4.0.0 > KTable out-of-order updates

[jira] [Commented] (KAFKA-10493) KTable out-of-order updates are not being ignored

[ https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17356055#comment-17356055 ] Matthias J. Sax commented on KAFKA-10493: - Seems we cannot agree on a solution for now. Pushing

[jira] [Commented] (KAFKA-12718) SessionWindows are closed too early

[ https://issues.apache.org/jira/browse/KAFKA-12718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17356005#comment-17356005 ] Matthias J. Sax commented on KAFKA-12718: - Thanks [~guozhang] – given the last message from

[jira] [Updated] (KAFKA-12317) Relax non-null key requirement for left/outer KStream joins

[ https://issues.apache.org/jira/browse/KAFKA-12317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12317: Description: Currently, for a stream-streams and stream-table/globalTable join

[jira] [Updated] (KAFKA-12317) Relax non-null key requirement for left KStream joins

[ https://issues.apache.org/jira/browse/KAFKA-12317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12317: Description: Currently, for a stream-streams and stream-table/globalTable join

[jira] [Updated] (KAFKA-12317) Relax non-null key requirement for left/outer KStream joins

[ https://issues.apache.org/jira/browse/KAFKA-12317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12317: Summary: Relax non-null key requirement for left/outer KStream joins (was: Relax

[jira] [Updated] (KAFKA-12317) Relax non-null key requirement for left KStream-KTable join

[ https://issues.apache.org/jira/browse/KAFKA-12317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12317: Description: Currently, for a stream-table join KafkaStreams drops all stream records

[jira] [Updated] (KAFKA-12317) Relax non-null key requirement for left KStream joins

[ https://issues.apache.org/jira/browse/KAFKA-12317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12317: Summary: Relax non-null key requirement for left KStream joins (was: Relax non-null key

[jira] [Comment Edited] (KAFKA-12718) SessionWindows are closed too early

[ https://issues.apache.org/jira/browse/KAFKA-12718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17355521#comment-17355521 ] Matthias J. Sax edited comment on KAFKA-12718 at 6/2/21, 7:09 AM: --

[jira] [Commented] (KAFKA-12718) SessionWindows are closed too early

[ https://issues.apache.org/jira/browse/KAFKA-12718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17355521#comment-17355521 ] Matthias J. Sax commented on KAFKA-12718: - `key=[k1@0/5]` is the key of a session, with data key

[jira] [Commented] (KAFKA-12845) Rollback change which requires join key to be non null on KStream->GlobalKTable

[ https://issues.apache.org/jira/browse/KAFKA-12845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17355514#comment-17355514 ] Matthias J. Sax commented on KAFKA-12845: - {quote}It was already there. KStream->KTable *and* 

[jira] [Resolved] (KAFKA-12845) Rollback change which requires join key to be non null on KStream->GlobalKTable

[ https://issues.apache.org/jira/browse/KAFKA-12845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-12845. - Resolution: Duplicate > Rollback change which requires join key to be non null on >

[jira] [Commented] (KAFKA-12845) Rollback change which requires join key to be non null on KStream->GlobalKTable

[ https://issues.apache.org/jira/browse/KAFKA-12845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17352870#comment-17352870 ] Matthias J. Sax commented on KAFKA-12845: - Ah. I see what you are saying. Sorry that I

[jira] [Commented] (KAFKA-12824) Remove Deprecated method KStream#branch

[ https://issues.apache.org/jira/browse/KAFKA-12824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351939#comment-17351939 ] Matthias J. Sax commented on KAFKA-12824: - It's not totally clear, but 4.0 should be the first

[jira] [Commented] (KAFKA-12845) Rollback change which requires join key to be non null on KStream->GlobalKTable

[ https://issues.apache.org/jira/browse/KAFKA-12845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351308#comment-17351308 ] Matthias J. Sax commented on KAFKA-12845: - I think you confuse "input record key" with

[jira] [Updated] (KAFKA-12839) SlidingWindow with timeDifference zero fails

[ https://issues.apache.org/jira/browse/KAFKA-12839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12839: Summary: SlidingWindow with timeDifference zero fails (was: SlidingWindow with

[jira] [Updated] (KAFKA-12839) SlidingWindow with timeDifference 0 fails

[ https://issues.apache.org/jira/browse/KAFKA-12839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12839: Summary: SlidingWindow with timeDifference 0 fails (was: SlidingWindow with size 0

[jira] [Updated] (KAFKA-12839) SlidingWindow with size 0 fails

[ https://issues.apache.org/jira/browse/KAFKA-12839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12839: Labels: needs-kip (was: ) > SlidingWindow with size 0 fails >

[jira] [Created] (KAFKA-12839) SlidingWindow with size 0 fails

Matthias J. Sax created KAFKA-12839: --- Summary: SlidingWindow with size 0 fails Key: KAFKA-12839 URL: https://issues.apache.org/jira/browse/KAFKA-12839 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-5676) MockStreamsMetrics should be in o.a.k.test

[ https://issues.apache.org/jira/browse/KAFKA-5676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17349843#comment-17349843 ] Matthias J. Sax commented on KAFKA-5676: Sure, feel free to pick it up. I never looked into the

[jira] [Commented] (KAFKA-12824) Remove Deprecated method KStream#branch

[ https://issues.apache.org/jira/browse/KAFKA-12824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17349840#comment-17349840 ] Matthias J. Sax commented on KAFKA-12824: - KIP-418 was only merged in 2.8 so I think it will be

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

[ https://issues.apache.org/jira/browse/KAFKA-12827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17349839#comment-17349839 ] Matthias J. Sax commented on KAFKA-12827: - KIP-663 was only merged in 2.8, so I think it will be

[jira] [Commented] (KAFKA-12830) Remove Deprecated constructor in TimeWindowedDeserializer and TimeWindowedSerde

[ https://issues.apache.org/jira/browse/KAFKA-12830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17349838#comment-17349838 ] Matthias J. Sax commented on KAFKA-12830: - KIP-659 was only merged in 2.8 so I think it will be

[jira] [Comment Edited] (KAFKA-12833) Remove Deprecated methods under TopologyTestDriver

[ https://issues.apache.org/jira/browse/KAFKA-12833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17349835#comment-17349835 ] Matthias J. Sax edited comment on KAFKA-12833 at 5/22/21, 8:24 PM: --- If

[jira] [Commented] (KAFKA-12832) Remove Deprecated methods under RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter

[ https://issues.apache.org/jira/browse/KAFKA-12832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17349837#comment-17349837 ] Matthias J. Sax commented on KAFKA-12832: - KIP-471 was only merged in 3.0.0, so I think it will

[jira] [Commented] (KAFKA-12833) Remove Deprecated methods under TopologyTestDriver

[ https://issues.apache.org/jira/browse/KAFKA-12833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17349835#comment-17349835 ] Matthias J. Sax commented on KAFKA-12833: - KIP-622 was only merged in 2.8 so I think it will be

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

[ https://issues.apache.org/jira/browse/KAFKA-12834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17349834#comment-17349834 ] Matthias J. Sax commented on KAFKA-12834: - KIP-622 was only merged in 3.0.0, so I think it will

[jira] [Commented] (KAFKA-12815) KTable.transformValue might have incorrect record metadata

[ https://issues.apache.org/jira/browse/KAFKA-12815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348072#comment-17348072 ] Matthias J. Sax commented on KAFKA-12815: - Well, user can still force to materialize the result

[jira] [Commented] (KAFKA-12815) KTable.transformValue might have incorrect record metadata

[ https://issues.apache.org/jira/browse/KAFKA-12815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348048#comment-17348048 ] Matthias J. Sax commented on KAFKA-12815: - [~ableegoldman] This bug does not affect FK-joins. I

[jira] [Resolved] (KAFKA-12815) KTable.transformValue might have incorrect record metadata

[ https://issues.apache.org/jira/browse/KAFKA-12815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-12815. - Resolution: Fixed > KTable.transformValue might have incorrect record metadata >

[jira] [Created] (KAFKA-12815) KTable.transformValue might have incorrect record metadata

Matthias J. Sax created KAFKA-12815: --- Summary: KTable.transformValue might have incorrect record metadata Key: KAFKA-12815 URL: https://issues.apache.org/jira/browse/KAFKA-12815 Project: Kafka

[jira] [Assigned] (KAFKA-12815) KTable.transformValue might have incorrect record metadata

[ https://issues.apache.org/jira/browse/KAFKA-12815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-12815: --- Assignee: Matthias J. Sax > KTable.transformValue might have incorrect record

[jira] [Updated] (KAFKA-12796) Removal of deprecated classes under `streams-scala`

[ https://issues.apache.org/jira/browse/KAFKA-12796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12796: Parent: KAFKA-12419 Issue Type: Sub-task (was: Task) > Removal of deprecated

[jira] [Updated] (KAFKA-12813) Remove Deprecated schedule method in ProcessorContext

[ https://issues.apache.org/jira/browse/KAFKA-12813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12813: Parent: KAFKA-12419 Issue Type: Sub-task (was: Task) > Remove Deprecated

[jira] [Comment Edited] (KAFKA-12419) Remove Deprecated APIs of Kafka Streams in 3.0

[ https://issues.apache.org/jira/browse/KAFKA-12419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17347816#comment-17347816 ] Matthias J. Sax edited comment on KAFKA-12419 at 5/19/21, 6:31 PM: --- As

[jira] [Updated] (KAFKA-12809) Remove Deprecated methods under Stores

[ https://issues.apache.org/jira/browse/KAFKA-12809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12809: Parent: KAFKA-12419 Issue Type: Sub-task (was: Task) > Remove Deprecated methods

[jira] [Updated] (KAFKA-12808) Remove Deprecated methods under StreamsMetrics

[ https://issues.apache.org/jira/browse/KAFKA-12808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12808: Parent: KAFKA-12419 Issue Type: Sub-task (was: Task) > Remove Deprecated methods

[jira] [Comment Edited] (KAFKA-12419) Remove Deprecated APIs of Kafka Streams in 3.0

[ https://issues.apache.org/jira/browse/KAFKA-12419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17347816#comment-17347816 ] Matthias J. Sax edited comment on KAFKA-12419 at 5/19/21, 6:28 PM: --- As

[jira] [Commented] (KAFKA-12419) Remove Deprecated APIs of Kafka Streams in 3.0

[ https://issues.apache.org/jira/browse/KAFKA-12419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17347816#comment-17347816 ] Matthias J. Sax commented on KAFKA-12419: - As explained on the KIP, it was effectively renamed

[jira] [Updated] (KAFKA-12796) Removal of deprecated classes under `streams-scala`

[ https://issues.apache.org/jira/browse/KAFKA-12796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12796: Labels: scala (was: ) > Removal of deprecated classes under `streams-scala` >

[jira] [Updated] (KAFKA-12761) Consumer offsets are deleted 7 days after last offset commit instead of EMPTY status

[ https://issues.apache.org/jira/browse/KAFKA-12761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12761: Component/s: (was: streams) > Consumer offsets are deleted 7 days after last offset

[jira] [Updated] (KAFKA-12780) java.lang.IllegalStateException: Tried to lookup lag for unknown task 2_0

[ https://issues.apache.org/jira/browse/KAFKA-12780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12780: Affects Version/s: 2.8.0 > java.lang.IllegalStateException: Tried to lookup lag for

[jira] [Updated] (KAFKA-12780) java.lang.IllegalStateException: Tried to lookup lag for unknown task 2_0

[ https://issues.apache.org/jira/browse/KAFKA-12780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12780: Component/s: streams > java.lang.IllegalStateException: Tried to lookup lag for unknown

<    6   7   8   9   10   11   12   13   14   15   >