Re: [DISCUSS] Apache Kafka 3.5.0 release

2023-05-19 Thread Matthias J. Sax
//github.com/apache/kafka/pull/13434 On Fri, Apr 14, 2023 at 10:13 AM Matthias J. Sax < mj...@apache.org> wrote: Thanks a lot! On 4/14/23 5:32 AM, Mickael Maison wrote: Hi Matthias, I merged the PR before cutting the 3.5 branch. Thanks, Mickael On Fri, Apr 14, 2023

Re: Query regarding implementation of KStreams with Hbase

2023-05-12 Thread Matthias J. Sax
Kafka Streams is designed to read and write from a broker cluster. It's not designed to write data to different system like HBase. If you want to get data from Kafka to HBase, you should use Kafka Connect. Of course, it's possible (but not recommended) to implement your own `Processor` and do

Re: Some questions on Kafka on order of messages with mutiple partitions

2023-05-12 Thread Matthias J. Sax
Does having 9 partitions with 9 replication factors make sense here? A replication factor of 9 sounds very high. For production, replication factor of 3 is recommended. How many partitions you want/need is a different question, and cannot be answered in a general way. "Yes" to all other

[jira] [Commented] (KAFKA-13349) Allow Iterator.remove on KeyValueIterator

2023-05-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722005#comment-17722005 ] Matthias J. Sax commented on KAFKA-13349: - Yes, we want to add `remove()` to interface [https

[jira] [Commented] (KAFKA-14911) Add system tests for rolling upgrade path of KIP-904

2023-05-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722004#comment-17722004 ] Matthias J. Sax commented on KAFKA-14911: - No worries. And thanks for helping on reviewing

[jira] [Commented] (KAFKA-14981) Set `group.instance.id` in streams consumer so that rebalance will not happen if a instance is restarted

2023-05-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722003#comment-17722003 ] Matthias J. Sax commented on KAFKA-14981: - I was not aware that there was (or maybe still

Re: apply for permission to contribute to Apache Kafka

2023-05-10 Thread Matthias J. Sax
I just checked permissions and you should be all set. Did you try to log out and log in again? -Matthias On 5/9/23 10:04 PM, Doe John wrote: Thanks, After obtaining permission, I want to assign this JIRA ticket

Re: Question ❓

2023-05-10 Thread Matthias J. Sax
Partitions are not for different users. If you want to isolate users, you would do it at the topic level. You could use ACLs to grant access to different topics: https://kafka.apache.org/documentation/#security_authz -Matthias On 5/9/23 11:11 AM, влад тасканов wrote: Hi. I recently

[jira] [Commented] (KAFKA-14981) Set `group.instance.id` in streams consumer so that rebalance will not happen if a instance is restarted

2023-05-09 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17721114#comment-17721114 ] Matthias J. Sax commented on KAFKA-14981: - Very interesting idea – given that we persist

Re: [DISCUSS] KIP-923: Add A Grace Period to Stream Table Join

2023-05-08 Thread Matthias J. Sax
Thanks for the KIP! Also some question/comments from my side: 10) Notation: you use the term "late data" but I think you mean out-of-order. We reserve the term "late" to records that arrive after grace period passed, and thus, "late == out-of-order data that is dropped". 20) "There is only

[jira] [Commented] (KAFKA-14957) Default value for state.dir is confusing

2023-05-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719079#comment-17719079 ] Matthias J. Sax commented on KAFKA-14957: - Ah. Thanks. That's gonna be nasty to fix

[jira] [Updated] (KAFKA-14957) Default value for state.dir is confusing

2023-05-02 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14957: Component/s: docs > Default value for state.dir is confus

[jira] [Updated] (KAFKA-14957) Default value for state.dir is confusing

2023-05-02 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14957: Labels: beginner newbie (was: ) > Default value for state.dir is confus

[jira] [Updated] (KAFKA-14957) Default value for state.dir is confusing

