[
https://issues.apache.org/jira/browse/KAFKA-14957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-14957.
-
Fix Version/s: 3.8.0
Resolution: Fixed
> Default value for state.
[
https://issues.apache.org/jira/browse/KAFKA-14957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-14957.
-
Fix Version/s: 3.8.0
Resolution: Fixed
> Default value for state.
[
https://issues.apache.org/jira/browse/KAFKA-16241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17816238#comment-17816238
]
Matthias J. Sax commented on KAFKA-16241:
-
{quote} Detected out-of-order KTable update
{quote}
I
[
https://issues.apache.org/jira/browse/KAFKA-16241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16241:
Affects Version/s: 3.6.1
> Kafka Streams hits IllegalStateException trying to recy
[
https://issues.apache.org/jira/browse/KAFKA-16241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16241:
Attachment: streams-3.zip
> Kafka Streams hits IllegalStateException trying to recy
[
https://issues.apache.org/jira/browse/KAFKA-16241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16241:
Attachment: streams-2.zip
> Kafka Streams hits IllegalStateException trying to recy
[
https://issues.apache.org/jira/browse/KAFKA-16241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16241:
Attachment: streams-1.zip
> Kafka Streams hits IllegalStateException trying to recy
Matthias J. Sax created KAFKA-16241:
---
Summary: Kafka Streams hits IllegalStateException trying to
recycle a task
Key: KAFKA-16241
URL: https://issues.apache.org/jira/browse/KAFKA-16241
Project
Matthias J. Sax created KAFKA-16241:
---
Summary: Kafka Streams hits IllegalStateException trying to
recycle a task
Key: KAFKA-16241
URL: https://issues.apache.org/jira/browse/KAFKA-16241
Project
Still need to digest the KIP, but one thing coming to mind:
Instead of requiring existing interfaces to implement `Closable`, would
it make sense to make `Monitorable extends Closable` to sidestep this issue?
-Matthias
On 1/25/24 9:03 AM, Mickael Maison wrote:
Hi Luke,
The reason vary for
31, 2024 at 9:20 PM Matthias J. Sax
wrote:
Thanks for raising this. The `kafka-streams-scala` module seems
to
be an
important feature for Kafka Streams and I am generally in favor
of
your
proposal to add Scala 3 support. However, I am personally no
Scala
person and it sounds like quite som
[
https://issues.apache.org/jira/browse/KAFKA-16237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16237:
Labels: needs-kip (was: )
> Kafka-Streams-Scala for Scal
[
https://issues.apache.org/jira/browse/KAFKA-16237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815763#comment-17815763
]
Matthias J. Sax commented on KAFKA-16237:
-
Thanks for filing the ticket and working on a PR. – I
[
https://issues.apache.org/jira/browse/KAFKA-16237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-16237:
---
Assignee: Matthias Berndt
> Kafka-Streams-Scala for Scal
[
https://issues.apache.org/jira/browse/KAFKA-16236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-16236.
-
Resolution: Duplicate
Thanks for filing this tickets. It's duplicate of
https
[
https://issues.apache.org/jira/browse/KAFKA-16236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815760#comment-17815760
]
Matthias J. Sax edited comment on KAFKA-16236 at 2/8/24 4:52 PM:
-
Thanks
[
https://issues.apache.org/jira/browse/KAFKA-16236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-16236.
-
Resolution: Duplicate
Thanks for filing this tickets. It's duplicate of
https
[
https://issues.apache.org/jira/browse/KAFKA-14747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815759#comment-17815759
]
Matthias J. Sax commented on KAFKA-14747:
-
It seems [~kma] did never find time to pick it up
regate person. There
are 14 sub topologies... - measuring the e2e latency shows values
around 600ms which seems rather high to me. Does that sound crazy? ;)
Best wishes
Karsten
Am Do., 1. Feb. 2024 um 19:02 Uhr schrieb Matthias J. Sax :
I see. You need to ensure that you get _all_ Person.
For this c
[
https://issues.apache.org/jira/browse/KAFKA-13292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815404#comment-17815404
]
Matthias J. Sax commented on KAFKA-13292:
-
Sounds like a question about Spring... For a plain
[
https://issues.apache.org/jira/browse/KAFKA-12823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815089#comment-17815089
]
Matthias J. Sax commented on KAFKA-12823:
-
Look for ticket labeled "beginner"
[
https://issues.apache.org/jira/browse/KAFKA-14567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-14567:
Description:
Running a Kafka Streams application with EOS-v2.
We first see
[
https://issues.apache.org/jira/browse/KAFKA-16221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-16221.
-
Resolution: Fixed
> IllegalStateException from Produ
[
https://issues.apache.org/jira/browse/KAFKA-16221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17814437#comment-17814437
]
Matthias J. Sax commented on KAFKA-16221:
-
Marking this as resolved to 3.7 for now – we might
[
https://issues.apache.org/jira/browse/KAFKA-16221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-16221.
-
Resolution: Fixed
> IllegalStateException from Produ
[
https://issues.apache.org/jira/browse/KAFKA-16221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16221:
Fix Version/s: 3.7.0
> IllegalStateException from Produ
[
https://issues.apache.org/jira/browse/KAFKA-16221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16221:
Description:
https://issues.apache.org/jira/browse/KAFKA-14831 fixed a producer bug about
[
https://issues.apache.org/jira/browse/KAFKA-16221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16221:
Description:
https://issues.apache.org/jira/browse/KAFKA-14831 fixed a producer bug about
[
https://issues.apache.org/jira/browse/KAFKA-16221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16221:
Description:
https://issues.apache.org/jira/browse/KAFKA-14831 fixed a producer bug about
Matthias J. Sax created KAFKA-16221:
---
Summary: IllegalStateException from Producer
Key: KAFKA-16221
URL: https://issues.apache.org/jira/browse/KAFKA-16221
Project: Kafka
Issue Type: Bug
Matthias J. Sax created KAFKA-16221:
---
Summary: IllegalStateException from Producer
Key: KAFKA-16221
URL: https://issues.apache.org/jira/browse/KAFKA-16221
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-16217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16217:
Component/s: producer
> Transactional producer stuck in IllegalStateException dur
nd then
using that for three independent re-key-operations is not allowed.
Best wishes,
Karsten
Am Do., 1. Feb. 2024 um 02:16 Uhr schrieb Matthias J. Sax :
Thanks for the details. This does make sense.
So it seems you can read all topic as table (ie, builder.table("topic")
-- no need to so `b
I, as I've specified no extra configuration
for them.
Best wishes,
Karsten
Am Di., 30. Jan. 2024 um 20:03 Uhr schrieb Matthias J. Sax :
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?
Ing
[
https://issues.apache.org/jira/browse/KAFKA-12549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812993#comment-17812993
]
Matthias J. Sax commented on KAFKA-12549:
-
[~high.lee] – this ticket is superceded by
https
Thanks for raising this. The `kafka-streams-scala` module seems to be an
important feature for Kafka Streams and I am generally in favor of your
proposal to add Scala 3 support. However, I am personally no Scala
person and it sounds like quite some overhead.
If you are willing to drive and
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
301 - 400 of 11152 matches
Mail list logo
