Did reply on SO.
-Matthias
On 1/24/24 2:18 AM, warrior2...@gmail.com wrote:
Let's say there's a topic in which chunks of different files are all
mixed up represented by a tuple |(FileId, Chunk)|.
Chunks of a same file also can be a little out of order.
The task is to aggregate all files and
Both fk1 and fk2 point to the PK of another entity (not shown for
brevity, of no relevance to the question).
It this two independent FK, or one two-column FK?
Ingesting the topic into a Kafka Streams application, how can I re-key
the resulting KTable by both fk1 and fk2?
If you read the
I am a not sure if I can follow completely.
From the figures you show, you have a topic with 4 partitions, and 4
consumer groups. Thus, each consumer group should read all 4 partitions,
but the figure indicate that each group would read a single partition only?
Can you clarify? Are you using
[
https://issues.apache.org/jira/browse/KAFKA-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-10184.
-
Assignee: (was: John Roesler)
Resolution: Cannot Reproduce
This ticket
[
https://issues.apache.org/jira/browse/KAFKA-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-10184.
-
Assignee: (was: John Roesler)
Resolution: Cannot Reproduce
This ticket
[
https://issues.apache.org/jira/browse/KAFKA-16017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16017:
Fix Version/s: 3.5.3
3.4.2
3.6.2
> Checkpoin
[
https://issues.apache.org/jira/browse/KAFKA-16141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16141:
Fix Version/s: 3.7.0
> StreamsStandbyTask##test_standby_tasks_rebalanceArgume
Stan, thanks for driving this all forward! Excellent job.
About
StreamsStandbyTask - https://issues.apache.org/jira/browse/KAFKA-16141
StreamsUpgradeTest - https://issues.apache.org/jira/browse/KAFKA-16139
For `StreamsUpgradeTest` it was a test setup issue and should be fixed
now in trunk
[
https://issues.apache.org/jira/browse/KAFKA-16141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16141:
Component/s: streams
> StreamsStandbyTask##test_standby_tasks_rebalanceArgume
[
https://issues.apache.org/jira/browse/KAFKA-16139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16139:
Component/s: streams
system tests
> StreamsUpgradeTest fa
[
https://issues.apache.org/jira/browse/KAFKA-15770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-15770:
---
Assignee: Matthias J. Sax
[
https://issues.apache.org/jira/browse/KAFKA-16123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16123:
Component/s: streams
> KStreamKStreamJoinProcessor forwards null records for left/ou
[
https://issues.apache.org/jira/browse/KAFKA-16159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16159:
Affects Version/s: 3.7.0
> Prune excessive logging from Telemetry Repor
[
https://issues.apache.org/jira/browse/KAFKA-16159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16159:
Fix Version/s: (was: 3.8.0)
> Prune excessive logging from Telemetry Repor
[
https://issues.apache.org/jira/browse/KAFKA-16139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-16139.
-
Fix Version/s: 3.7.0
3.6.1
Resolution: Fixed
[
https://issues.apache.org/jira/browse/KAFKA-16139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-16139.
-
Fix Version/s: 3.7.0
3.6.1
Resolution: Fixed
[
https://issues.apache.org/jira/browse/KAFKA-16141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16141:
Issue Type: Bug (was: Test)
> StreamsStandbyTask##test_standby_tasks_rebalanceArgume
[
https://issues.apache.org/jira/browse/KAFKA-16141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807890#comment-17807890
]
Matthias J. Sax edited comment on KAFKA-16141 at 1/17/24 9:15 PM
Matthias J. Sax created KAFKA-16158:
---
Summary: Cleanup usage of `TimestampedBytesStore` interface
Key: KAFKA-16158
URL: https://issues.apache.org/jira/browse/KAFKA-16158
Project: Kafka
Matthias J. Sax created KAFKA-16158:
---
Summary: Cleanup usage of `TimestampedBytesStore` interface
Key: KAFKA-16158
URL: https://issues.apache.org/jira/browse/KAFKA-16158
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-16141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807890#comment-17807890
]
Matthias J. Sax commented on KAFKA-16141:
-
After discussion with Almog (and testing
[
https://issues.apache.org/jira/browse/KAFKA-16141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-16141:
---
Assignee: Matthias J. Sax (was: Almog Gavra)
> StreamsStandbyT
tream here ???/*
On 2024-Jan-13 01:22, Matthias J. Sax wrote:
`KGroupedStream` is just an "intermediate representation" to get a
better flow in the DSL. It's not a "top level" abstraction like
KStream/KTable.
For `KTable` there is `transformValue()` -- there is no `tra
[
https://issues.apache.org/jira/browse/KAFKA-16141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807543#comment-17807543
]
Matthias J. Sax commented on KAFKA-16141:
-
Thanks. I am wondering if the right fix would
[
https://issues.apache.org/jira/browse/KAFKA-16141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807411#comment-17807411
]
Matthias J. Sax commented on KAFKA-16141:
-
Assigned to [~agavra] and marked as blocker. Might
[
https://issues.apache.org/jira/browse/KAFKA-16141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16141:
Priority: Blocker (was: Major)
> StreamsStandbyT
[
https://issues.apache.org/jira/browse/KAFKA-16141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-16141:
---
Assignee: Almog Gavra
> StreamsStandbyTask##test_standby_tasks_rebalanceArgume
François,
thanks for starting this initiative. Personally, I don't think it's
necessarily harmful for the project to add such a new page, however, I
share the same concerns others raised already.
I understand your motivation that people had issues finding commercial
support, but I am not
François,
thanks for starting this initiative. Personally, I don't think it's
necessarily harmful for the project to add such a new page, however, I
share the same concerns others raised already.
I understand your motivation that people had issues finding commercial
support, but I am not
`KGroupedStream` is just an "intermediate representation" to get a
better flow in the DSL. It's not a "top level" abstraction like
KStream/KTable.
For `KTable` there is `transformValue()` -- there is no `transform()`
because keying must be preserved -- if you want to change the keying you
`KGroupedStream` is just an "intermediate representation" to get a
better flow in the DSL. It's not a "top level" abstraction like
KStream/KTable.
For `KTable` there is `transformValue()` -- there is no `transform()`
because keying must be preserved -- if you want to change the keying you
[
https://issues.apache.org/jira/browse/KAFKA-16089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17806217#comment-17806217
]
Matthias J. Sax commented on KAFKA-16089:
-
Great job!
> Kafka Streams still leaking mem
[
https://issues.apache.org/jira/browse/KAFKA-14949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-14949.
-
Resolution: Fixed
> Add Streams upgrade tests from AK
[
https://issues.apache.org/jira/browse/KAFKA-14949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-14949.
-
Resolution: Fixed
> Add Streams upgrade tests from AK
[
https://issues.apache.org/jira/browse/KAFKA-14949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-14949:
---
Assignee: Mickael Maison
> Add Streams upgrade tests from AK
[
https://issues.apache.org/jira/browse/KAFKA-16092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16092:
Issue Type: New Feature (was: Improvement)
> Queues for Ka
[
https://issues.apache.org/jira/browse/KAFKA-14404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17803543#comment-17803543
]
Matthias J. Sax commented on KAFKA-14404:
-
It seems [~sujayopensource] lost interest to work
and merged in trunk, I'll
update the 3.7 branch as well.
Regards,
Apoorv Mittal
+44 7721681581
On Thu, Jan 4, 2024 at 12:49 PM Matthias J. Sax wrote:
We found a blocker for 3.7:
https://issues.apache.org/jira/browse/KAFKA-16077
Already having a PR under review to fix it.
-Matthias
On 1/3
We found a blocker for 3.7:
https://issues.apache.org/jira/browse/KAFKA-16077
Already having a PR under review to fix it.
-Matthias
On 1/3/24 10:43 AM, Stanislav Kozlovski wrote:
Hey all, happy new year.
Thanks for the heads up Almog. Makes sense.
To give an update - I haven't been able
[
https://issues.apache.org/jira/browse/KAFKA-16077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16077:
Priority: Blocker (was: Critical)
> Streams fails to close task after restoration w
Congrats!
On 12/29/23 9:40 AM, Viktor Somogyi-Vass wrote:
Congrats Divij, well deserved!
On Fri, Dec 29, 2023, 09:36 Lucas Brutschy
wrote:
Congratulations, Divij!
On Fri, Dec 29, 2023 at 1:32 AM Colin McCabe wrote:
Congratulations, Divij!
best,
Colin
On Thu, Dec 28, 2023, at 11:38,
SGTM.
I found it always odd that it's named `KafkaConnect` :)
-Matthias
On 12/26/23 6:03 PM, Greg Harris wrote:
Hi Connect Developers,
I noticed recently that we had two Jira components: "KafkaConnect" and
"connect", one with >1000 issues and one with 20 issues. I merged the
two tags,
[
https://issues.apache.org/jira/browse/KAFKA-16055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16055:
Component/s: streams
> Thread unsafe use of HashMap stored in QueryableStoreProvi
[
https://issues.apache.org/jira/browse/KAFKA-16046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16046:
Fix Version/s: 3.7.0
> Stream Stream Joins fail after restoration with deserializat
[
https://issues.apache.org/jira/browse/KAFKA-16018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798908#comment-17798908
]
Matthias J. Sax commented on KAFKA-16018:
-
Timing is a little unclear to be fair
[
https://issues.apache.org/jira/browse/KAFKA-15448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-15448.
-
Fix Version/s: 3.7.0
Assignee: Colt McNealy
Resolution: Fixed
> Stre
[
https://issues.apache.org/jira/browse/KAFKA-15448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-15448:
Issue Type: New Feature (was: Improvement)
> Streams StandbyTaskUpdateListe
[
https://issues.apache.org/jira/browse/KAFKA-15448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-15448.
-
Fix Version/s: 3.7.0
Assignee: Colt McNealy
Resolution: Fixed
> Stre
[
https://issues.apache.org/jira/browse/KAFKA-15448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-15448:
Labels: kip (was: needs-kip)
> Streams StandbyTaskUpdateListe
[
https://issues.apache.org/jira/browse/KAFKA-15448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-15448:
Description:
KIP-869:
[https://cwiki.apache.org/confluence/display/KAFKA/KIP-988%3A
[
https://issues.apache.org/jira/browse/KAFKA-16018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798137#comment-17798137
]
Matthias J. Sax commented on KAFKA-16018:
-
Seems this will "auto fix" in 4.0 when
[
https://issues.apache.org/jira/browse/KAFKA-9545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-9545.
Resolution: Fixed
> Flaky T
[
https://issues.apache.org/jira/browse/KAFKA-9545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-9545.
Resolution: Fixed
> Flaky T
[
https://issues.apache.org/jira/browse/KAFKA-15027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-15027:
Labels: kip (was: )
> Implement rack aware assignment for standby ta
[
https://issues.apache.org/jira/browse/KAFKA-15024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-15024:
Labels: kip (was: )
> Add cost function for task/cli
[
https://issues.apache.org/jira/browse/KAFKA-15054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-15054:
Labels: kip (was: )
> Add configs and logic to decide if rack aware assignment sho
[
https://issues.apache.org/jira/browse/KAFKA-15025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-15025:
Labels: kip (was: )
> Implement min-cost flow without balancing tasks for s
[
https://issues.apache.org/jira/browse/KAFKA-15026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax closed KAFKA-15026.
---
> Implement min-cost flow balancing tasks for same subtopol
[
https://issues.apache.org/jira/browse/KAFKA-15023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-15023:
Labels: kip (was: )
> Get rack information for source topic partitions for a t
[
https://issues.apache.org/jira/browse/KAFKA-15026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-15026:
Labels: kip (was: )
> Implement min-cost flow balancing tasks for same subtopol
[
https://issues.apache.org/jira/browse/KAFKA-15026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-15026.
-
Fix Version/s: 3.7.0
Resolution: Fixed
> Implement min-cost flow balancing ta
[
https://issues.apache.org/jira/browse/KAFKA-15022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-15022.
-
Fix Version/s: 3.7.0
3.6.0
Resolution: Fixed
> Support r
[
https://issues.apache.org/jira/browse/KAFKA-15026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-15026.
-
Fix Version/s: 3.7.0
Resolution: Fixed
> Implement min-cost flow balancing ta
[
https://issues.apache.org/jira/browse/KAFKA-15022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-15022.
-
Fix Version/s: 3.7.0
3.6.0
Resolution: Fixed
> Support r
[
https://issues.apache.org/jira/browse/KAFKA-15348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-15348:
Labels: kip (was: )
> Range IQs with versioned state sto
[
https://issues.apache.org/jira/browse/KAFKA-15347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-15347.
-
Fix Version/s: 3.7.0
Resolution: Fixed
> Single-Key_multi-timestamp
[
https://issues.apache.org/jira/browse/KAFKA-15346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-15346:
Labels: kip (was: )
> Single-Key_single-timestamp IQs with versioned state sto
[
https://issues.apache.org/jira/browse/KAFKA-15347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-15347.
-
Fix Version/s: 3.7.0
Resolution: Fixed
> Single-Key_multi-timestamp
[
https://issues.apache.org/jira/browse/KAFKA-15347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-15347:
Labels: kip (was: )
> Single-Key_multi-timestamp IQs with versioned state sto
[
https://issues.apache.org/jira/browse/KAFKA-15957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-15957.
-
Resolution: Fixed
[
https://issues.apache.org/jira/browse/KAFKA-15957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-15957.
-
Resolution: Fixed
[
https://issues.apache.org/jira/browse/KAFKA-15957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-15957:
---
Assignee: Lucas Brutschy
der, LittleHorse.dev*
On Thu, Nov 30, 2023 at 4:43 PM Matthias J. Sax wrote:
parameter is somewhat irrelevant to our use case
Sounds like a weird justification to change the KIP. Providing more
information is usually better than less, so it seems it won't hurt to
just keep it (seems useful in gene
hu, Oct 26, 2023 at 12:17 PM Matthias J. Sax wrote:
Thanks. SGTM.
On 10/25/23 4:06 PM, Sophie Blee-Goldman wrote:
That all sounds good to me! Thanks for the KIP
On Wed, Oct 25, 2023 at 3:47 PM Colt McNealy
wrote:
Hi Sophie, Matthias, Bruno, and Eduwer—
Thanks for your patience as I
[
https://issues.apache.org/jira/browse/KAFKA-15527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-15527.
-
Resolution: Fixed
> Add reverseRange and reverseAll query over kv-store in I
[
https://issues.apache.org/jira/browse/KAFKA-15527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-15527.
-
Resolution: Fixed
> Add reverseRange and reverseAll query over kv-store in I
Matthias J. Sax created KAFKA-15951:
---
Summary: MissingSourceTopicException should include topic names
Key: KAFKA-15951
URL: https://issues.apache.org/jira/browse/KAFKA-15951
Project: Kafka
Matthias J. Sax created KAFKA-15951:
---
Summary: MissingSourceTopicException should include topic names
Key: KAFKA-15951
URL: https://issues.apache.org/jira/browse/KAFKA-15951
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-15629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-15629.
-
Resolution: Fixed
> proposal to introduce IQv2 Query Types: TimestampedKeyQu
[
https://issues.apache.org/jira/browse/KAFKA-15629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-15629.
-
Resolution: Fixed
> proposal to introduce IQv2 Query Types: TimestampedKeyQu
[
https://issues.apache.org/jira/browse/KAFKA-15941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-15941:
Labels: flaky-test (was: )
> Flaky test: shouldRestoreNullRec
[
https://issues.apache.org/jira/browse/KAFKA-15941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-15941:
Component/s: streams
unit tests
> Flaky test: shouldRestoreNullRec
[
https://issues.apache.org/jira/browse/KAFKA-15944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-15944:
Component/s: unit tests
> Flaky test - verifyStore[cache=false, log=true, suppl
When you send an email to unsubscribe..., there should be a response
from the bot. Check your spam folder.
You need to ack the unsubscribe by replying the the response email the
bot sent.
HTH.
-Matthias
On 11/28/23 6:10 AM, Dasun Nirmitha wrote:
Hello Kafka devs,
I'm aware that it's a
[
https://issues.apache.org/jira/browse/KAFKA-15768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17790835#comment-17790835
]
Matthias J. Sax commented on KAFKA-15768:
-
Thanks for the details [~vvcephei]!
{quote}In other
[
https://issues.apache.org/jira/browse/KAFKA-15896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-15896:
Labels: flaky-test (was: )
> Flaky test: shouldQuerySpecificStalePartitionSto
[
https://issues.apache.org/jira/browse/KAFKA-15896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-15896:
Component/s: streams
unit tests
> Flaky t
[
https://issues.apache.org/jira/browse/KAFKA-8575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-8575:
---
Fix Version/s: 4.0.0
> Investigate removing EAGER protocol & cleaning up task sus
[
https://issues.apache.org/jira/browse/KAFKA-8088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-8088:
---
Fix Version/s: 4.0.0
> Deprecate `WindowStoreIterator` interf
[
https://issues.apache.org/jira/browse/KAFKA-12281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-12281:
Labels: beginner needs-kip newbie (was: needs-kip)
> Deprec
[
https://issues.apache.org/jira/browse/KAFKA-15768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-15768:
Description:
Calling `StateQueryResult#getOnlyPartitionResult` crashes with an incorrect
[
https://issues.apache.org/jira/browse/KAFKA-15768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-15768:
Description:
Calling `StateQueryResult#getOnlyPartitionResult` crashes with an incorrect
Thanks Sophie. Overall I agree with you.
I think 50% is too high as a general rule, and I believe something like
30% might be more appropriate (going lower, given the infrastructure at
hand might become too aggressive)?
The difficult part about a policy like this is, that we don't really
Matthias J. Sax wrote:
Adding an enum is a good idea!
Wondering if `UNORDERED` is the best name? Want to avoid bike shedding,
just asking.
We could also use `UNDEFINED` / `UNSPECIFIED` / `NONE` / `ANY` ?
In the end, the result _might_ be ordered, we just don't guarantee any
order.
-Matthias
returns an
Optional.
Cheers,
Alieh
On Mon, Nov 20, 2023 at 7:38 PM Matthias J. Sax wrote:
I think we should also discuss a little more about `validTo()` method?
Given that "latest" version does not have a valid-to TS, should we
change the return type to `Optional` and ret
+1 (binding)
On 11/20/23 1:42 PM, Jason Gustafson wrote:
+1 Thanks for the KIP!
On Mon, Nov 20, 2023 at 9:31 AM Jun Rao wrote:
Hi, Andrew,
Thanks for the KIP. +1
Jun
On Thu, Nov 16, 2023 at 9:12 AM Andrew Schofield <
andrew_schofield_j...@outlook.com> wrote:
Hi Apoorv,
Thanks for your
Adding an enum is a good idea!
Wondering if `UNORDERED` is the best name? Want to avoid bike shedding,
just asking.
We could also use `UNDEFINED` / `UNSPECIFIED` / `NONE` / `ANY` ?
In the end, the result _might_ be ordered, we just don't guarantee any
order.
-Matthias
On 11/20/23 9:17
cts of the KIP are quite clear now and we have come
to a consensus about them, I think it 's time to vote ;-)
I look forward to your votes. Thanks a lot.
Cheers,
Alieh
On Fri, Nov 17, 2023 at 2:27 AM Matthias J. Sax wrote:
Thanks, Alieh.
Overall SGTM. About `validTo` -- wondering if we should
Thanks for the KIP.
Given how `WindowRangeQuery` works right now, it's really time to
improve it.
1) Agree. It's not clear what will be added right now. I think we should
deprecate existing `getKey()` w/o an actually replacement? For
`getFromKey` and `getToKey` we should actually be
the no-order-guaranteed option does not cost us
anything and it keeps the IQv2 interface flexible. I assume we want to
drop the Evolving annotation at some point.
Sorry for not having brought this up in the discussion about KIP-985.
Best,
Bruno
On 11/15/23 6:56 AM, Matthias J. Sax wrote:
Just
301 - 400 of 11116 matches
Mail list logo