2023-05-02 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14957: Priority: Minor (was: Major) > Default value for state.dir is confus

[jira] [Commented] (KAFKA-14957) Default value for state.dir is confusing

2023-05-02 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17718759#comment-17718759 ] Matthias J. Sax commented on KAFKA-14957: - [~mimaison] – Thanks. What part of the docs are you

Re: [DISCUSS] Adding non-committers as Github collaborators

2023-04-28 Thread Matthias J. Sax
In general I am +1 The only question I have is about You may only have 20 active collaborators at any given time per repository. Not sure if this is a concern or not? I would assume not, but wanted to bring it to everyone's attention. There is actually also a way to allow people to

[jira] [Updated] (KAFKA-14949) Add Streams upgrade tests from AK 3.4

2023-04-28 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14949: Component/s: system tests > Add Streams upgrade tests from AK

Re: [DISCUSS] Re-visit end of life policy

2023-04-25 Thread Matthias J. Sax
the users about the community's 12 month EOL policy. I will get back on this thread once I have more data to support the proposal. -- Divij Vaidya On Thu, Apr 20, 2023 at 3:52 AM Matthias J. Sax wrote: While I understand the desire, I tend to agree with Ismael. In general, it's a significant

Re: [DISCUSS] Re-visit end of life policy

2023-04-25 Thread Matthias J. Sax
the users about the community's 12 month EOL policy. I will get back on this thread once I have more data to support the proposal. -- Divij Vaidya On Thu, Apr 20, 2023 at 3:52 AM Matthias J. Sax wrote: While I understand the desire, I tend to agree with Ismael. In general, it's a significant

[jira] [Assigned] (KAFKA-14911) Add system tests for rolling upgrade path of KIP-904

2023-04-25 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-14911: --- Assignee: Victoria Xia > Add system tests for rolling upgrade path of KIP-

[jira] [Assigned] (KAFKA-14839) Exclude protected variable from JavaDocs

2023-04-25 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-14839: --- Assignee: Atul Sharma > Exclude protected variable from JavaD

[jira] [Commented] (KAFKA-14839) Exclude protected variable from JavaDocs

2023-04-25 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17716493#comment-17716493 ] Matthias J. Sax commented on KAFKA-14839: - Sure! > Exclude protected variable from JavaD

[jira] [Updated] (KAFKA-14936) Add Grace Period To Stream Table Join

2023-04-25 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14936: Labels: kip streams (was: streams) > Add Grace Period To Stream Table J

[jira] [Updated] (KAFKA-14172) bug: State stores lose state when tasks are reassigned under EOS wit…

2023-04-25 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14172: Fix Version/s: 3.4.1 > bug: State stores lose state when tasks are reassigned under

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

2023-04-25 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 updated KAFKA-14922: Labels: beginner needs-kip newbie (was: ) > kafka-streams-application-reset dele

[jira] [Updated] (KAFKA-14862) Outer stream-stream join does not output all results with multiple input partitions

2023-04-24 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14862: Affects Version/s: 3.1.0 > Outer stream-stream join does not output all resu

Re: [ANNOUNCE] New PMC chair: Mickael Maison

2023-04-21 Thread Matthias J. Sax
Congrats Mickael! And thanks a lot for taking on this additional task! Glad to have you! -Matthias On 4/21/23 9:40 AM, Viktor Somogyi-Vass wrote: Jun, thank you for all your hard work! Also, congrats Mickael, it is very well deserved :) Best, Viktor On Fri, Apr 21, 2023, 18:15 Adam

Re: [ANNOUNCE] New PMC chair: Mickael Maison

2023-04-21 Thread Matthias J. Sax
Congrats Mickael! And thanks a lot for taking on this additional task! Glad to have you! -Matthias On 4/21/23 9:40 AM, Viktor Somogyi-Vass wrote: Jun, thank you for all your hard work! Also, congrats Mickael, it is very well deserved :) Best, Viktor On Fri, Apr 21, 2023, 18:15 Adam

