[
https://issues.apache.org/jira/browse/KAFKA-14076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-14076:
Priority: Blocker (was: Major)
> Fix issues with KafkaStreams.CloseOpti
[
https://issues.apache.org/jira/browse/KAFKA-14076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-14076:
Fix Version/s: 3.3.0
> Fix issues with KafkaStreams.CloseOpti
[
https://issues.apache.org/jira/browse/KAFKA-14076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-14076:
---
Assignee: Jim Hughes
> Fix issues with KafkaStreams.CloseOpti
[
https://issues.apache.org/jira/browse/KAFKA-12887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17568659#comment-17568659
]
Matthias J. Sax commented on KAFKA-12887:
-
This feature broke some stuff,
[
https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13152:
Labels: kip (was: needs-kip)
> Replace "buffered.records.per.partiti
[
https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reopened KAFKA-13152:
-
> Replace "buffered.records.per.partition" with "inpu
[
https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13152:
Fix Version/s: (was: 3.3.0)
> Replace "buffered.records.per.partiti
[
https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reopened KAFKA-13152:
-
> Replace "buffered.records.per.partition" with "inpu
ing in this new class devoid of any StreamPartitioner. I just
thought it's cleaner to keep it this way as StreamPartitioner already
dpes the partitioning. Let me know what you think.
Thanks!
Sagar.
On Wed, Jun 29, 2022 at 5:34 AM Matthias J. Sax wrote:
Thanks for the KIP. Overall a good addi
Jun 29, 2022 at 4:57 AM David Jacot wrote:
Thanks for the KIP.
I read it and I am also worried by the complexity of the new
configurations. They are not easy to grasp. I need to digest it a bit more,
I think.
Best,
David
Le mer. 29 juin 2022 à 02:25, Matthias J. Sax a écrit :
Thanks for the
[
https://issues.apache.org/jira/browse/KAFKA-14049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563510#comment-17563510
]
Matthias J. Sax commented on KAFKA-14049:
-
{quote}Null Values in the Stream
[ https://issues.apache.org/jira/browse/KAFKA-14049 ]
Matthias J. Sax deleted comment on KAFKA-14049:
-
was (Author: mjsax):
Sounds like a duplicate to https://issues.apache.org/jira/browse/KAFKA-12317 ?
> Relax Non Null Requirement
[
https://issues.apache.org/jira/browse/KAFKA-14049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563509#comment-17563509
]
Matthias J. Sax commented on KAFKA-14049:
-
Sounds like a duplicate to h
[
https://issues.apache.org/jira/browse/KAFKA-13936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13936:
Fix Version/s: 3.3.0
> Invalid consumer lag when monitoring from a kafka stre
[
https://issues.apache.org/jira/browse/KAFKA-13936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-13936:
---
Assignee: Prashanth Joseph Babu
> Invalid consumer lag when monitoring fro
[
https://issues.apache.org/jira/browse/KAFKA-13936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-13936.
-
Resolution: Fixed
> Invalid consumer lag when monitoring from a kafka stre
[
https://issues.apache.org/jira/browse/KAFKA-13936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-13936.
-
Resolution: Fixed
> Invalid consumer lag when monitoring from a kafka stre
1
+1(binding)
On Thu, Mar 24, 2022 at 5:13 PM Matthias J. Sax wrote:
+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
[
https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17560622#comment-17560622
]
Matthias J. Sax commented on KAFKA-10493:
-
There is nothing official yet,
Thanks for the KIP.
I don't think I fully digested the proposal yet, but my first reaction
is: this is quite complicated. Frankly, I am worried about complexity
and usability.
Especially the option `safe_latest` is a "weird" one IMHO, and `nearest`
is even more complex.
The problem at hand
Thanks for the KIP. Overall a good addition.
I am actually not sure if we need to add a new class? From my
understanding, if there is exactly one abstract method, the interface is
still functional? Thus, we could add a new method to
`StreamsPartitioner` with a default implementation (that call
[
https://issues.apache.org/jira/browse/KAFKA-13531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555781#comment-17555781
]
Matthias J. Sax commented on KAFKA-13531:
-
Could be. We usually also repor
[
https://issues.apache.org/jira/browse/KAFKA-13531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-13531.
-
Resolution: Cannot Reproduce
> Flaky test NamedTopologyIntegrationT
[
https://issues.apache.org/jira/browse/KAFKA-13531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-13531.
-
Resolution: Cannot Reproduce
> Flaky test NamedTopologyIntegrationT
[
https://issues.apache.org/jira/browse/KAFKA-13939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17554742#comment-17554742
]
Matthias J. Sax commented on KAFKA-13939:
-
Thanks for the PR. I added yo
[
https://issues.apache.org/jira/browse/KAFKA-13939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-13939:
---
Assignee: Jackson Newhouse
> Memory Leak When Logging Is Disabled
messages, I mean if both batches include a message being written to topic
A, could messages from batch with sn X+1 end up being persisted with an
offset lesser than the ones from the batch with sn X?
Does this question make sense?
El mar, 7 jun 2022 a las 16:13, Matthias J. Sax ()
escribió:
Yes, t
[
https://issues.apache.org/jira/browse/SUREFIRE-2076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17554376#comment-17554376
]
Matthias J. Sax commented on SUREFIRE-2076:
---
Thanks for the update!
[
https://issues.apache.org/jira/browse/KAFKA-13963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17551333#comment-17551333
]
Matthias J. Sax commented on KAFKA-13963:
-
{quote}Is it worth updating the
[
https://issues.apache.org/jira/browse/KAFKA-13963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17551271#comment-17551271
]
Matthias J. Sax commented on KAFKA-13963:
-
TopologyDescription only descr
Yes, the broker de-dupes using the sequence number.
But for example, if a sequence number is skipped, you could get this
exception: the current batch of messages cannot be appended to the log,
as one batch is missing, and the producer would need to re-send the
previous/missing batch with lower
`enable.auto.commit` is a Consumer config and does not apply to Kafka
Stream.
In Kafka Streams, you basically always have auto commit enabled, and you
can control how frequently commits happen via `commit.interval.ms`.
Also on `close()` Kafka Streams would commit offsets.
-Matthias
On 5/31
[
https://issues.apache.org/jira/browse/KAFKA-13936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17546407#comment-17546407
]
Matthias J. Sax commented on KAFKA-13936:
-
The docs are in the same reposi
[
https://issues.apache.org/jira/browse/KAFKA-13936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17545686#comment-17545686
]
Matthias J. Sax commented on KAFKA-13936:
-
Might be worth to document for
[
https://issues.apache.org/jira/browse/KAFKA-13945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13945:
Description: KIP-846:
[https://cwiki.apache.org/confluence/pages/viewpage.action?pageId
[
https://issues.apache.org/jira/browse/KAFKA-13936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17544647#comment-17544647
]
Matthias J. Sax commented on KAFKA-13936:
-
As mentioned above, offsets ar
[
https://issues.apache.org/jira/browse/KAFKA-13939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17544645#comment-17544645
]
Matthias J. Sax commented on KAFKA-13939:
-
Thanks for reporting this i
[
https://issues.apache.org/jira/browse/KAFKA-13939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13939:
Component/s: streams
> Memory Leak When Logging Is Disabled
[
https://issues.apache.org/jira/browse/KAFKA-13939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13939:
Priority: Blocker (was: Major)
> Memory Leak When Logging Is Disabled
[
https://issues.apache.org/jira/browse/KAFKA-13936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17542359#comment-17542359
]
Matthias J. Sax commented on KAFKA-13936:
-
> we see in the kafka UI
T
ane wrote:
@Matthias J. Sax / All
Have added below line :
.suppress(Suppressed.untilWindowCloses(Suppressed.BufferConfig.unbounded()))
Here is the output : (for uuid (*2cbef750-325b-4a2f-ac39-b2c23fa0313f)*,
expecting single output but that is not the case here. Which 1 is the final
output from tho
Added. Feel free to update wiki pages with smaller details like this
directly.
-Matthias
On 5/19/22 2:27 PM, James Cheng wrote:
Thanks Guozhang! Based on your comment, I searched through the repo and found
the associated pull requests and JIRAs.
It looks like most of the support was added i
[
https://issues.apache.org/jira/browse/KAFKA-13817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17540294#comment-17540294
]
Matthias J. Sax commented on KAFKA-13817:
-
Thanks for the PR! I put it int
[
https://issues.apache.org/jira/browse/KAFKA-13913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17539718#comment-17539718
]
Matthias J. Sax commented on KAFKA-13913:
-
There was some discussion about
[
https://issues.apache.org/jira/browse/KAFKA-13913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13913:
Labels: kip (was: )
> Provide builders for KafkaProducer/KafkaConsumer and KafkaStre
[
https://issues.apache.org/jira/browse/KAFKA-13913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13913:
Component/s: streams
> Provide builders for KafkaProducer/KafkaConsumer and KafkaStre
Emitting intermediate result is by-design.
If you don't want to get intermediate result, you can add `suppress()`
after the aggregation and configure it to only "emit on window close".
-Matthias
On 5/17/22 3:20 AM, Shankar Mane wrote:
Hi All,
Our use case is to use sliding window. (for e.g.
[
https://issues.apache.org/jira/browse/KAFKA-6520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17537860#comment-17537860
]
Matthias J. Sax commented on KAFKA-6520:
It's still an open item –
[
https://issues.apache.org/jira/browse/KAFKA-13817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17536926#comment-17536926
]
Matthias J. Sax commented on KAFKA-13817:
-
> as it will eventually self-
[
https://issues.apache.org/jira/browse/SUREFIRE-2076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17535072#comment-17535072
]
Matthias J. Sax commented on SUREFIRE-2076:
---
[~tibordigana] [~zoltan.
[
https://issues.apache.org/jira/browse/KAFKA-7527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-7527.
Resolution: Fixed
> Enable Dependency Injection for Kafka Streams handlers (KIP-
[
https://issues.apache.org/jira/browse/KAFKA-7527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-7527.
Resolution: Fixed
> Enable Dependency Injection for Kafka Streams handlers (KIP-
I had one minor question on the discuss thread. It's mainly about
clarifying and document the user contract. I am fine either way.
+1 (binding)
-Matthias
On 5/10/22 12:32 PM, Sophie Blee-Goldman wrote:
Thanks for the KIP! +1 (binding)
On Tue, May 10, 2022, 12:24 PM Bruno Cadonna wrote:
T
ably
better
to also commit the processing before we pause it.
Guozhang
On Fri, May 6, 2022 at 6:12 PM Jim Hughes
wrote:
Hi Matthias,
Since the only thing which will be paused is processing the
topology, I
think we can let commits happen naturally.
Good point about getting the paused stat
I think it's tricky to propagate a pauseAll() via the rebalance
protocol. New members joining the group would need to get paused, too?
Could there be weird race conditions with overlapping pauseAll() and
resumeAll() calls on different instanced while there could be a errors /
network partitions
[
https://issues.apache.org/jira/browse/KAFKA-8769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17532427#comment-17532427
]
Matthias J. Sax commented on KAFKA-8769:
Just a "random" comment,
[
https://issues.apache.org/jira/browse/KAFKA-13873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13873:
Description:
In order to reduce resources used or modify data pipelines, users may want
[
https://issues.apache.org/jira/browse/KAFKA-13873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13873:
Component/s: streams
> Add ability to Pause / Resume KafkaStreams Topolog
[
https://issues.apache.org/jira/browse/KAFKA-13873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13873:
Labels: kip (was: )
> Add ability to Pause / Resume KafkaStreams Topolog
[
https://issues.apache.org/jira/browse/KAFKA-13870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13870:
Labels: needs-kip (was: )
> support both Suppressed untilTimeLimit and maxBytes with
[
https://issues.apache.org/jira/browse/KAFKA-13870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17531836#comment-17531836
]
Matthias J. Sax commented on KAFKA-13870:
-
I think you mix up two conc
[
https://issues.apache.org/jira/browse/KAFKA-13813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13813:
Summary: left/outer joins can wait indefinitely for emitted record with
spurious record
Matthias J. Sax created KAFKA-13866:
---
Summary: Support more advanced time retention policies
Key: KAFKA-13866
URL: https://issues.apache.org/jira/browse/KAFKA-13866
Project: Kafka
Issue
Matthias J. Sax created KAFKA-13866:
---
Summary: Support more advanced time retention policies
Key: KAFKA-13866
URL: https://issues.apache.org/jira/browse/KAFKA-13866
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/SUREFIRE-2076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17529670#comment-17529670
]
Matthias J. Sax commented on SUREFIRE-2076:
---
Seems we are hitting
king it up.
Levani
On 23. Apr 2022, at 02:43, Matthias J. Sax wrote:
Ivan,
are you still interested in this KIP? I think it would be a good addition.
-Matthias
On 8/16/21 5:30 PM, Matthias J. Sax wrote:
Your point about the IQ problem is an interesting one. I missed the
point that the "
[
https://issues.apache.org/jira/browse/KAFKA-13647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17528288#comment-17528288
]
Matthias J. Sax commented on KAFKA-13647:
-
Should we close this ticket?
Ivan,
are you still interested in this KIP? I think it would be a good addition.
-Matthias
On 8/16/21 5:30 PM, Matthias J. Sax wrote:
Your point about the IQ problem is an interesting one. I missed the
point that the "new key" would be a "superkey", and thus, it should
a
ml#asList-T...-
[3] -
https://docs.oracle.com/javase/8/docs/api/java/util/Collection.html#toArray-T:A-
Cheers,
Chris
On Tue, Mar 29, 2022 at 11:14 PM Matthias J. Sax wrote:
My understand was, that the original proposal was to have:
merge(KStream stream);
merge(KStream... streams);
Mayb
[
https://issues.apache.org/jira/browse/KAFKA-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17522502#comment-17522502
]
Matthias J. Sax edited comment on KAFKA-12909 at 4/21/22 9:1
[
https://issues.apache.org/jira/browse/KAFKA-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17526086#comment-17526086
]
Matthias J. Sax commented on KAFKA-12909:
-
Ah sorry. That was my bad... F
[
https://issues.apache.org/jira/browse/KAFKA-13842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13842:
Description:
Kafka Streams follows a continuous refinement model for aggregation. For
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&focusedCommentId=17516068#comment-17516068
]
Matthias J. Sax edited comment on KAFKA-13787 at 4/15/22 8:5
[
https://issues.apache.org/jira/browse/KAFKA-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17522502#comment-17522502
]
Matthias J. Sax edited comment on KAFKA-12909 at 4/14/22 7:1
[
https://issues.apache.org/jira/browse/KAFKA-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17522502#comment-17522502
]
Matthias J. Sax commented on KAFKA-12909:
-
{quote}It makes sense but i
[
https://issues.apache.org/jira/browse/KAFKA-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521985#comment-17521985
]
Matthias J. Sax commented on KAFKA-12909:
-
This ticket is about left/outer
[
https://issues.apache.org/jira/browse/KAFKA-8318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521866#comment-17521866
]
Matthias J. Sax commented on KAFKA-8318:
It seem [~ipasynkov] does no wor
[
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&focusedCommentId=17521243#comment-17521243
]
Matthias J. Sax commented on KAFKA-13813:
-
The change is intentionally
[
https://issues.apache.org/jira/browse/KAFKA-13820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521234#comment-17521234
]
Matthias J. Sax commented on KAFKA-13820:
-
Sounds related to
[h
[
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 record w
[
https://issues.apache.org/jira/browse/KAFKA-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519199#comment-17519199
]
Matthias J. Sax commented on KAFKA-7509:
Thanks for staying on top of this.
[
https://issues.apache.org/jira/browse/KAFKA-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519175#comment-17519175
]
Matthias J. Sax commented on KAFKA-12909:
-
Not that _inner_ join result
[
https://issues.apache.org/jira/browse/KAFKA-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516979#comment-17516979
]
Matthias J. Sax commented on KAFKA-7509:
Thanks for following up. – I bri
[
https://issues.apache.org/jira/browse/KAFKA-13787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516068#comment-17516068
]
Matthias J. Sax commented on KAFKA-13787:
-
`StateDirectory` should have
+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&focusedCommentId=17515648#comment-17515648
]
Matthias J. Sax commented on KAFKA-13787:
-
What file system are you u
[
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
ng a variant that accepts 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, bec
a
single n-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) v
[
https://issues.apache.org/jira/browse/KAFKA-4609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16959455#comment-16959455
]
Matthias J. Sax edited comment on KAFKA-4609 at 3/25/22, 5:3
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 sur
+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 use
[
https://issues.apache.org/jira/browse/KAFKA-13542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17512018#comment-17512018
]
Matthias J. Sax commented on KAFKA-13542:
-
SGTM.
> Utilize the new C
1701 - 1800 of 10763 matches
Mail list logo
