Matthias J. Sax created KAFKA-13842:
---
Summary: Add per-aggregation step before repartitioning
Key: KAFKA-13842
URL: https://issues.apache.org/jira/browse/KAFKA-13842
Project: Kafka
Issue
Matthias J. Sax created KAFKA-13842:
---
Summary: Add per-aggregation step before repartitioning
Key: KAFKA-13842
URL: https://issues.apache.org/jira/browse/KAFKA-13842
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-13787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516068#comment-17516068
]
Matthias J. Sax edited comment on KAFKA-13787 at 4/15/22 8:56 PM
[
https://issues.apache.org/jira/browse/KAFKA-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522502#comment-17522502
]
Matthias J. Sax edited comment on KAFKA-12909 at 4/14/22 7:12 PM
[
https://issues.apache.org/jira/browse/KAFKA-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522502#comment-17522502
]
Matthias J. Sax commented on KAFKA-12909:
-
{quote}It makes sense but it is still kind of hard
[
https://issues.apache.org/jira/browse/KAFKA-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17521985#comment-17521985
]
Matthias J. Sax commented on KAFKA-12909:
-
This ticket is about left/outer join in particular
[
https://issues.apache.org/jira/browse/KAFKA-8318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17521866#comment-17521866
]
Matthias J. Sax commented on KAFKA-8318:
It seem [~ipasynkov] does no work on this any longer
[
https://issues.apache.org/jira/browse/KAFKA-13817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13817:
Labels: beginner newbie (was: )
> Schedule nextTimeToEmit to system time every t
[
https://issues.apache.org/jira/browse/KAFKA-13817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13817:
Component/s: streams
> Schedule nextTimeToEmit to system time every time instead of j
[
https://issues.apache.org/jira/browse/KAFKA-13813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17521243#comment-17521243
]
Matthias J. Sax commented on KAFKA-13813:
-
The change is intentionally, as users wanted to get
[
https://issues.apache.org/jira/browse/KAFKA-13820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17521234#comment-17521234
]
Matthias J. Sax commented on KAFKA-13820:
-
Sounds related to
[https://cwiki.apache.org
[
https://issues.apache.org/jira/browse/KAFKA-13813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13813:
Issue Type: Improvement (was: Bug)
> left/outer joins can wait indefinitely for emit
[
https://issues.apache.org/jira/browse/KAFKA-13813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13813:
Component/s: streams
> left/outer joins can wait indefinitely for emitted rec
[
https://issues.apache.org/jira/browse/KAFKA-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519199#comment-17519199
]
Matthias J. Sax commented on KAFKA-7509:
Thanks for staying on top of this. The filtering code
[
https://issues.apache.org/jira/browse/KAFKA-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519175#comment-17519175
]
Matthias J. Sax commented on KAFKA-12909:
-
Not that _inner_ join result are still instant, even
[
https://issues.apache.org/jira/browse/KAFKA-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516979#comment-17516979
]
Matthias J. Sax commented on KAFKA-7509:
Thanks for following up. – I briefly took a look. My
[
https://issues.apache.org/jira/browse/KAFKA-13787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516068#comment-17516068
]
Matthias J. Sax commented on KAFKA-13787:
-
`StateDirectory` should have all relevant code
+1 (binding)
On 4/1/22 6:47 AM, John Roesler wrote:
Thanks for the KIP, Daan!
I’m +1 (binding)
-John
On Tue, Mar 29, 2022, at 06:01, Daan Gertis wrote:
I would like to start a vote on this one:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-813%3A+Shareable+State+Stores
Cheers,
D.
Hi,
we added record header support to Kafka via KIP-82 many years ago. I
think it's time to complement this feature with record footers.
Looking forward to your feedback.
https://tinyurl.com/43jubbaj
-Matthias
[
https://issues.apache.org/jira/browse/KAFKA-13787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515648#comment-17515648
]
Matthias J. Sax commented on KAFKA-13787:
-
What file system are you using?
> Failed to del
[
https://issues.apache.org/jira/browse/KAFKA-13785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13785:
Labels: kip (was: )
> Support emit final result for windowed aggregat
[
https://issues.apache.org/jira/browse/KAFKA-13785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13785:
Component/s: streams
> Support emit final result for windowed aggregat
a Named parameter?
Might be tricky to accommodate since variadic arguments have to be last.
[1] - https://stackoverflow.com/a/48850722
Cheers,
Chris
On Mon, Mar 28, 2022 at 11:46 PM Matthias J. Sax wrote:
I think Java does not allow to have both overloads, because it would
result in a
-ary merge is what you're really modelling.
Regards,
Nick
On Thu, 24 Mar 2022 at 21:24, Matthias J. Sax wrote:
Thanks for proposing this KIP.
I feel a little bit torn by the idea. In general, we try to keep the
surface area small, and only add APIs that delivery (significant) value.
It seems
[
https://issues.apache.org/jira/browse/KAFKA-4609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16959455#comment-16959455
]
Matthias J. Sax edited comment on KAFKA-4609 at 3/25/22, 5:31 PM
Thanks for proposing this KIP.
I feel a little bit torn by the idea. In general, we try to keep the
surface area small, and only add APIs that delivery (significant) value.
It seems the current proposal is more or less about syntactic sugar,
what can still be valuable, but I am not really
+1 (binding)
On 3/24/22 1:52 PM, Hao Li wrote:
I hit reply on my phone in the mail app and changed the title and text
hoping it will start a new thread. Apparently it doesn't work...
On Thu, Mar 24, 2022 at 12:36 PM Bruno Cadonna wrote:
Hi Hao,
Actually, this is the VOTE thread. Do you
[
https://issues.apache.org/jira/browse/KAFKA-13542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17512018#comment-17512018
]
Matthias J. Sax commented on KAFKA-13542:
-
SGTM.
> Utilize the new Consumer#enforceRebala
d to other non-windowed operators in the
future.
2. To be consistent with other control class names, I
feel
maybe
we
can
name it "Emitted", not "EmitConfig".
3. Following the first comment, I think we can have the
static
constructor
names as "onWindowClose" an
[
https://issues.apache.org/jira/browse/KAFKA-13542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511537#comment-17511537
]
Matthias J. Sax commented on KAFKA-13542:
-
Curious: did we figure out why the patch resulted
[
https://issues.apache.org/jira/browse/KAFKA-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17510997#comment-17510997
]
Matthias J. Sax commented on KAFKA-7509:
Thanks for the detailed explanation. I don't know
The old API IQv1 is not deprecated yet, so I don't see a reason to revert.
We might not want to "advertise" the IQv2 in the release announcement
though if it's not complete and unstable right now.
We might also not want to mention it in the docs? Not sure if there was
already docs PR. If
[
https://issues.apache.org/jira/browse/KAFKA-13739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17510043#comment-17510043
]
Matthias J. Sax commented on KAFKA-13739:
-
Thank you! – Let us know if you need any help
[
https://issues.apache.org/jira/browse/KAFKA-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509095#comment-17509095
]
Matthias J. Sax commented on KAFKA-7509:
{quote} # Breaking backwards compatibility for a lot
[
https://issues.apache.org/jira/browse/KAFKA-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17507833#comment-17507833
]
Matthias J. Sax commented on KAFKA-7509:
Personally, I think the best way would be to tackle
[
https://issues.apache.org/jira/browse/KAFKA-13739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13739:
Labels: beginner newbie (was: )
> Sliding window without grace not work
[
https://issues.apache.org/jira/browse/KAFKA-13739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17507825#comment-17507825
]
Matthias J. Sax commented on KAFKA-13739:
-
Thanks for chiming in [~lct45] \
{quote}_if_ we want
but how we output to `KTable`. That's why I
feel option 1 makes more sense as it applies to `TimeWindowedKStream`. But
I'm also OK with option 2.
Hao
On Tue, Mar 15, 2022 at 4:48 PM Matthias J. Sax wrote:
Thanks for the KIP.
A general comment: it seem that we won't need any new
Thanks for the KIP.
A general comment: it seem that we won't need any new `allowedLateness`
parameter because the grace-period is defined on the window itself already?
(On the other hand, if I think about it once more, maybe the
`grace-period` is actually not a property of the window but a
+1 (binding)
Thanks for pushing this through. Was a difficult discussion!
-Matthias
On 3/15/22 10:01 AM, John Roesler wrote:
Thanks for the update, Jorge!
I’m still +1 (binding)
Thanks,
John
On Thu, Feb 17, 2022, at 12:57, Guozhang Wang wrote:
Thanks Jorge, overall looks good to me.
and Jon on going forward with the new
`FixedKeyRecord` approach.
The KIP has been updated accordingly.
Feel free to add your vote or amend on the vote thread if needed.
Cheers,
On Mon, 7 Mar 2022 at 21:57, Matthias J. Sax wrote:
I think it's ok that we cannot prevent users from mutating
[
https://issues.apache.org/jira/browse/KAFKA-13739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13739:
Priority: Minor (was: Major)
> Sliding window without grace not work
[
https://issues.apache.org/jira/browse/KAFKA-13739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17507261#comment-17507261
]
Matthias J. Sax commented on KAFKA-13739:
-
Thanks for reporting this. Good catch. I think you
0:22, Sophie Blee-Goldman wrote:
Thanks all, +1 (non-binding)
Cheers,
Sophie
On Wed, Jul 8, 2020 at 4:02 AM Bruno Cadonna
wrote:
Thanks Will and Piotr,
+1 (non-binding)
Best,
Bruno
On Wed, Jul 8, 2020 at 8:12 AM Matthias J. Sax
wrote:
Thanks for the KIP.
+1 (binding)
-Matthias
On 7/7
[
https://issues.apache.org/jira/browse/KAFKA-13699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13699:
Affects Version/s: 3.0.0
(was: 2.7.0)
> ProcessorContext d
[
https://issues.apache.org/jira/browse/KAFKA-13699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-13699:
---
Assignee: Matthias J. Sax
> ProcessorContext does not expose Stream T
[
https://issues.apache.org/jira/browse/KAFKA-13721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-13721:
---
Assignee: Matthias J. Sax
> Left-join still emit spurious results in stream-str
[
https://issues.apache.org/jira/browse/KAFKA-13722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13722:
Component/s: streams
> Update internal interfaces that use ProcessorContext to
[
https://issues.apache.org/jira/browse/KAFKA-8065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-8065:
--
Assignee: Matthias J. Sax
> Forwarding modified timestamps does not reset timest
[
https://issues.apache.org/jira/browse/KAFKA-13683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503218#comment-17503218
]
Matthias J. Sax commented on KAFKA-13683:
-
{quote}We are using kakfa streams 3.0.
{quote}
Should
[
https://issues.apache.org/jira/browse/KAFKA-13699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503214#comment-17503214
]
Matthias J. Sax commented on KAFKA-13699:
-
Seems the only question is, if we need to update
[
https://issues.apache.org/jira/browse/KAFKA-13699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13699:
Labels: newbie (was: )
> ProcessorContext does not expose Stream T
[
https://issues.apache.org/jira/browse/KAFKA-6035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503213#comment-17503213
]
Matthias J. Sax commented on KAFKA-6035:
Even if this ticket is finished, if you call
evel abstraction,
therefore users should be aware of the potential runtime exceptions if
the
key changes.
This is why I'm leaning towards alternative 1.
Looking forward to your feedback.
As a reminder, the vote thread is still open. Feel free to add your
vote
or
amend if needed.
Cheers,
On Fri, 4 M
level abstraction,
therefore users should be aware of the potential runtime exceptions if
the
key changes.
This is why I'm leaning towards alternative 1.
Looking forward to your feedback.
As a reminder, the vote thread is still open. Feel free to add your vote
or
amend if needed.
Cheers,
O
a projection of the
data. Either way, I would not add that into this KIP since it is a specific
use-case pattern.
Unless there is anything more to add or change, I would propose moving to a
vote?
Cheers!
D.
From: Matthias J. Sax
Date: Friday, 18 February 2022 at 03:29
To: dev@kafka.apache.org
Hard to answer from a 10,000ft view.
In general, a rolling upgrade (ie, bounce one instance at a time) is
recommended. If you have state, you would need to ensure that state is
not lost during a bounce. As you are using Kubernetes, using stateful
sets that allow you to re-attach disk should
Hard to answer from a 10,000ft view.
In general, a rolling upgrade (ie, bounce one instance at a time) is
recommended. If you have state, you would need to ensure that state is
not lost during a bounce. As you are using Kubernetes, using stateful
sets that allow you to re-attach disk should
do you mind clarifying these points in the
Compatibility section of your KIP?
Thanks,
-John
On Wed, 2022-02-23 at 15:07 -0800, Matthias J. Sax wrote:
For this KIP, I also see the value. I was just trying to make a
step
back and ask if it's a good short term solution. If we believe it
is,
[
https://issues.apache.org/jira/browse/KAFKA-13678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499753#comment-17499753
]
Matthias J. Sax commented on KAFKA-13678:
-
We have a different use case in mind: punctuation
[
https://issues.apache.org/jira/browse/KAFKA-13699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499691#comment-17499691
]
Matthias J. Sax commented on KAFKA-13699:
-
That's my understanding, too. Seems we missed to add
[
https://issues.apache.org/jira/browse/KAFKA-13678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497935#comment-17497935
]
Matthias J. Sax commented on KAFKA-13678:
-
We believe it's important for the data re-processing
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497934#comment-17497934
]
Matthias J. Sax commented on KAFKA-4212:
A windowed-store is basically just a `` kv-store
[
https://issues.apache.org/jira/browse/KAFKA-10635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497214#comment-17497214
]
Matthias J. Sax commented on KAFKA-10635:
-
Is this fixed via https://issues.apache.org/jira
[
https://issues.apache.org/jira/browse/KAFKA-12446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497210#comment-17497210
]
Matthias J. Sax commented on KAFKA-12446:
-
Just discovering the ticket. – I don't think it makes
[
https://issues.apache.org/jira/browse/KAFKA-12640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-12640.
-
Resolution: Duplicate
> AbstractCoordinator ignores backoff timeout when join
[
https://issues.apache.org/jira/browse/KAFKA-12640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-12640.
-
Resolution: Duplicate
> AbstractCoordinator ignores backoff timeout when join
[
https://issues.apache.org/jira/browse/KAFKA-13501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497201#comment-17497201
]
Matthias J. Sax commented on KAFKA-13501:
-
There is also https://issues.apache.org/jira/browse
[
https://issues.apache.org/jira/browse/KAFKA-13501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497196#comment-17497196
]
Matthias J. Sax commented on KAFKA-13501:
-
I just discovered https://issues.apache.org/jira
, at 00:43, Jorge Esteban Quilcate Otoya wrote:
On Fri, 18 Feb 2022 at 02:16, Matthias J. Sax wrote:
It probably deserves its own thread to start discussing ideas.
Yes. My question was: if we think it's time to do a DSL 2.0, should we
drop this KIP and just fix via DSL 2.0 instead?
Goo
[
https://issues.apache.org/jira/browse/KAFKA-13685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13685:
Component/s: streams
(was: consumer
[
https://issues.apache.org/jira/browse/KAFKA-13678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13678:
Issue Type: Improvement (was: Bug)
> 2nd punctuation using STREAM_TIME does not resp
[
https://issues.apache.org/jira/browse/KAFKA-13678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497056#comment-17497056
]
Matthias J. Sax commented on KAFKA-13678:
-
What [~guozhang] says is right – we align stream-time
[
https://issues.apache.org/jira/browse/KAFKA-13677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13677:
Component/s: streams
(was: clients)
> version 3.0.0 Proces
ctly, there was some checkpoint logic available when
restoring, but we are bypassing that since logging is disabled on the
statestore, no?
As always, thanks for your insights.
Cheers,
D.
From: Matthias J. Sax
Date: Wednesday, 16 February 2022 at 02:09
To: dev@kafka.apache.org
Subject: Re: [DIS
Esteban Quilcate Otoya <
quilcate.jo...@gmail.com> wrote:
Thank you Matthias, this is great feedback.
Adding my comments below.
On Wed, 16 Feb 2022 at 00:42, Matthias J. Sax wrote:
Thanks for the KIP.
In alignment to my reply to KIP-634, I am wondering if we are heading
into the right dir
en
what's
the main difference of adding a read-only store v.s. adding a global
store?
I think because of the first answer the behavior differs from global
stores.
Makes sense?
Cheers,
D.
From: Matthias J. Sax
Date: Thursday, 20 January 2022 at 21:12
To: dev@kafka.apache.org
Subject: Re: [DI
Thanks for the KIP.
In alignment to my reply to KIP-634, I am wondering if we are heading
into the right direction, or if we should consider to re-design the DSL
from scratch?
Even if we don't do a DSL 2.0 right now, I have some concerns about this
KIP:
(1) I am not sure if the propose
key, final V value, final
RecordContext
recordContext);
}
```
This would require to change `Topology#addSink()` to support
this
extractor as well.
If this is aligned with your proposal, I'm happy to add it to
this KIP.
Cheers,
Jorge.
On Fri, Sep 11, 2020 at 11:03 PM Matthias J. Sax <
mj..
[
https://issues.apache.org/jira/browse/KAFKA-13655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17492280#comment-17492280
]
Matthias J. Sax edited comment on KAFKA-13655 at 2/15/22, 12:23 AM
[
https://issues.apache.org/jira/browse/KAFKA-13655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17492280#comment-17492280
]
Matthias J. Sax commented on KAFKA-13655:
-
Missed you message from a week ago – sorry about
[
https://issues.apache.org/jira/browse/KAFKA-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17491093#comment-17491093
]
Matthias J. Sax commented on KAFKA-6647:
Not sure if I can follow the details – it might be best
[
https://issues.apache.org/jira/browse/KAFKA-13229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-13229:
---
Assignee: Rohan Desai
> KIP-761: implement a total blocked time metric in Ka
[
https://issues.apache.org/jira/browse/KAFKA-13641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489966#comment-17489966
]
Matthias J. Sax commented on KAFKA-13641:
-
{quote}Hope I didn't come across as rude or imply
[
https://issues.apache.org/jira/browse/KAFKA-13289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489962#comment-17489962
]
Matthias J. Sax commented on KAFKA-13289:
-
Great news! Thanks for sharing. Happy you got your
I feel setting 6 months for
closing and notifying committers on a per-week basis seems sufficient.
Guozhang
On Sun, Feb 6, 2022 at 9:58 AM Matthias J. Sax
wrote:
I am +1 to close stale PRs -- not sure to what extend we want to
automate it, or just leave it up to the committers to do the cleanup
man
[
https://issues.apache.org/jira/browse/KAFKA-13655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-13655.
-
Resolution: Not A Bug
> Cannot edit clients p
[
https://issues.apache.org/jira/browse/KAFKA-13655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489958#comment-17489958
]
Matthias J. Sax edited comment on KAFKA-13655 at 2/10/22, 5:05 AM
[
https://issues.apache.org/jira/browse/KAFKA-13655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-13655.
-
Resolution: Not A Bug
> Cannot edit clients p
[
https://issues.apache.org/jira/browse/KAFKA-13655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489958#comment-17489958
]
Matthias J. Sax commented on KAFKA-13655:
-
Did you create an account (note the Jira and wiki
Congratulations! Glad to have you onboard, Luke!
-Matthias
On 2/9/22 16:37, Bill Bejeck wrote:
Congrats Luke! Well deserved.
-Bill
On Wed, Feb 9, 2022 at 7:25 PM Israel Ekpo wrote:
Congratulations Luke!
Thank you for your service
On Wed, Feb 9, 2022 at 6:22 PM Guozhang Wang wrote:
Congratulations! Glad to have you onboard, Luke!
-Matthias
On 2/9/22 16:37, Bill Bejeck wrote:
Congrats Luke! Well deserved.
-Bill
On Wed, Feb 9, 2022 at 7:25 PM Israel Ekpo wrote:
Congratulations Luke!
Thank you for your service
On Wed, Feb 9, 2022 at 6:22 PM Guozhang Wang wrote:
[
https://issues.apache.org/jira/browse/KAFKA-13400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-13400.
-
Resolution: Not A Bug
Based on the information provided, the conclusion seems
[
https://issues.apache.org/jira/browse/KAFKA-13400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-13400.
-
Resolution: Not A Bug
Based on the information provided, the conclusion seems
[
https://issues.apache.org/jira/browse/KAFKA-13492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13492:
Fix Version/s: 3.2.0
> IQ Parity: queries for key/value store range and s
[
https://issues.apache.org/jira/browse/KAFKA-8410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-8410:
---
Description:
KIP-478:
[https://cwiki.apache.org/confluence/display/KAFKA/KIP-478+-+Strongly
[
https://issues.apache.org/jira/browse/KAFKA-8410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-8410:
---
Labels: kip tech-debt (was: tech-debt)
> Strengthen the types of Processors, at le
[
https://issues.apache.org/jira/browse/KAFKA-8410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-8410.
Resolution: Fixed
This feature (KIP–478:
[https://cwiki.apache.org/confluence/display
[
https://issues.apache.org/jira/browse/KAFKA-8410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-8410.
Resolution: Fixed
This feature (KIP–478:
[https://cwiki.apache.org/confluence/display
[
https://issues.apache.org/jira/browse/KAFKA-8410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-8410:
---
Fix Version/s: 2.7.0
> Strengthen the types of Processors, at least in the DSL, ma
1201 - 1300 of 11152 matches
Mail list logo