[jira] [Commented] (KAFKA-14722) Make BooleanSerde public

2023-04-21 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715157#comment-17715157 ] Matthias J. Sax commented on KAFKA-14722: - I did a PR: [https://github.com/apache/kafka/pull

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

2023-04-20 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17714770#comment-17714770 ] Matthias J. Sax commented on KAFKA-14922: - {quote}We could add a warning with the list

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

2023-04-19 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 updated KAFKA-14922: Component/s: streams tools > kafka-streams-application-reset dele

Re: [DISCUSS] Re-visit end of life policy

2023-04-19 Thread Matthias J. Sax
While I understand the desire, I tend to agree with Ismael. In general, it's a significant amount of work not just to do the actual releases, but also the cherry-pick bug-fixed to older branches. Code diverges very quickly, and a clean cherry-pick is usually only possible for one or two

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

2023-04-19 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17714354#comment-17714354 ] Matthias J. Sax commented on KAFKA-14922: - Thanks for creating this ticket. It's a know issue

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

2023-04-19 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4327. Fix Version/s: (was: 4.0.0) Resolution: Fixed This was resolved via https

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

2023-04-19 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4327. Fix Version/s: (was: 4.0.0) Resolution: Fixed This was resolved via https

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

2023-04-19 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-4327: -- Assignee: (was: Jorge Esteban Quilcate Otoya) > Move Reset Tool from c

[jira] [Commented] (KAFKA-14586) Move StreamsResetter to tools

2023-04-18 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17713836#comment-17713836 ] Matthias J. Sax commented on KAFKA-14586: - Thanks for providing context, and no worries about

[jira] [Assigned] (KAFKA-14862) Outer stream-stream join does not output all results with multiple input partitions

2023-04-17 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-14862: --- Assignee: Matthias J. Sax > Outer stream-stream join does not output all resu

[jira] [Commented] (KAFKA-14586) Move StreamsResetter to tools

2023-04-17 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17713233#comment-17713233 ] Matthias J. Sax commented on KAFKA-14586: - [~mimaison] [~sagarrao] – I am just realizing that we

[jira] [Commented] (KAFKA-14911) Add system tests for rolling upgrade path of KIP-904

2023-04-17 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17713230#comment-17713230 ] Matthias J. Sax commented on KAFKA-14911: - [~fqpublic] – are you planning to pickup this ticket

Re: [DISCUSS] Apache Kafka 3.5.0 release

2023-04-14 Thread Matthias J. Sax
, Satish. On Fri, 14 Apr 2023 at 12:52, Matthias J. Sax wrote: Hey Mickael, we have one open PR for KIP-914 left. Would be great if you could merge it before cutting the 3.5 branch. If you don't want to merge it and prefer that I cherry-pick it to 3.5 branch later, also works for me. I did

Re: [DISCUSS] Apache Kafka 3.5.0 release

2023-04-14 Thread Matthias J. Sax
Hey Mickael, we have one open PR for KIP-914 left. Would be great if you could merge it before cutting the 3.5 branch. If you don't want to merge it and prefer that I cherry-pick it to 3.5 branch later, also works for me. I did close the ticket already as resolved. It's just a minor change

[jira] [Resolved] (KAFKA-7499) Extend ProductionExceptionHandler to cover serialization exceptions

2023-04-14 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7499. Fix Version/s: 3.5.0 Resolution: Fixed > Extend ProductionExceptionHandler to co

[jira] [Resolved] (KAFKA-7499) Extend ProductionExceptionHandler to cover serialization exceptions

2023-04-14 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7499. Fix Version/s: 3.5.0 Resolution: Fixed > Extend ProductionExceptionHandler to co

[jira] [Resolved] (KAFKA-14834) Improved processor semantics for versioned stores

2023-04-14 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-14834. - Fix Version/s: 3.5.0 Resolution: Fixed > Improved processor semant

[jira] [Resolved] (KAFKA-14834) Improved processor semantics for versioned stores

