Matthias J. Sax created KAFKA-16332:
---
Summary: Remove Deprecated builder methods for
Time/Session/Join/SlidingWindows
Key: KAFKA-16332
URL: https://issues.apache.org/jira/browse/KAFKA-16332
Project
Matthias J. Sax created KAFKA-16332:
---
Summary: Remove Deprecated builder methods for
Time/Session/Join/SlidingWindows
Key: KAFKA-16332
URL: https://issues.apache.org/jira/browse/KAFKA-16332
Project
[
https://issues.apache.org/jira/browse/KAFKA-16332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16332:
Fix Version/s: 4.0.0
> Remove Deprecated builder methods for Time/Session/J
[
https://issues.apache.org/jira/browse/KAFKA-16331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17823337#comment-17823337
]
Matthias J. Sax commented on KAFKA-16331:
-
While I think we should for sure remove Producer
Matthias J. Sax created KAFKA-16331:
---
Summary: Remove Deprecated EOSv1
Key: KAFKA-16331
URL: https://issues.apache.org/jira/browse/KAFKA-16331
Project: Kafka
Issue Type: Sub-task
Matthias J. Sax created KAFKA-16331:
---
Summary: Remove Deprecated EOSv1
Key: KAFKA-16331
URL: https://issues.apache.org/jira/browse/KAFKA-16331
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-16328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16328:
Description:
* #retries was deprecated in AK 2.7 – already unused – via
[https
[
https://issues.apache.org/jira/browse/KAFKA-16328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16328:
Summary: Remove Deprecated config from StreamsConfig (was: Remove
Deprecated config
[
https://issues.apache.org/jira/browse/KAFKA-16330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16330:
Description:
Cf [https://cwiki.apache.org/confluence/pages/viewpage.action?pageId
[
https://issues.apache.org/jira/browse/KAFKA-16329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16329:
Description:
Deprecated in AK 3.0 via
[https://cwiki.apache.org/confluence/display/KAFKA
Matthias J. Sax created KAFKA-16330:
---
Summary: Remove Deprecated methods/variables from TaskId
Key: KAFKA-16330
URL: https://issues.apache.org/jira/browse/KAFKA-16330
Project: Kafka
Issue
Matthias J. Sax created KAFKA-16330:
---
Summary: Remove Deprecated methods/variables from TaskId
Key: KAFKA-16330
URL: https://issues.apache.org/jira/browse/KAFKA-16330
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-16329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16329:
Description:
Deprecated in AK 3.0 via
[https://cwiki.apache.org/confluence/display/KAFKA
Matthias J. Sax created KAFKA-16329:
---
Summary: Remove Deprecated Task/ThreadMetadata classes and related
methods
Key: KAFKA-16329
URL: https://issues.apache.org/jira/browse/KAFKA-16329
Project
Matthias J. Sax created KAFKA-16329:
---
Summary: Remove Deprecated Task/ThreadMetadata classes and related
methods
Key: KAFKA-16329
URL: https://issues.apache.org/jira/browse/KAFKA-16329
Project
[
https://issues.apache.org/jira/browse/KAFKA-12829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-12829:
Description:
The following methods were deprecated in version 2.7
[
https://issues.apache.org/jira/browse/KAFKA-12829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-12829:
Description:
The following methods were deprecated in version 2.7
[
https://issues.apache.org/jira/browse/KAFKA-12831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-12831.
-
Resolution: Fixed
> Remove Deprecated method StateStore#i
[
https://issues.apache.org/jira/browse/KAFKA-12831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-12831.
-
Resolution: Fixed
> Remove Deprecated method StateStore#i
[
https://issues.apache.org/jira/browse/KAFKA-12829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-12829:
Description:
The following methods were deprecated in version 2.7
[
https://issues.apache.org/jira/browse/KAFKA-12825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-12825.
-
Resolution: Fixed
> Remove Deprecated method StreamsBuilder#addGlobalSt
[
https://issues.apache.org/jira/browse/KAFKA-12825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-12825.
-
Resolution: Fixed
> Remove Deprecated method StreamsBuilder#addGlobalSt
[
https://issues.apache.org/jira/browse/KAFKA-12829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-12829:
Summary: Remove Deprecated methods can classes of old Processor API (was:
Remove
[
https://issues.apache.org/jira/browse/KAFKA-16328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16328:
Summary: Remove Deprecated config StreamsConfig#retries (was: Remove
deprecated config
Matthias J. Sax created KAFKA-16328:
---
Summary: Remove deprecated config StreamsConfig#retries
Key: KAFKA-16328
URL: https://issues.apache.org/jira/browse/KAFKA-16328
Project: Kafka
Issue
Matthias J. Sax created KAFKA-16328:
---
Summary: Remove deprecated config StreamsConfig#retries
Key: KAFKA-16328
URL: https://issues.apache.org/jira/browse/KAFKA-16328
Project: Kafka
Issue
Matthias J. Sax created KAFKA-16327:
---
Summary: Remove Deprecated variable
StreamsConfig#TOPOLOGY_OPTIMIZATION
Key: KAFKA-16327
URL: https://issues.apache.org/jira/browse/KAFKA-16327
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-16327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16327:
Priority: Blocker (was: Minor)
> Remove Deprecated variable StreamsCon
[
https://issues.apache.org/jira/browse/KAFKA-16327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16327:
Fix Version/s: 4.0.0
> Remove Deprecated variable StreamsConfig#TOPOLOGY_OPTIMIZAT
Matthias J. Sax created KAFKA-16327:
---
Summary: Remove Deprecated variable
StreamsConfig#TOPOLOGY_OPTIMIZATION
Key: KAFKA-16327
URL: https://issues.apache.org/jira/browse/KAFKA-16327
Project: Kafka
Thanks for the KIP Walker.
Fixing this issue, and providing users some flexibility to opt-in/out on
"restore reprocessing" is certainly a good improvement.
From an API design POV, I like the idea to not require passing in a
ProcessorSupplier to begin with. Given the current implementation of
?
-Matthias
On 2/21/24 2:41 PM, Matthias J. Sax wrote:
Thanks for the KIP. Sounds like a nice cleanup.
window.size.ms is not a true KafkaStreams config, and results in an
error when set from a KStreams application
What error?
Given that the configs is used by `TimeWindowedDeserializer` I am
[
https://issues.apache.org/jira/browse/KAFKA-15797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-15797:
---
Assignee: Matthias J. Sax
> Flaky t
[
https://issues.apache.org/jira/browse/KAFKA-16316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16316:
Labels: needs-kip (was: )
> Make the restore behavior of GlobalKTables with cus
[
https://issues.apache.org/jira/browse/KAFKA-9062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17820819#comment-17820819
]
Matthias J. Sax commented on KAFKA-9062:
Given that bulk loading was disabled, should we close
To subscribe, please follow instructions from the webpage
https://kafka.apache.org/contact
-Matthias
On 2/23/24 1:15 AM, kashi mori wrote:
Hi, please add my email to the mailin list
To subscribe, please follow instructions from the webpage
https://kafka.apache.org/contact
-Matthias
On 2/23/24 1:15 AM, kashi mori wrote:
Hi, please add my email to the mailin list
[
https://issues.apache.org/jira/browse/KAFKA-12549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-12549.
-
Resolution: Duplicate
Closing this ticket in favor of K14412.
> Allow state sto
[
https://issues.apache.org/jira/browse/KAFKA-12549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-12549.
-
Resolution: Duplicate
Closing this ticket in favor of K14412.
> Allow state sto
To close the loop on this thread. KIP-892 was accepted and is currently
implemented. Thus I'll go a head and mark this KIP a discarded.
Thanks a lot Alex for spending so much time on this very important
feature! Without your ground work, we would not have KIP-892 and your
contributions are
[
https://issues.apache.org/jira/browse/KAFKA-16302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16302:
Component/s: streams
unit tests
> Builds failing due to streams t
[
https://issues.apache.org/jira/browse/KAFKA-16302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-16302:
---
Assignee: Justine Olshan
> Builds failing due to streams test execution failu
Thanks for the KIP. Sounds like a nice cleanup.
window.size.ms is not a true KafkaStreams config, and results in an error when
set from a KStreams application
What error?
Given that the configs is used by `TimeWindowedDeserializer` I am
wondering if we should additionally add
public
Filed https://issues.apache.org/jira/browse/KAFKA-16295
Also, for global store support, we do have a ticket already:
https://issues.apache.org/jira/browse/KAFKA-13523
It's actually a little bit more involved due to position tracking... I
guess we might need a KIP to fix this.
And yes: if
Matthias J. Sax created KAFKA-16295:
---
Summary: Align RocksDB and in-memory store inti() sequence
Key: KAFKA-16295
URL: https://issues.apache.org/jira/browse/KAFKA-16295
Project: Kafka
Matthias J. Sax created KAFKA-16295:
---
Summary: Align RocksDB and in-memory store inti() sequence
Key: KAFKA-16295
URL: https://issues.apache.org/jira/browse/KAFKA-16295
Project: Kafka
+1 (binding)
On 2/20/24 2:55 AM, Manikumar wrote:
+1 (binding).
Thanks for the KIP.
Manikumar
On Tue, Feb 20, 2024 at 2:31 PM Andrew Schofield <
andrew_schofield_j...@outlook.com> wrote:
Hi Apoorv,
Thanks for the KIP.
+1 (non-binding)
Thanks,
Andrew
On 19 Feb 2024, at 22:31, Apoorv
[
https://issues.apache.org/jira/browse/KAFKA-16284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16284:
Affects Version/s: 3.8.0
> Performance regression in Rock
Matthias J. Sax created KAFKA-16279:
---
Summary: Avoid leaking abstractions of `StateStore`
Key: KAFKA-16279
URL: https://issues.apache.org/jira/browse/KAFKA-16279
Project: Kafka
Issue Type
Matthias J. Sax created KAFKA-16279:
---
Summary: Avoid leaking abstractions of `StateStore`
Key: KAFKA-16279
URL: https://issues.apache.org/jira/browse/KAFKA-16279
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-14049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-14049:
Fix Version/s: 3.7.0
> Relax Non Null Requirement for KStreamGlobalKTable Left J
[
https://issues.apache.org/jira/browse/KAFKA-15143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-15143:
Labels: needs-kip (was: )
> MockFixedKeyProcessorContext is missing from test-ut
[
https://issues.apache.org/jira/browse/KAFKA-15143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-15143:
---
Assignee: Shashwat Pandey
> MockFixedKeyProcessorContext is missing from t
Thanks for the KIP. Seems there is not much we need to discuss about it.
Feel free to start a VOTE.
-Matthias
On 2/15/24 7:24 AM, Manikumar wrote:
LGTM, Thanks for the KIP.
On Thu, Feb 15, 2024 at 8:50 PM Doğuşcan Namal
wrote:
LGTM thanks for the KIP.
+1(non-binding)
On Wed, 14 Feb 2024
Matthias J. Sax created KAFKA-16263:
---
Summary: Add Kafka Streams docs about available listeners/callback
Key: KAFKA-16263
URL: https://issues.apache.org/jira/browse/KAFKA-16263
Project: Kafka
Matthias J. Sax created KAFKA-16263:
---
Summary: Add Kafka Streams docs about available listeners/callback
Key: KAFKA-16263
URL: https://issues.apache.org/jira/browse/KAFKA-16263
Project: Kafka
Matthias J. Sax created KAFKA-16262:
---
Summary: Add IQv2 to Kafka Streams documentation
Key: KAFKA-16262
URL: https://issues.apache.org/jira/browse/KAFKA-16262
Project: Kafka
Issue Type
Matthias J. Sax created KAFKA-16262:
---
Summary: Add IQv2 to Kafka Streams documentation
Key: KAFKA-16262
URL: https://issues.apache.org/jira/browse/KAFKA-16262
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-12317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17817833#comment-17817833
]
Matthias J. Sax commented on KAFKA-12317:
-
[~aki] – I was just looking into
[https
[
https://issues.apache.org/jira/browse/KAFKA-14049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17817827#comment-17817827
]
Matthias J. Sax commented on KAFKA-14049:
-
[~aki] does KIP-962 cover this ticket?
> Relax
[
https://issues.apache.org/jira/browse/KAFKA-16260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16260:
Component/s: streams
> Remove window.size.ms from StreamsCon
[
https://issues.apache.org/jira/browse/KAFKA-16260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16260:
Labels: needs-kip (was: )
> Remove window.size.ms from StreamsCon
[
https://issues.apache.org/jira/browse/KAFKA-16260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-16260:
---
Assignee: Lucia Cerchie
> Remove window.size.ms from StreamsCon
https://cwiki.apache.org/confluence/display/KAFKA/Time+Based+Release+Plan#TimeBasedReleasePlan-WhatIsOurEOLPolicy?
On 2/11/24 8:08 PM, Sahil Sharma D wrote:
Hi team,
Can you please share the EOS date for Kafka Version 3.5.1?
Regards,
Sahil
[
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
201 - 300 of 11116 matches
Mail list logo
