Matthias J. Sax created KAFKA-17281:
---
Summary: Remove old PAPI methods
Key: KAFKA-17281
URL: https://issues.apache.org/jira/browse/KAFKA-17281
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-17280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-17280:
Description:
Existing handler got changed in 3.9, to have new `ErrorHandlerContext` input
Matthias J. Sax created KAFKA-17280:
---
Summary: Remove deprecated methods from
DeserializationExceptionHandler as ProductionExceptionHandler
Key: KAFKA-17280
URL: https://issues.apache.org/jira/browse/KAFKA
Matthias J. Sax created KAFKA-17280:
---
Summary: Remove deprecated methods from
DeserializationExceptionHandler as ProductionExceptionHandler
Key: KAFKA-17280
URL: https://issues.apache.org/jira/browse/KAFKA
[
https://issues.apache.org/jira/browse/KAFKA-17229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871515#comment-17871515
]
Matthias J. Sax commented on KAFKA-17229:
-
Thanks for clarification. This m
[
https://issues.apache.org/jira/browse/KAFKA-12828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-12828.
-
Resolution: Fixed
> Remove Deprecated methods under KeyQueryMetad
[
https://issues.apache.org/jira/browse/KAFKA-12828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-12828.
-
Resolution: Fixed
> Remove Deprecated methods under KeyQueryMetad
[
https://issues.apache.org/jira/browse/KAFKA-17229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871407#comment-17871407
]
Matthias J. Sax commented on KAFKA-17229:
-
{quote}a processor with a punctu
[
https://issues.apache.org/jira/browse/KAFKA-15896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-15896.
-
Resolution: Cannot Reproduce
> Flaky test: shouldQuerySpecificStalePartitionSto
[
https://issues.apache.org/jira/browse/KAFKA-15896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871402#comment-17871402
]
Matthias J. Sax commented on KAFKA-15896:
-
This test did not fail for mo
[
https://issues.apache.org/jira/browse/KAFKA-15896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-15896.
-
Resolution: Cannot Reproduce
> Flaky test: shouldQuerySpecificStalePartitionSto
[
https://issues.apache.org/jira/browse/KAFKA-12829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871126#comment-17871126
]
Matthias J. Sax commented on KAFKA-12829:
-
Thanks for the PR [~pegasas
[
https://issues.apache.org/jira/browse/KAFKA-12829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-12829:
---
Assignee: Junyao Huang
> Remove Deprecated methods can classes of old Proces
[
https://issues.apache.org/jira/browse/KAFKA-16336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871123#comment-17871123
]
Matthias J. Sax commented on KAFKA-16336:
-
Thanks [~frankvicky] – If [~kyrm
[
https://issues.apache.org/jira/browse/KAFKA-12830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871122#comment-17871122
]
Matthias J. Sax commented on KAFKA-12830:
-
No need to ask – feel free to
[
https://issues.apache.org/jira/browse/KAFKA-12824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871119#comment-17871119
]
Matthias J. Sax commented on KAFKA-12824:
-
Go ahead. All tasks for 4.0
[
https://issues.apache.org/jira/browse/KAFKA-12830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-12830:
---
Assignee: PoAn Yang
> Remove Deprecated constructor in TimeWindowedDeseriali
[
https://issues.apache.org/jira/browse/KAFKA-12832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871121#comment-17871121
]
Matthias J. Sax commented on KAFKA-12832:
-
Done. You can now also self-as
[
https://issues.apache.org/jira/browse/KAFKA-12832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-12832:
---
Assignee: 黃竣陽
> Remove Deprecated methods un
[
https://issues.apache.org/jira/browse/KAFKA-16328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871118#comment-17871118
]
Matthias J. Sax commented on KAFKA-16328:
-
Thanks for picking it up!
>
[
https://issues.apache.org/jira/browse/KAFKA-17253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17870785#comment-17870785
]
Matthias J. Sax commented on KAFKA-17253:
-
Sure. No need to asked :)
>
[
https://issues.apache.org/jira/browse/KAFKA-17253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-17253:
---
Assignee: TengYao Chi
> Remove leaking getter methods in Joined helper cl
[
https://issues.apache.org/jira/browse/KAFKA-17253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-17253:
Description:
The helper class `Joined` has four getter methods `gracePeriod
[
https://issues.apache.org/jira/browse/KAFKA-17253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-17253:
Description:
The helper class `Joined` has three getter methods `keySerde()`, `valueSerde
Matthias J. Sax created KAFKA-17253:
---
Summary: Remove leaking getter methods in Joined helper class
Key: KAFKA-17253
URL: https://issues.apache.org/jira/browse/KAFKA-17253
Project: Kafka
Matthias J. Sax created KAFKA-17253:
---
Summary: Remove leaking getter methods in Joined helper class
Key: KAFKA-17253
URL: https://issues.apache.org/jira/browse/KAFKA-17253
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-17251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-17251:
Description:
`KafkaStreams#cleanup()` method is designed to delete an instance local
[
https://issues.apache.org/jira/browse/KAFKA-17251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-17251:
Description:
`KafkaStreams#cleanup()` method is designed to delete an instance local
Matthias J. Sax created KAFKA-17251:
---
Summary: KafkaStreams.cleanup() semantics unclear
Key: KAFKA-17251
URL: https://issues.apache.org/jira/browse/KAFKA-17251
Project: Kafka
Issue Type
Matthias J. Sax created KAFKA-17251:
---
Summary: KafkaStreams.cleanup() semantics unclear
Key: KAFKA-17251
URL: https://issues.apache.org/jira/browse/KAFKA-17251
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-17248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-17248:
Labels: kip (was: need-kip)
> Extend KIP-714 to allow for registering additional metr
[
https://issues.apache.org/jira/browse/KAFKA-17248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-17248:
Component/s: admin
clients
consumer
[
https://issues.apache.org/jira/browse/KAFKA-17248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-17248:
Description:
Add new methods to the Admin, Consumer, and Producer interfaces and
[
https://issues.apache.org/jira/browse/KAFKA-17248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-17248:
Component/s: streams
> Extend KIP-714 to allow for registering additional metrics w
Thanks Loïc!
On 8/1/24 6:19 AM, Loic Greffier wrote:
Hi,
Last PR that completed KIP-1033 has been merged.
Thanks to all participants, for the guidance and the feedbacks!
Just letting you know about some decisions and changes made through the
different PRs that were not initially mentioned in
y raised the idea of barrier to entry regarding the template. I did
not state or even really imply that it should affect this initiative in
general. Please do not feel obligated to discuss that concept further if
we're all on the same page RE not adding to the template.
On Wed, Jul 31, 2024,
Hi,
thanks for starting this discussion. It's for sure useful.
I don't care too much about the naming personally, it just should be
well defined.
I agree to Josep, that I don't think we would need to change the KIP
template. A KIP is a design doc for the full feature, and should not
concern
[
https://issues.apache.org/jira/browse/KAFKA-12827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17870011#comment-17870011
]
Matthias J. Sax commented on KAFKA-12827:
-
Done. You can now also self-as
[
https://issues.apache.org/jira/browse/KAFKA-12827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-12827:
---
Assignee: Abhishek Giri
> Remove Deprecated method KafkaStre
[
https://issues.apache.org/jira/browse/KAFKA-12823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869803#comment-17869803
]
Matthias J. Sax commented on KAFKA-12823:
-
Done. You can now also self-as
[
https://issues.apache.org/jira/browse/KAFKA-12823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-12823:
---
Assignee: Arnav Dadarya
> Remove Deprecated method KStream#thro
[
https://issues.apache.org/jira/browse/KAFKA-16863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869792#comment-17869792
]
Matthias J. Sax commented on KAFKA-16863:
-
[~muralibasani] – `trunk` was bu
Hi,
Also a +1 (binging) from me.
I am closing this vote with the KIP being accepted with 4 binding +1s
from Sophie, Bill, Lucas, and myself.
Thanks a lot!
-Matthias
On 7/26/24 10:52 AM, Matthias J. Sax wrote:
I updated the KIP accordingly.
If there is no further follow usp, I'll
Thanks a lot for the KIP Ray!
It seems to be a good improvement to make using KS with Clojure more
seamless.
However, I am not 100% sure if all listed interfaces make sense?
(100) GlobalKTable: it's basically a sibling to `KStream`, and `KTable`
interfaces, but users would never implemented
Matthias J. Sax created KAFKA-17224:
---
Summary: Make ForeachProcessor internal
Key: KAFKA-17224
URL: https://issues.apache.org/jira/browse/KAFKA-17224
Project: Kafka
Issue Type: Improvement
Matthias J. Sax created KAFKA-17224:
---
Summary: Make ForeachProcessor internal
Key: KAFKA-17224
URL: https://issues.apache.org/jira/browse/KAFKA-17224
Project: Kafka
Issue Type: Improvement
ions
for now. I think we should focus on discussing its necessity with the
community. I'll let it sit for a few more days, and if there are no
objections, I will propose changes over the weekend and share them
here
again.
Regards,
Rich
On Thu, Jul 25, 2024 at 5:51 PM Matthias J. Sa
[
https://issues.apache.org/jira/browse/KAFKA-17216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869781#comment-17869781
]
Matthias J. Sax edited comment on KAFKA-17216 at 7/31/24 12:5
[
https://issues.apache.org/jira/browse/KAFKA-17216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869781#comment-17869781
]
Matthias J. Sax commented on KAFKA-17216:
-
Just saw this other comment:
[h
[
https://issues.apache.org/jira/browse/KAFKA-16332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869780#comment-17869780
]
Matthias J. Sax commented on KAFKA-16332:
-
Yes, feel free to pickup this ti
[
https://issues.apache.org/jira/browse/KAFKA-16508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869779#comment-17869779
]
Matthias J. Sax commented on KAFKA-16508:
-
Updated fix version to 4.0.
[
https://issues.apache.org/jira/browse/KAFKA-16508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16508:
Fix Version/s: 4.0.0
(was: 3.9.0)
> Infinite loop if output to
[
https://issues.apache.org/jira/browse/KAFKA-16336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869771#comment-17869771
]
Matthias J. Sax commented on KAFKA-16336:
-
[~kyrmar98] – The 3.9 release br
[
https://issues.apache.org/jira/browse/KAFKA-16333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869769#comment-17869769
]
Matthias J. Sax commented on KAFKA-16333:
-
[~muralibasani] – The 3.9 rel
[
https://issues.apache.org/jira/browse/KAFKA-16334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869770#comment-17869770
]
Matthias J. Sax commented on KAFKA-16334:
-
[~caioguedes] – The 3.9 rel
[
https://issues.apache.org/jira/browse/KAFKA-16329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869767#comment-17869767
]
Matthias J. Sax commented on KAFKA-16329:
-
[~muralibasani] – The 3.9 rel
[
https://issues.apache.org/jira/browse/KAFKA-16330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869768#comment-17869768
]
Matthias J. Sax commented on KAFKA-16330:
-
[~muralibasani] – The 3.9 rel
[
https://issues.apache.org/jira/browse/KAFKA-12831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869766#comment-17869766
]
Matthias J. Sax commented on KAFKA-12831:
-
[~vvakati] – The 3.9 release br
[
https://issues.apache.org/jira/browse/KAFKA-12829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869765#comment-17869765
]
Matthias J. Sax commented on KAFKA-12829:
-
[~pegasas] – The 3.9 release br
[
https://issues.apache.org/jira/browse/KAFKA-12823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869763#comment-17869763
]
Matthias J. Sax commented on KAFKA-12823:
-
[~ardada2468] – The 3.9 rel
[
https://issues.apache.org/jira/browse/KAFKA-12826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869764#comment-17869764
]
Matthias J. Sax commented on KAFKA-12826:
-
[~shiqin.lan] The 3.9 release br
[
https://issues.apache.org/jira/browse/KAFKA-12689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869762#comment-17869762
]
Matthias J. Sax commented on KAFKA-12689:
-
After some more discussio
[
https://issues.apache.org/jira/browse/KAFKA-12822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869761#comment-17869761
]
Matthias J. Sax commented on KAFKA-12822:
-
The 3.9 release branch was cut
[
https://issues.apache.org/jira/browse/KAFKA-16327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869760#comment-17869760
]
Matthias J. Sax commented on KAFKA-16327:
-
[~ksolves.kafka] – The 3.9 rel
[
https://issues.apache.org/jira/browse/KAFKA-17215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869759#comment-17869759
]
Matthias J. Sax commented on KAFKA-17215:
-
I cannot help with creati
[
https://issues.apache.org/jira/browse/KAFKA-17216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869758#comment-17869758
]
Matthias J. Sax commented on KAFKA-17216:
-
The only PR which comes to mind
[
https://issues.apache.org/jira/browse/KAFKA-17214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869756#comment-17869756
]
Matthias J. Sax commented on KAFKA-17214:
-
Thanks a ton [~jlprat]!
> Ad
[
https://issues.apache.org/jira/browse/KAFKA-17216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-17216:
Component/s: streams
> StreamsConfig STATE_DIR_CON
Thanks for clarifying Colin. So my assumptions were actually correct.
We have a lot of contributors waiting to pick-up 4.0 tickets, and I'll
go ahead a tell them that we are ready and they can start to pick them up.
Thanks.
-Matthias
On 7/30/24 3:51 PM, Colin McCabe wrote:
Hi Chia-Ping Tsa
Thanks Greg. Overall, this makes sense to me.
The only assumption on my side was, that we are actually pretty sure
that we will hit case (1) or (2)...
And I actually also thought, that completing the required KRaft work
would only take a few more weeks, and that is also why we have a 3.9
rel
--
Josep Prat
Open Source Engineering Director, Aiven
josep.p...@aiven.io | +491715557497 | aiven.io
Aiven Deutschland GmbH
Alexanderufer 3-7, 10117 Berlin
Geschäftsführer: Oskari Saarenmaa, Hannu Valtonen,
Anna Richardson, Kenneth Chen
Amtsgericht Charlottenburg, HRB 209739 B
On Tue, Jul 30, 2024, 18:
Thanks for cutting the release branch.
It's great to see `trunk` being bumped to 4.0-SNAPSHOT, and I wanted to
follow up on this:
We have a bunch of tickets that we can only ship with 4.0 release, and
these tickets were blocked so far. I wanted to get confirmation that we
will stick with 4.0
[
https://issues.apache.org/jira/browse/KAFKA-17214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869487#comment-17869487
]
Matthias J. Sax commented on KAFKA-17214:
-
As we already have a 3.9 branch
[
https://issues.apache.org/jira/browse/KAFKA-17214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-17214:
Component/s: clients
consumer
core
[
https://issues.apache.org/jira/browse/KAFKA-17215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-17215:
Description:
Kafka traditionally does not use a `get` prefix for getter methods. However
[
https://issues.apache.org/jira/browse/KAFKA-17215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-17215:
Description:
Kafka traditionally does not use a `get` prefix for getter methods. However
[
https://issues.apache.org/jira/browse/KAFKA-17215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-17215:
Description:
Kafka traditionally does not use a `get` prefix for getter methods. However
Matthias J. Sax created KAFKA-17215:
---
Summary: Remove get-prefix for all getters
Key: KAFKA-17215
URL: https://issues.apache.org/jira/browse/KAFKA-17215
Project: Kafka
Issue Type
Matthias J. Sax created KAFKA-17215:
---
Summary: Remove get-prefix for all getters
Key: KAFKA-17215
URL: https://issues.apache.org/jira/browse/KAFKA-17215
Project: Kafka
Issue Type
Thanks for the KIP Brenden.
+1 (binding)
On 7/26/24 1:16 AM, Andrew Schofield wrote:
HI Brenden,
Thanks for the KIP.
+1 (non-binding)
Thanks,
Andrew
On 25 Jul 2024, at 23:26, Apoorv Mittal wrote:
Hi Brenden,
The metrics look good. Thanks for the KIP.
+1 (Non-Binding)
Regards,
Apoorv Mit
I updated the KIP accordingly.
If there is no further follow usp, I'll close the vote shortly.
-Matthias
On 7/21/24 10:24 PM, Matthias J. Sax wrote:
I just realized that both
- ValueTransformerWithKey and
- ValueTransfromerWithKeySupplier
are still used by non-deprecated `K
[
https://issues.apache.org/jira/browse/KAFKA-17112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-17112:
---
Assignee: Ao Li
> StreamThread shutdown calls completeShutdown only in CREA
[
https://issues.apache.org/jira/browse/KAFKA-17204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-17204.
-
Fix Version/s: 3.9.0
Resolution: Fixed
[
https://issues.apache.org/jira/browse/KAFKA-17204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-17204.
-
Fix Version/s: 3.9.0
Resolution: Fixed
[
https://issues.apache.org/jira/browse/KAFKA-17203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-17203:
---
Assignee: PoAn Yang
> StreamThread leaking producer instan
[
https://issues.apache.org/jira/browse/KAFKA-17203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868995#comment-17868995
]
Matthias J. Sax commented on KAFKA-17203:
-
Thanks for your interest! Go fo
[
https://issues.apache.org/jira/browse/KAFKA-17202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-17202:
---
Assignee: TengYao Chi
[
https://issues.apache.org/jira/browse/KAFKA-17202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868993#comment-17868993
]
Matthias J. Sax commented on KAFKA-17202:
-
Thanks for your interest to pic
Rich,
thanks for resurrecting this KIP. I was not part of the original
discussion back in the day, but personally agree with your assessment
that making headers available in the callbacks would make developer's
life much simpler.
For the KIP itself, starting with "Public Interface" section,
Not 100% sure if librdkafka provides the exact some semantics as the
Kafka Java producer (but I believe it does for this case; but might be
worth to check the docs?).
If `send()` gives an error back, ordering would not be guaranteed any
longer if the retry happens at the application level. Ord
[
https://issues.apache.org/jira/browse/KAFKA-16263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868808#comment-17868808
]
Matthias J. Sax commented on KAFKA-16263:
-
It seems [~brandboat] and [~
[
https://issues.apache.org/jira/browse/KAFKA-17054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-17054.
-
Resolution: Invalid
> test
>
>
> Key:
[
https://issues.apache.org/jira/browse/KAFKA-13501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868807#comment-17868807
]
Matthias J. Sax commented on KAFKA-13501:
-
It's some not so easy to
[
https://issues.apache.org/jira/browse/KAFKA-17054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-17054.
-
Resolution: Invalid
> test
>
>
> Key:
transaction aborts.
If someone uses the method, or doesn't use it, they aren't put at risk of
compromising their delivery guarantees unexpectedly.
Thanks,
Greg
[1]
https://cwiki.apache.org/confluence/display/KAFKA/KIP-98+-+Exactly+Once+Delivery+and+Transactional+Messaging
[2] https:/
[
https://issues.apache.org/jira/browse/KAFKA-13501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867880#comment-17867880
]
Matthias J. Sax commented on KAFKA-13501:
-
I don't think state upda
Matthias J. Sax wrote:
I just realized, that there is more interfaces with a similar situation:
- Transformer
- TransformerSupplier
- ValueTransformer
- ValueTransfomerSupplier
- ValueTransformerWithKey
- ValueTransfromerWithKeySupplier
Given that `KStream#transform` and `KStream#transformValues
Matthias J. Sax created KAFKA-17178:
---
Summary: Update KTable.transformValues to new Processor API
Key: KAFKA-17178
URL: https://issues.apache.org/jira/browse/KAFKA-17178
Project: Kafka
Matthias J. Sax created KAFKA-17178:
---
Summary: Update KTable.transformValues to new Processor API
Key: KAFKA-17178
URL: https://issues.apache.org/jira/browse/KAFKA-17178
Project: Kafka
be sufficient to prevent RTLEs.
This is the sort of estimation that I would expect application developers
could implement, without knowing the exact serialization and protocol
overhead. This could prevent user-originated oversize records from making
it to the producer.
Thanks,
Greg
On Mon, Jul 1
201 - 300 of 2823 matches
Mail list logo