2023-04-14 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-14834. - Fix Version/s: 3.5.0 Resolution: Fixed > Improved processor semant

[jira] [Updated] (KAFKA-14209) Optimize stream stream self join to use single state store

2023-04-12 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14209: Description: KIP-862: [https://cwiki.apache.org/confluence/display/KAFKA/KIP-862%3A+Self

[jira] [Updated] (KAFKA-14209) Optimize stream stream self join to use single state store

2023-04-12 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14209: Labels: kip (was: ) > Optimize stream stream self join to use single state st

Re: Fwd: [VOTE] KIP-914 Join Processor Semantics for Versioned Stores

2023-04-11 Thread Matthias J. Sax
Matthias J. Sax wrote: Thanks. One question: for the repartition topic format change, do we want to re-use flag=2, or should we introduce flag=3, and determine when compiling the DSL into the Topology if we want/need to include the timestamp, and if not, use format version=2 to avoid unnecessary

Re: Fwd: [VOTE] KIP-914 Join Processor Semantics for Versioned Stores

2023-04-10 Thread Matthias J. Sax
ar 22, 2023 at 7:11 AM Bruno Cadonna wrote: +1 (binding) Thanks Victoria! Best, Bruno On 20.03.23 17:13, Matthias J. Sax wrote: +1 (binding) On 3/20/23 9:05 AM, Guozhang Wang wrote: +1, thank you Victoria! On Sat, Mar 18, 2023 at 8:27 AM Victoria Xia wrote: Hi all, I'd like to s

[jira] [Assigned] (KAFKA-14054) Unexpected client shutdown as TimeoutException is thrown as IllegalStateException

2023-04-10 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-14054: --- Assignee: Matthias J. Sax > Unexpected client shutdown as TimeoutExcept

[jira] [Reopened] (KAFKA-14318) KIP-878: Autoscaling for Statically Partitioned Streams

2023-04-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-14318: - > KIP-878: Autoscaling for Statically Partitioned Stre

[jira] [Resolved] (KAFKA-14318) KIP-878: Autoscaling for Statically Partitioned Streams

2023-04-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-14318. - Resolution: Fixed > KIP-878: Autoscaling for Statically Partitioned Stre

[jira] [Resolved] (KAFKA-14318) KIP-878: Autoscaling for Statically Partitioned Streams

2023-04-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-14318. - Resolution: Fixed > KIP-878: Autoscaling for Statically Partitioned Stre

[jira] [Reopened] (KAFKA-14318) KIP-878: Autoscaling for Statically Partitioned Streams

2023-04-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-14318: - > KIP-878: Autoscaling for Statically Partitioned Stre

[jira] [Assigned] (KAFKA-14318) KIP-878: Autoscaling for Statically Partitioned Streams

2023-04-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-14318: --- Assignee: (was: A. Sophie Blee-Goldman) > KIP-878: Autoscaling for Statica

[jira] [Updated] (KAFKA-14318) KIP-878: Autoscaling for Statically Partitioned Streams

2023-04-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14318: Fix Version/s: (was: 3.5.0) > KIP-878: Autoscaling for Statically Partitioned Stre

[jira] [Resolved] (KAFKA-14491) Introduce Versioned Key-Value Stores to Kafka Streams

2023-04-05 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-14491. - Fix Version/s: 3.5.0 Resolution: Fixed > Introduce Versioned Key-Value Sto

[jira] [Resolved] (KAFKA-14491) Introduce Versioned Key-Value Stores to Kafka Streams

2023-04-05 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-14491. - Fix Version/s: 3.5.0 Resolution: Fixed > Introduce Versioned Key-Value Sto

[jira] [Resolved] (KAFKA-14864) Memory leak in KStreamWindowAggregate with ON_WINDOW_CLOSE emit strategy

2023-04-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-14864. - Fix Version/s: 3.4.1 3.3.3 Resolution: Fixed > Memory l

[jira] [Resolved] (KAFKA-14864) Memory leak in KStreamWindowAggregate with ON_WINDOW_CLOSE emit strategy

2023-04-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-14864. - Fix Version/s: 3.4.1 3.3.3 Resolution: Fixed > Memory l

[jira] [Commented] (KAFKA-14722) Make BooleanSerde public

2023-04-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17708211#comment-17708211 ] Matthias J. Sax commented on KAFKA-14722: - The docs PRs was not merged yet – thus the work

[jira] [Updated] (KAFKA-14722) Make BooleanSerde public

2023-04-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14722: Fix Version/s: 3.5.0 > Make BooleanSerde pub

[jira] [Updated] (KAFKA-14864) Memory leak in KStreamWindowAggregate with ON_WINDOW_CLOSE emit strategy

2023-04-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14864: Affects Version/s: 3.3.2 3.4.0 > Memory l

[jira] [Updated] (KAFKA-14847) Separate the callers of commitAllTasks v.s. commitTasks for EOS(-v2) and ALOS

2023-03-25 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14847: Description: Today, EOS-v2/v1 and ALOS shares the same internal callpath inside

[jira] [Updated] (KAFKA-14847) Separate the callers of commitAllTasks v.s. commitTasks for EOS(-v2) and ALOS

2023-03-25 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14847: Description: Today, EOS-v2/v1 and ALOS shares the same internal callpath inside

[jira] [Updated] (KAFKA-14847) Separate the callers of commitAllTasks v.s. commitTasks for EOS(-v2) and ALOS

2023-03-25 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14847: Description: Today, EOS-v2/v1 and ALOS shares the same internal callpath inside

[jira] [Created] (KAFKA-14839) Exclude protected variable from JavaDocs

2023-03-23 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-14839: --- Summary: Exclude protected variable from JavaDocs Key: KAFKA-14839 URL: https://issues.apache.org/jira/browse/KAFKA-14839 Project: Kafka Issue Type

[jira] [Created] (KAFKA-14839) Exclude protected variable from JavaDocs

2023-03-23 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-14839: --- Summary: Exclude protected variable from JavaDocs Key: KAFKA-14839 URL: https://issues.apache.org/jira/browse/KAFKA-14839 Project: Kafka Issue Type

Re: Request small bug or minor issue

2023-03-21 Thread Matthias J. Sax
Thanks for your interest. Please checkout https://kafka.apache.org/contributing to get started. You can look for tickets labeled "newbie" or "beginner":

Re: can Kafka streams support ordering across 2 different topics when consuming from multiple source topics?

2023-03-21 Thread Matthias J. Sax
In general there is no ordering guarantee between topics. So it might depend a lot ofnthe details of your use case. For example, if you know that it will be always two event, you could buffer the first one in a state-store, and wait for the second one to arrive and decide in which order to

[jira] [Commented] (KAFKA-7224) KIP-328: Add spill-to-disk for Suppression

2023-03-20 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17702980#comment-17702980 ] Matthias J. Sax commented on KAFKA-7224: With [https://cwiki.apache.org/confluence/display/KAFKA

Re: [VOTE] KIP-914 Join Processor Semantics for Versioned Stores

2023-03-20 Thread Matthias J. Sax
+1 (binding) On 3/20/23 9:05 AM, Guozhang Wang wrote: +1, thank you Victoria! On Sat, Mar 18, 2023 at 8:27 AM Victoria Xia wrote: Hi all, I'd like to start a vote on KIP-914 for updating the Kafka Streams join processors to use proper timestamp-based semantics in applications with

Re: [DISCUSS] KIP-914 Join Processor Semantics for Versioned Stores

2023-03-15 Thread Matthias J. Sax
Thanks for the KIP! Great to see a first step towards using the new versioned stores! I think the described tradeoffs make sense and I like make a pragmatic step into the right direction, and avoid boiling the ocean. Thus, I agree to the proposed solution. One minor thing, that I believe

[jira] [Updated] (KAFKA-14385) Flaky Test QueryableStateIntegrationTest.shouldNotMakeStoreAvailableUntilAllStoresAvailable

2023-03-14 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14385: Priority: Critical (was: Major) > Flaky T

[jira] [Updated] (KAFKA-14384) Flaky Test SelfJoinUpgradeIntegrationTest.shouldUpgradeWithTopologyOptimizationOff

2023-03-14 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14384: Priority: Critical (was: Major) > Flaky T

[jira] [Updated] (KAFKA-10184) Flaky HighAvailabilityTaskAssignorIntegrationTest.shouldScaleOutWithWarmupTasksAndPersistentStores

2023-03-14 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10184: Priority: Critical (was: Minor) > Fl

[jira] [Updated] (KAFKA-8691) Flakey test ProcessorContextTest#shouldNotAllowToScheduleZeroMillisecondPunctuation

2023-03-14 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8691: --- Priority: Critical (was: Major) > Flakey test > ProcessorConte

[jira] [Updated] (KAFKA-14533) Flaky Test SmokeTestDriverIntegrationTest.shouldWorkWithRebalance

2023-03-14 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14533: Priority: Critical (was: Major) > Flaky T

[jira] [Assigned] (KAFKA-10688) Handle accidental truncation of repartition topics as exceptional failure

2023-03-13 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-10688: --- Assignee: (was: Guozhang Wang) > Handle accidental truncation of repartit

Re: [ANNOUNCE] New Kafka PMC Member: Chris Egerton

2023-03-09 Thread Matthias J. Sax
Congrats! On 3/9/23 2:59 PM, José Armando García Sancio wrote: Congrats Chris. On Thu, Mar 9, 2023 at 2:01 PM Kowshik Prakasam wrote: Congrats Chris! On Thu, Mar 9, 2023 at 1:33 PM Divij Vaidya wrote: Congratulations Chris! I am in awe with the amount of effort you put in code reviews

Re: [ANNOUNCE] New Kafka PMC Member: Chris Egerton

2023-03-09 Thread Matthias J. Sax
Congrats! On 3/9/23 2:59 PM, José Armando García Sancio wrote: Congrats Chris. On Thu, Mar 9, 2023 at 2:01 PM Kowshik Prakasam wrote: Congrats Chris! On Thu, Mar 9, 2023 at 1:33 PM Divij Vaidya wrote: Congratulations Chris! I am in awe with the amount of effort you put in code reviews

Re: [ANNOUNCE] New Kafka PMC Member: David Arthur

2023-03-09 Thread Matthias J. Sax
Congrats! On 3/9/23 2:59 PM, José Armando García Sancio wrote: Congrats David! On Thu, Mar 9, 2023 at 2:00 PM Kowshik Prakasam wrote: Congrats David! On Thu, Mar 9, 2023 at 12:09 PM Lucas Brutschy wrote: Congratulations! On Thu, Mar 9, 2023 at 8:37 PM Manikumar wrote: Congrats

Re: [ANNOUNCE] New Kafka PMC Member: David Arthur

2023-03-09 Thread Matthias J. Sax
Congrats! On 3/9/23 2:59 PM, José Armando García Sancio wrote: Congrats David! On Thu, Mar 9, 2023 at 2:00 PM Kowshik Prakasam wrote: Congrats David! On Thu, Mar 9, 2023 at 12:09 PM Lucas Brutschy wrote: Congratulations! On Thu, Mar 9, 2023 at 8:37 PM Manikumar wrote: Congrats

[jira] [Assigned] (KAFKA-4969) State-store workload-aware StreamsPartitionAssignor

2023-03-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-4969: -- Assignee: Bill Bejeck > State-store workload-aware StreamsPartitionAssig

[jira] [Commented] (KAFKA-14778) Kafka Streams 2.7.1 to 3.3.1 rolling upgrade with static membership triggers a rebalance

2023-03-06 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697181#comment-17697181 ] Matthias J. Sax commented on KAFKA-14778: - Thanks for reporting this. – I believe the issue

[jira] [Updated] (KAFKA-14722) Make BooleanSerde public

2023-03-06 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14722: Description: KIP-907: [https://cwiki.apache.org/confluence/display/KAFKA/KIP-907%3A+Add

[jira] [Updated] (KAFKA-14722) Make BooleanSerde public

2023-03-06 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14722: Labels: beginner kip newbie (was: beginner need-kip newbie) > Make BooleanSerde pub

[jira] [Updated] (KAFKA-12446) Define KGroupedTable#aggregate subtractor + adder order of execution

2023-03-06 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12446: Description: KIP-904: [https://cwiki.apache.org/confluence/display/KAFKA/KIP-904%3A

[jira] [Updated] (KAFKA-12446) Define KGroupedTable#aggregate subtractor + adder order of execution

2023-03-06 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12446: Labels: kip (was: ) > Define KGroupedTable#aggregate subtractor + adder or

[jira] [Commented] (KAFKA-14748) Relax non-null FK left-join requirement

2023-03-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696313#comment-17696313 ] Matthias J. Sax commented on KAFKA-14748: - Yes, the behavior would change. But make this change

[jira] [Commented] (KAFKA-9234) Consider using @Nullable and @Nonnull annotations

2023-03-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696306#comment-17696306 ] Matthias J. Sax commented on KAFKA-9234: Thanks for the pointer – I am not familiar with JSpecify

[jira] [Commented] (KAFKA-9234) Consider using @Nullable and @Nonnull annotations

2023-03-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696249#comment-17696249 ] Matthias J. Sax commented on KAFKA-9234: {quote}I just joined the community this week. {quote

[jira] [Assigned] (KAFKA-9234) Consider using @Nullable and @Nonnull annotations

2023-03-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-9234: -- Assignee: Ganesh Sahu (was: Manasvi Gupta) > Consider using @Nullable and @Nonn

[jira] [Commented] (KAFKA-14748) Relax non-null FK left-join requirement

2023-03-02 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695945#comment-17695945 ] Matthias J. Sax commented on KAFKA-14748: - {quote}But for table-table FK-joins, today the former

[jira] [Commented] (KAFKA-14747) FK join should record discarded subscription responses

2023-03-02 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695848#comment-17695848 ] Matthias J. Sax commented on KAFKA-14747: - You would create a branch from `trunk` – for more

[jira] [Commented] (KAFKA-9234) Consider using @Nullable and @Nonnull annotations

2023-03-02 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695846#comment-17695846 ] Matthias J. Sax commented on KAFKA-9234:  [~rndgstn] did look into the PRs - maybe he knows best

Re: [VOTE] KIP-904: Kafka Streams - Guarantee subtractor is called before adder if key has not changed

2023-03-01 Thread Matthias J. Sax
+1 (binding) Thanks for the KIP! On 3/1/23 10:58 AM, Walker Carlson wrote: +1 Binding On Mon, Feb 27, 2023 at 12:48 PM Guozhang Wang wrote: +1. On Sun, Feb 26, 2023 at 4:27 PM Fq Public wrote: Hi everyone, I'd like to start the vote on KIP-904: Kafka Streams - Guarantee subtractor

Re: [VOTE] KIP-907: Add Boolean Serde to public interface

2023-03-01 Thread Matthias J. Sax
+1 (binding) Thanks for the KIP! On 3/1/23 10:59 AM, Walker Carlson wrote: +1 Binding On Mon, Feb 27, 2023 at 1:46 PM Chia-Ping Tsai wrote: +1 (binding)

[jira] [Assigned] (KAFKA-14533) Flaky Test SmokeTestDriverIntegrationTest.shouldWorkWithRebalance

2023-02-28 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-14533: --- Assignee: Guozhang Wang > Flaky T

<    3   4   5   6   7   8   9   10   11   12   >