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

2021-05-13 Thread Matthias J. Sax (Jira)
[ 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

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

2021-05-10 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-12718: --- Assignee: Juan C. Gonzalez-Zurita > SessionWindows are closed too early >

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

2021-05-10 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17342293#comment-17342293 ] Matthias J. Sax commented on KAFKA-12718: - [~gonzur] it seems [~byusti] lost interest to work on

[jira] [Resolved] (KAFKA-12760) Delete My Account

2021-05-10 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-12760. - Resolution: Invalid [~byusti] – we cannot delete your account either. You could try to

[jira] [Resolved] (KAFKA-10847) Avoid spurious left/outer join results in stream-stream join

2021-05-06 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10847. - Fix Version/s: 3.0.0 Resolution: Fixed > Avoid spurious left/outer join results

[jira] [Resolved] (KAFKA-8531) Change default replication factor config

2021-05-05 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8531. Resolution: Fixed > Change default replication factor config >

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

2021-04-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337615#comment-17337615 ] Matthias J. Sax edited comment on KAFKA-12718 at 4/30/21, 8:47 PM: --- I

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

2021-04-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-12718: --- Assignee: Bernardo Yusti > SessionWindows are closed too early >

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

2021-04-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337615#comment-17337615 ] Matthias J. Sax commented on KAFKA-12718: - I just realized that the issue is actually not within

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

2021-04-29 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337019#comment-17337019 ] Matthias J. Sax commented on KAFKA-12718: - Well, `gracePeriod` is a generic concept that applies

[jira] [Updated] (KAFKA-12724) Add 2.8.0 to system tests and streams upgrade tests

2021-04-28 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12724: Component/s: system tests streams > Add 2.8.0 to system tests and

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

2021-04-28 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334964#comment-17334964 ] Matthias J. Sax commented on KAFKA-12718: - I was just looking into `suppress()` implementation,

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

2021-04-26 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12718: Labels: beginner easy-fix newbie (was: ) > SessionWindows are closed too early >

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

2021-04-26 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12718: Fix Version/s: 3.0.0 > SessionWindows are closed too early >

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

2021-04-26 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-12718: --- Summary: SessionWindows are closed too early Key: KAFKA-12718 URL: https://issues.apache.org/jira/browse/KAFKA-12718 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-12453) Guidance on whether a topology is eligible for optimisation

2021-04-25 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331635#comment-17331635 ] Matthias J. Sax commented on KAFKA-12453: - Thanks for asking. In general 3rd parties hold the

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

2021-04-24 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331319#comment-17331319 ] Matthias J. Sax commented on KAFKA-10493: - {quote}Without KIP-280, it would always be an issue

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

2021-04-23 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331042#comment-17331042 ] Matthias J. Sax commented on KAFKA-10493: - Not sure if I understand the idea about "restore by

[jira] [Updated] (KAFKA-12711) Add a back off option to Replace thread

2021-04-23 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12711: Labels: needs-kip (was: ) > Add a back off option to Replace thread >

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

2021-04-23 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17330116#comment-17330116 ] Matthias J. Sax commented on KAFKA-10493: - {quote}What is worse not dropping out-of-order

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

2021-04-22 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17329373#comment-17329373 ] Matthias J. Sax commented on KAFKA-10493: - {quote}verify the order during restoration {quote} I

[jira] [Updated] (KAFKA-12705) Task idling is not sufficiently tested

2021-04-21 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12705: Component/s: unit tests > Task idling is not sufficiently tested >

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

2021-04-21 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17326860#comment-17326860 ] Matthias J. Sax commented on KAFKA-10493: - Thinking about this ticket once more, I actually have

[jira] [Commented] (KAFKA-12696) Add standard getters to LagInfo class to allow automatic serialization

2021-04-21 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17326845#comment-17326845 ] Matthias J. Sax commented on KAFKA-12696: - {quote}Ok. Just to confirm, the confluence where KIPs

[jira] [Updated] (KAFKA-12696) Add standard getters to LagInfo class to allow automatic serialization

2021-04-20 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12696: Labels: needs-kip (was: ) > Add standard getters to LagInfo class to allow automatic

[jira] [Commented] (KAFKA-12696) Add standard getters to LagInfo class to allow automatic serialization

2021-04-20 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17326192#comment-17326192 ] Matthias J. Sax commented on KAFKA-12696: - [~mihasya] – two comments: # This ticket propose a

[jira] [Commented] (KAFKA-12695) KStream.toTable must be extended to allow for a specific Serde

2021-04-20 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17326191#comment-17326191 ] Matthias J. Sax commented on KAFKA-12695: - Thanks for reporting this. Seems that there is a gap

[jira] [Updated] (KAFKA-12695) KStream.toTable must be extended to allow for a specific Serde

2021-04-20 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12695: Labels: scala (was: ) > KStream.toTable must be extended to allow for a specific Serde

[jira] [Commented] (KAFKA-12666) Fix flaky kafka.server.RaftClusterTest.testCreateClusterAndCreateListDeleteTopic

2021-04-20 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17326190#comment-17326190 ] Matthias J. Sax commented on KAFKA-12666: - Different method:

[jira] [Commented] (KAFKA-12511) Flaky test DynamicConnectionQuotaTest.testDynamicListenerConnectionCreationRateQuota()

2021-04-20 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17326188#comment-17326188 ] Matthias J. Sax commented on KAFKA-12511: - Failed again:

[jira] [Commented] (KAFKA-12396) Dedicated exception for kstreams when null key received

2021-04-16 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17323977#comment-17323977 ] Matthias J. Sax commented on KAFKA-12396: - Thanks for the PR [~Nathan22177] – I added you to the

[jira] [Commented] (KAFKA-12566) Flaky Test MirrorConnectorsIntegrationSSLTest#testReplication

2021-04-16 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17323975#comment-17323975 ] Matthias J. Sax commented on KAFKA-12566: - Another one for

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

2021-04-16 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-12678: --- Summary: Flaky Test CustomQuotaCallbackTest.testCustomQuotaCallback Key: KAFKA-12678 URL: https://issues.apache.org/jira/browse/KAFKA-12678 Project: Kafka

[jira] [Commented] (KAFKA-12566) Flaky Test MirrorConnectorsIntegrationSSLTest#testReplication

2021-04-16 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17323958#comment-17323958 ] Matthias J. Sax commented on KAFKA-12566: -

[jira] [Assigned] (KAFKA-12396) Dedicated exception for kstreams when null key received

2021-04-16 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-12396: --- Assignee: Valery Kokorev > Dedicated exception for kstreams when null key received

[jira] [Updated] (KAFKA-8531) Change default replication factor config

2021-04-14 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8531: --- Description: With KAFKA-8305, AdminClient allows to create topics based on the broker

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

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

[jira] [Updated] (KAFKA-8613) Set default grace period to 0

2021-04-14 Thread Matthias J. Sax (Jira)
[ 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) Set default grace period to 0

2021-04-14 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8613: --- Labels: kip (was: ) > Set default grace period to 0 > - > >

[jira] [Updated] (KAFKA-10383) KTable Join on Foreign key is opinionated

2021-04-14 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10383: Description: *Status Quo:* The current implementation of [KIP-213 

[jira] [Updated] (KAFKA-10383) KTable Join on Foreign key is opinionated

2021-04-14 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10383: Labels: kip (was: needs-kip) > KTable Join on Foreign key is opinionated >

[jira] [Commented] (KAFKA-12608) Simple identity pipeline sometimes loses data

2021-04-13 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17320357#comment-17320357 ] Matthias J. Sax commented on KAFKA-12608: - What was said above, and to be more concrete: you

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

2021-04-13 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10493: Priority: Blocker (was: Major) > KTable out-of-order updates are not being ignored >

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

2021-04-13 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10493: Priority: Major (was: Critical) > KTable out-of-order updates are not being ignored >

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

2021-04-12 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10493: Summary: KTable out-of-order updates are not being ignored (was: Ktable out-of-order

[jira] [Assigned] (KAFKA-9195) Use Randomized State Directory Names in Streams System Tests

2021-04-12 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-9195: -- Assignee: (was: Matthias J. Sax) > Use Randomized State Directory Names in

[jira] [Commented] (KAFKA-12608) Simple identity pipeline sometimes loses data

2021-04-12 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319890#comment-17319890 ] Matthias J. Sax commented on KAFKA-12608: - Could you provide the used input data to allow us to

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

2021-04-12 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-12657: --- Summary: Flaky Tests BlockingConnectorTest.testWorkerRestartWithBlockInConnectorStop Key: KAFKA-12657 URL: https://issues.apache.org/jira/browse/KAFKA-12657

[jira] [Comment Edited] (KAFKA-12566) Flaky Test MirrorConnectorsIntegrationSSLTest#testReplication

2021-04-12 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319715#comment-17319715 ] Matthias J. Sax edited comment on KAFKA-12566 at 4/12/21, 8:59 PM: ---

[jira] [Commented] (KAFKA-12566) Flaky Test MirrorConnectorsIntegrationSSLTest#testReplication

2021-04-12 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319715#comment-17319715 ] Matthias J. Sax commented on KAFKA-12566: -

[jira] [Commented] (KAFKA-12650) NPE in InternalTopicManager#cleanUpCreatedTopics

2021-04-12 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319549#comment-17319549 ] Matthias J. Sax commented on KAFKA-12650: -

[jira] [Assigned] (KAFKA-12650) NPE in InternalTopicManager#cleanUpCreatedTopics

2021-04-12 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-12650: --- Assignee: Matthias J. Sax > NPE in InternalTopicManager#cleanUpCreatedTopics >

[jira] [Commented] (KAFKA-9013) Flaky Test MirrorConnectorsIntegrationTest#testReplication

2021-04-12 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319546#comment-17319546 ] Matthias J. Sax commented on KAFKA-9013:

[jira] [Commented] (KAFKA-12629) Flaky Test RaftClusterTest

2021-04-12 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319548#comment-17319548 ] Matthias J. Sax commented on KAFKA-12629: - Another timeout:

[jira] [Commented] (KAFKA-12566) Flaky Test MirrorConnectorsIntegrationSSLTest#testReplication

2021-04-09 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17318218#comment-17318218 ] Matthias J. Sax commented on KAFKA-12566: -

[jira] [Updated] (KAFKA-12449) Remove deprecated WindowStore#put

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

[jira] [Resolved] (KAFKA-12449) Remove deprecated WindowStore#put

2021-04-09 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-12449. - Fix Version/s: 3.0.0 Resolution: Fixed > Remove deprecated WindowStore#put >

[jira] [Comment Edited] (KAFKA-12453) Guidance on whether a topology is eligible for optimisation

2021-04-09 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17318193#comment-17318193 ] Matthias J. Sax edited comment on KAFKA-12453 at 4/9/21, 6:24 PM: --

[jira] [Commented] (KAFKA-12453) Guidance on whether a topology is eligible for optimisation

2021-04-09 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17318193#comment-17318193 ] Matthias J. Sax commented on KAFKA-12453: - {quote} # Why does the input topic need to be

[jira] [Commented] (KAFKA-12634) Should checkpoint after restore finished

2021-04-08 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17317529#comment-17317529 ] Matthias J. Sax commented on KAFKA-12634: - {quote}By the way, shouldn't we also checkpoint 

[jira] [Commented] (KAFKA-12634) Should checkpoint after restore finished

2021-04-08 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17317504#comment-17317504 ] Matthias J. Sax commented on KAFKA-12634: - I actually did look into `trunk` and it seems not to

[jira] [Commented] (KAFKA-9831) Failing test: EosIntegrationTest.shouldNotViolateEosIfOneTaskFailsWithState[exactly_once_beta]

2021-04-08 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17317477#comment-17317477 ] Matthias J. Sax commented on KAFKA-9831: That is weird... the stacktrace does not match the code:

[jira] [Comment Edited] (KAFKA-9831) Failing test: EosIntegrationTest.shouldNotViolateEosIfOneTaskFailsWithState[exactly_once_beta]

2021-04-08 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17317364#comment-17317364 ] Matthias J. Sax edited comment on KAFKA-9831 at 4/8/21, 8:41 PM: - I saw

[jira] [Comment Edited] (KAFKA-9831) Failing test: EosIntegrationTest.shouldNotViolateEosIfOneTaskFailsWithState[exactly_once_beta]

2021-04-08 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17317364#comment-17317364 ] Matthias J. Sax edited comment on KAFKA-9831 at 4/8/21, 8:40 PM: - I saw

[jira] [Commented] (KAFKA-12634) Should checkpoint after restore finished

2021-04-08 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17317469#comment-17317469 ] Matthias J. Sax commented on KAFKA-12634: - Confirmed for 2.5 (so should also affect all newer

[jira] [Created] (KAFKA-12634) Should checkpoint after restore finished

2021-04-08 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-12634: --- Summary: Should checkpoint after restore finished Key: KAFKA-12634 URL: https://issues.apache.org/jira/browse/KAFKA-12634 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-12453) Guidance on whether a topology is eligible for optimisation

2021-04-08 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17317327#comment-17317327 ] Matthias J. Sax commented on KAFKA-12453: - {quote}and why `builder.stream().toTable()` is

[jira] [Commented] (KAFKA-12629) Flaky Test RaftClusterTest

2021-04-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316552#comment-17316552 ] Matthias J. Sax commented on KAFKA-12629: - Also observed a timeout issue {quote} 

[jira] [Commented] (KAFKA-12319) Flaky test ConnectionQuotasTest.testListenerConnectionRateLimitWhenActualRateAboveLimit()

2021-04-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316559#comment-17316559 ] Matthias J. Sax commented on KAFKA-12319: - Failed again. > Flaky test >

[jira] [Commented] (KAFKA-12566) Flaky Test MirrorConnectorsIntegrationSSLTest#testReplication

2021-04-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316558#comment-17316558 ] Matthias J. Sax commented on KAFKA-12566: - Another timeout: {quote} 

[jira] [Comment Edited] (KAFKA-12566) Flaky Test MirrorConnectorsIntegrationSSLTest#testReplication

2021-04-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316543#comment-17316543 ] Matthias J. Sax edited comment on KAFKA-12566 at 4/7/21, 6:43 PM: --

[jira] [Commented] (KAFKA-12383) Get RaftClusterTest.java and other KIP-500 junit tests working

2021-04-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316553#comment-17316553 ] Matthias J. Sax commented on KAFKA-12383: - Created

[jira] [Created] (KAFKA-12629) Flaky Test RaftClusterTest

2021-04-07 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-12629: --- Summary: Flaky Test RaftClusterTest Key: KAFKA-12629 URL: https://issues.apache.org/jira/browse/KAFKA-12629 Project: Kafka Issue Type: Test

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

2021-04-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316546#comment-17316546 ] Matthias J. Sax commented on KAFKA-9009: One more: {quote} {{java.lang.AssertionError: assertion

[jira] [Commented] (KAFKA-12566) Flaky Test MirrorConnectorsIntegrationSSLTest#testReplication

2021-04-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316543#comment-17316543 ] Matthias J. Sax commented on KAFKA-12566: - Different method:

[jira] [Resolved] (KAFKA-5146) Kafka Streams: remove compile dependency on connect-json

2021-04-06 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5146. Fix Version/s: 3.0.0 Resolution: Fixed > Kafka Streams: remove compile dependency

[jira] [Commented] (KAFKA-12383) Get RaftClusterTest.java and other KIP-500 junit tests working

2021-04-06 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17315832#comment-17315832 ] Matthias J. Sax commented on KAFKA-12383: - Observed a timeout issue {quote} 

[jira] [Commented] (KAFKA-9013) Flaky Test MirrorConnectorsIntegrationTest#testReplication

2021-04-06 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17315831#comment-17315831 ] Matthias J. Sax commented on KAFKA-9013: Timeout issue (observed twice): {quote} 

[jira] [Commented] (KAFKA-12344) Support SlidingWindows in the Scala API

2021-04-06 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17315675#comment-17315675 ] Matthias J. Sax commented on KAFKA-12344: - Sound about right – in the Java code,

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

2021-04-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17314586#comment-17314586 ] Matthias J. Sax commented on KAFKA-9559: {quote}refactoring the code where we get the default

[jira] [Comment Edited] (KAFKA-12594) Self-join produces no ouput, and prevents other streams from producing output

2021-04-01 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313493#comment-17313493 ] Matthias J. Sax edited comment on KAFKA-12594 at 4/2/21, 12:53 AM: ---

[jira] [Commented] (KAFKA-12594) Self-join produces no ouput, and prevents other streams from producing output

2021-04-01 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313493#comment-17313493 ] Matthias J. Sax commented on KAFKA-12594: - Can you maybe add a `stream().map((k,v) ->

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

2021-04-01 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313490#comment-17313490 ] Matthias J. Sax commented on KAFKA-9559: Thanks for looking into the code – I think a

[jira] [Commented] (KAFKA-12574) Deprecate eos-alpha

2021-04-01 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313484#comment-17313484 ] Matthias J. Sax commented on KAFKA-12574: - I agree that "hot swapping" might be too aggressive.

[jira] [Commented] (KAFKA-12594) Self-join produces no ouput, and prevents other streams from producing output

2021-04-01 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313482#comment-17313482 ] Matthias J. Sax commented on KAFKA-12594: - The order of processing depends on the record

[jira] [Updated] (KAFKA-12593) Some Scala, Python, and Gradle files contain the wrong license header

2021-04-01 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12593: Labels: scala (was: ) > Some Scala, Python, and Gradle files contain the wrong license

[jira] [Updated] (KAFKA-12593) Some Scala, Python, and Gradle files contain the wrong license header

2021-04-01 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12593: Labels: (was: scala) > Some Scala, Python, and Gradle files contain the wrong license

[jira] [Updated] (KAFKA-12593) Some Scala, Python, and Gradle files contain the wrong license header

2021-04-01 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12593: Component/s: streams > Some Scala, Python, and Gradle files contain the wrong license

[jira] [Updated] (KAFKA-12593) Some Scala, Python, and Gradle files contain the wrong license header

2021-04-01 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12593: Component/s: (was: streams) > Some Scala, Python, and Gradle files contain the wrong

[jira] [Commented] (KAFKA-12453) Guidance on whether a topology is eligible for optimisation

2021-03-31 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17312523#comment-17312523 ] Matthias J. Sax commented on KAFKA-12453: - {quote}Are we saying that its safe to enable topology

[jira] [Commented] (KAFKA-12453) Guidance on whether a topology is eligible for optimisation

2021-03-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17311952#comment-17311952 ] Matthias J. Sax commented on KAFKA-12453: - Sweet! Thanks for digging it out [~ableegoldman]

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

2021-03-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17311946#comment-17311946 ] Matthias J. Sax commented on KAFKA-12419: -

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

2021-03-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17311945#comment-17311945 ] Matthias J. Sax commented on KAFKA-9559: {quote}Adding a check for NPE everywhere serdes are used

[jira] [Commented] (KAFKA-12564) KTable#filter-method called twice after aggregation

2021-03-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17311943#comment-17311943 ] Matthias J. Sax commented on KAFKA-12564: - {quote}In the (stateless) filter-method I cannot

[jira] [Commented] (KAFKA-12574) Deprecate eos-alpha

2021-03-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17311939#comment-17311939 ] Matthias J. Sax commented on KAFKA-12574: - We discussed "auto-fall back" but there are issues

[jira] [Updated] (KAFKA-12568) Remove deprecated "KStream#groupBy/join", "Joined#named" overloads

2021-03-27 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12568: Component/s: streams > Remove deprecated "KStream#groupBy/join", "Joined#named" overloads

[jira] [Updated] (KAFKA-12462) Threads in PENDING_SHUTDOWN entering a rebalance can cause an illegal state exception

2021-03-27 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12462: Affects Version/s: 2.7.0 > Threads in PENDING_SHUTDOWN entering a rebalance can cause an

[jira] [Commented] (KAFKA-12396) Dedicated exception for kstreams when null key received

2021-03-27 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17310097#comment-17310097 ] Matthias J. Sax commented on KAFKA-12396: - [~dvsingh9] Feel to assign the ticket to yourself and

[jira] [Commented] (KAFKA-12453) Guidance on whether a topology is eligible for optimisation

2021-03-27 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17310096#comment-17310096 ] Matthias J. Sax commented on KAFKA-12453: - I would need to double check the code, but I am not

[jira] [Commented] (KAFKA-12499) Adjust transaction timeout according to commit interval on Streams EOS

2021-03-27 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17310095#comment-17310095 ] Matthias J. Sax commented on KAFKA-12499: - Not sure if we can pick a reasonable default (even if

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