Re: [VOTE] KIP-997: Partition-Level Throughput Metrics

2023-11-16 Thread Matthias J. Sax
This is KIP-977, right? Not as the subject says. Guess we won't be able to fix this now. Hope it does not cause confusion down the line... -Matthias On 11/16/23 4:43 AM, Kamal Chandraprakash wrote: +1 (non-binding). Thanks for the KIP! On Thu, Nov 16, 2023 at 9:00 AM Satish Duggana

[jira] [Resolved] (KAFKA-15346) Single-Key_single-timestamp IQs with versioned state stores

2023-11-15 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-15346. - Fix Version/s: 3.7.0 Resolution: Fixed > Single-Key_single-timestamp

[jira] [Resolved] (KAFKA-15346) Single-Key_single-timestamp IQs with versioned state stores

2023-11-15 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-15346. - Fix Version/s: 3.7.0 Resolution: Fixed > Single-Key_single-timestamp

[jira] [Commented] (KAFKA-15834) Subscribing to non-existent topic blocks StreamThread from stopping

2023-11-15 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786564#comment-17786564 ] Matthias J. Sax commented on KAFKA-15834: - Thank for reporting and such a detailed analysis

Re: [DISCUSS] Should we continue to merge without a green build? No!

2023-11-14 Thread Matthias J. Sax
and it has never worked. I think we should try something different. When it comes to marking flaky tests as release blockers, I don't think this should be done as a general rule. We should instead assess on a case by case basis, same way we do it for bugs. Ismael On Tue, Nov 14, 2023 at 5:02 PM

Re: [DISCUSS] KIP-968: Support single-key_multi-timestamp interactive queries (IQv2) for versioned state stores

2023-11-14 Thread Matthias J. Sax
his API is better compared with being consistent with "WindowKeyQuery"? 3. I agree with Matthias that naming is always tricky, and I also tend to be consistent with what we already have (even if in retro it may not be the best idea :P and if that was really becoming a complaint, we would change i

Re: [DISCUSS] Should we continue to merge without a green build? No!

2023-11-14 Thread Matthias J. Sax
Thanks for starting this discussion David! I totally agree to "no"! I think there is no excuse whatsoever for merging PRs with compilation errors (except an honest mistake for conflicting PRs that got merged interleaved). -- Every committer must(!) check the Jenkins status before merging to

[jira] [Updated] (KAFKA-15828) Protect clients from broker hostname reuse

2023-11-14 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-15828: Labels: needs-kip (was: ) > Protect clients from broker hostname re

[jira] [Updated] (KAFKA-15828) Protect clients from broker hostname reuse

2023-11-14 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-15828: Component/s: clients consumer producer > Prot

[jira] [Commented] (KAFKA-14419) Failed SyncGroup leading to partitions lost due to processing during rebalances

2023-11-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17783897#comment-17783897 ] Matthias J. Sax commented on KAFKA-14419: - [~Carlstedt] – did not look into too many details

Re: [VOTE] KIP-998: Give ProducerConfig(props, doLog) constructor protected access

2023-11-07 Thread Matthias J. Sax
very, very ugly in my opinion). It will be helpful to end-users as well as plugin authors -- maybe people want this. And it doesn't require the subclassing hack to get access to it. best, Colin On Fri, Nov 3, 2023, at 17:06, Matthias J. Sax wrote: Sophie reads my mind well, but I also won't objec

[jira] [Commented] (KAFKA-13627) Topology changes shouldn't require a full reset of local state

2023-11-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17783894#comment-17783894 ] Matthias J. Sax commented on KAFKA-13627: - As you pointed out, the KIP did not make progress

[jira] [Updated] (KAFKA-15797) Flaky test EosV2UpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosV2[true]

2023-11-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-15797: Component/s: streams unit tests > Flaky t

[jira] [Updated] (KAFKA-15798) Flaky Test NamedTopologyIntegrationTest.shouldAddAndRemoveNamedTopologiesBeforeStartingAndRouteQueriesToCorrectTopology()

2023-11-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-15798: Component/s: streams unit tests > Flaky T

[jira] [Updated] (KAFKA-15792) Kafka Streams stuck partition fixed after restarting the process

2023-11-06 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-15792: Issue Type: Bug (was: New Feature) > Kafka Streams stuck partition fixed af

[jira] [Comment Edited] (KAFKA-15792) Kafka Streams stuck partition fixed after restarting the process

2023-11-06 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17783114#comment-17783114 ] Matthias J. Sax edited comment on KAFKA-15792 at 11/6/23 5:04 PM: -- Can

[jira] [Comment Edited] (KAFKA-15792) Kafka Streams stuck partition fixed after restarting the process

2023-11-06 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17783114#comment-17783114 ] Matthias J. Sax edited comment on KAFKA-15792 at 11/6/23 5:04 PM: -- Can

[jira] [Comment Edited] (KAFKA-15792) Kafka Streams stuck partition fixed after restarting the process

2023-11-06 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17783114#comment-17783114 ] Matthias J. Sax edited comment on KAFKA-15792 at 11/6/23 5:03 PM: -- Can

Re: [DISCUSS] KIP-969: Support range interactive queries for versioned state stores

2023-11-03 Thread Matthias J. Sax
very important point. How can a user     retrieve the latest value? We have the same issue with kip-968 as well.     Asking a user to call `toTime(max)` violates the API design rules, as you     mentioned. So I think we must have a `latest()` method for both KIP-968 and     KIP-969. What do you th

Re: [VOTE] KIP-992 Proposal to introduce IQv2 Query Types: TimestampedKeyQuery and TimestampedRangeQuery

2023-11-03 Thread Matthias J. Sax
Thanks for the KIP. +1 (binding) -Matthias On 11/3/23 6:08 AM, Lucas Brutschy wrote: Hi Hanyu, Thanks for the KIP! +1 (binding) Cheers Lucas On Thu, Nov 2, 2023 at 10:19 PM Hao Li wrote: Hi Hanyu, Thanks for the KIP! +1 (non-binding) Hao On Thu, Nov 2, 2023 at 1:29 PM Bill Bejeck

Re: [VOTE] KIP-998: Give ProducerConfig(props, doLog) constructor protected access

2023-11-03 Thread Matthias J. Sax
ong to require inheritance for this and we already have a public constructor. I would make both of them public. Ismael On Fri, Nov 3, 2023 at 10:47 AM Matthias J. Sax wrote: +1 (binding) About "why not public" question: I think we need to distinguish between "end users" w

Re: [DISCUSS] KIP-954: expand default DSL store configuration to custom types

2023-11-03 Thread Matthias J. Sax
, but hopefully you have no objections to the goal! On Thu, Nov 2, 2023 at 8:44 PM Matthias J. Sax wrote: Almog, can you explain how you intent to implement this change? It's not clear to me, how we could do this? When we call `StreasmBuilder.build()` it will give us a already fully wired

Re: [VOTE] KIP-998: Give ProducerConfig(props, doLog) constructor protected access

2023-11-03 Thread Matthias J. Sax
+1 (binding) About "why not public" question: I think we need to distinguish between "end users" who create a producer instance, and "external parties" that might implement their own `Producer` (or wrap/extend `KafkaProducer`). In the end, I would not expect an "end user" to actually call

Re: [DISCUSS] Apache Kafka 3.5.2 release

2023-11-03 Thread Matthias J. Sax
J. Sax wrote: Thanks for the info Luke. We did backport all but one PR in the mean time. The missing PR is a RocksDB version bump. We want to consider it for 3.5.2, because it addresses a CVE. Cf https://github.com/apache/kafka/pull/14216 However, RocksDB versions bumps are a little bit more

Re: [DISCUSS] KIP-954: expand default DSL store configuration to custom types

2023-11-02 Thread Matthias J. Sax
sume it's a fully qualified class name and try to instantiate it? Note that there is no functionality for this kind of thing in AbstractConfig (it's either a String validated enum or a class) so this would be a departure from convention. Again, I'm happy to implement that if

[jira] [Resolved] (KAFKA-15669) Implement telemetry naming strategy

2023-11-01 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-15669. - Fix Version/s: 3.7.0 Resolution: Fixed > Implement telemetry naming strat

[jira] [Resolved] (KAFKA-15669) Implement telemetry naming strategy

2023-11-01 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-15669. - Fix Version/s: 3.7.0 Resolution: Fixed > Implement telemetry naming strat

[jira] [Resolved] (KAFKA-15668) Add Opentelemetry Proto library with shadowed classes

2023-11-01 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-15668. - Fix Version/s: 3.7.0 Resolution: Fixed > Add Opentelemetry Proto libr

[jira] [Resolved] (KAFKA-15668) Add Opentelemetry Proto library with shadowed classes

2023-11-01 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-15668. - Fix Version/s: 3.7.0 Resolution: Fixed > Add Opentelemetry Proto libr

[jira] [Assigned] (KAFKA-15765) Remove task level metric "commit-latency"

2023-11-01 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-15765: --- Assignee: Bruno Cadonna > Remove task level metric "commit

[jira] [Commented] (KAFKA-14419) Failed SyncGroup leading to partitions lost due to processing during rebalances

2023-11-01 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17781946#comment-17781946 ] Matthias J. Sax commented on KAFKA-14419: - [~kirktrue] [~pnee] – will the new consumer threading

[jira] [Commented] (KAFKA-15602) Breaking change in 3.4.0 ByteBufferSerializer

2023-11-01 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17781935#comment-17781935 ] Matthias J. Sax commented on KAFKA-15602: - [~luke.kirby] – it seems unlikely

[jira] [Updated] (KAFKA-15770) org.apache.kafka.streams.integration.ConsistencyVectorIntegrationTest.shouldHaveSamePositionBoundActiveAndStandBy is flaky

2023-11-01 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-15770: Component/s: unit tests

Re: ACCESS to Apache Pony Mail

2023-10-31 Thread Matthias J. Sax
Only committers can login using their ASF account. -Matthias On 10/30/23 10:19 PM, Arpit Goyal wrote: Hi Can anyone help me provide access to Apache Pony Mail. I tried login using the jira credential but it didn't work. Thanks and Regards Arpit Goyal 8861094754

[jira] [Updated] (KAFKA-15768) StateQueryResult#getOnlyPartitionResult should not throw for FailedQueryResult

2023-10-31 Thread Matthias J. Sax (Jira)
[ 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

[jira] [Created] (KAFKA-15768) StateQueryResult#getOnlyPartitionResult should not throw for FailedQueryResult

2023-10-31 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-15768: --- Summary: StateQueryResult#getOnlyPartitionResult should not throw for FailedQueryResult Key: KAFKA-15768 URL: https://issues.apache.org/jira/browse/KAFKA-15768

[jira] [Created] (KAFKA-15768) StateQueryResult#getOnlyPartitionResult should not throw for FailedQueryResult

2023-10-31 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-15768: --- Summary: StateQueryResult#getOnlyPartitionResult should not throw for FailedQueryResult Key: KAFKA-15768 URL: https://issues.apache.org/jira/browse/KAFKA-15768

[jira] [Created] (KAFKA-15765) Remove task level metric "commit-latency"

2023-10-31 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-15765: --- Summary: Remove task level metric "commit-latency" Key: KAFKA-15765 URL: https://issues.apache.org/jira/browse/KAFKA-15765 Project: Kafka

[jira] [Created] (KAFKA-15765) Remove task level metric "commit-latency"

2023-10-31 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-15765: --- Summary: Remove task level metric "commit-latency" Key: KAFKA-15765 URL: https://issues.apache.org/jira/browse/KAFKA-15765 Project: Kafka

[jira] [Resolved] (KAFKA-15672) Add 3.6 to streams system tests

2023-10-31 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-15672. - Resolution: Duplicate > Add 3.6 to streams system te

[jira] [Resolved] (KAFKA-15672) Add 3.6 to streams system tests

2023-10-31 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-15672. - Resolution: Duplicate > Add 3.6 to streams system te

[jira] [Assigned] (KAFKA-15672) Add 3.6 to streams system tests

2023-10-31 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-15672: --- Assignee: Matthias J. Sax > Add 3.6 to streams system te

[jira] [Assigned] (KAFKA-15594) Add 3.6.0 to streams upgrade/compatibility tests

2023-10-31 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-15594: --- Assignee: Matthias J. Sax > Add 3.6.0 to streams upgrade/compatibility te

[jira] [Assigned] (KAFKA-15595) Session window aggregate drops records headers

2023-10-31 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-15595: --- Assignee: Hao Li > Session window aggregate drops records head

[jira] [Resolved] (KAFKA-15602) Breaking change in 3.4.0 ByteBufferSerializer

2023-10-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-15602. - Fix Version/s: 3.4.2 3.5.2 3.7.0

[jira] [Resolved] (KAFKA-15602) Breaking change in 3.4.0 ByteBufferSerializer

2023-10-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-15602. - Fix Version/s: 3.4.2 3.5.2 3.7.0

[jira] [Reopened] (KAFKA-4852) ByteBufferSerializer not compatible with offsets

2023-10-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-4852: Assignee: (was: LinShunkang) > ByteBufferSerializer not compatible with offs

[jira] [Updated] (KAFKA-4852) ByteBufferSerializer not compatible with offsets

2023-10-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4852: --- Labels: needs-kip (was: ) > ByteBufferSerializer not compatible with offs

[jira] [Reopened] (KAFKA-4852) ByteBufferSerializer not compatible with offsets

2023-10-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-4852: Assignee: (was: LinShunkang) > ByteBufferSerializer not compatible with offs

[jira] [Updated] (KAFKA-4852) ByteBufferSerializer not compatible with offsets

2023-10-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4852: --- Fix Version/s: (was: 3.4.0) > ByteBufferSerializer not compatible with offs

Re: [ANNOUNCE] New Kafka PMC Member: Satish Duggana

2023-10-27 Thread Matthias J. Sax
Congrats! On 10/27/23 10:01 AM, Viktor Somogyi-Vass wrote: Congrats Satish! On Fri, Oct 27, 2023, 18:48 Ivan Yurchenko wrote: Congrats Satish! Ivan On Fri, Oct 27, 2023, at 19:02, Kamal Chandraprakash wrote: Congratulations Satish! On Fri, Oct 27, 2023, 21:10 Jorge Esteban Quilcate

[jira] [Updated] (KAFKA-15319) Upgrade rocksdb to fix CVE-2022-37434

2023-10-26 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-15319: Fix Version/s: 3.5.2 > Upgrade rocksdb to fix CVE-2022-37

[jira] [Updated] (KAFKA-15690) EosIntegrationTest is flaky.

2023-10-26 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-15690: Component/s: streams unit tests > EosIntegrationTest is fl

Re: [DISCUSS] KIP-992 Proposal to introduce IQv2 Query Types: TimestampedKeyQuery and TimestampedRangeQuery

2023-10-26 Thread Matthias J. Sax
Hanyu On Fri, Oct 20, 2023 at 10:40 AM Matthias J. Sax wrote: Thanks for the KIP Hanyu, One questions: To address this inconsistency, we propose that KeyQuery should be restricted to querying kv-stores only, ensuring that it always returns a plain V type, making the be

Re: [VOTE] KIP-988 Streams StandbyUpdateListener

2023-10-26 Thread Matthias J. Sax
+1 (binding) On 10/25/23 4:06 PM, Sophie Blee-Goldman wrote: Happy to see this -- that's a +1 (binding) from me On Mon, Oct 23, 2023 at 6:33 AM Bill Bejeck wrote: This is a great addition +1(binding) -Bill On Fri, Oct 20, 2023 at 2:29 PM Almog Gavra wrote: +1 (non-binding) - great

Re: [DISCUSS] KIP-988 Streams Standby Task Update Listener

2023-10-26 Thread Matthias J. Sax
end offset within the same release, ie without any deprecations. There are plenty of paths forward here, so don't let us drag this out forever if you know what you want Cheers, Sophie On Fri, Oct 20, 2023 at 10:57 AM Matthias J. Sax wrote: Forgot one thing: We could also pass `curren

[jira] [Commented] (KAFKA-12550) Introduce RESTORING state to the KafkaStreams FSM

2023-10-26 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17780015#comment-17780015 ] Matthias J. Sax commented on KAFKA-12550: - Hmmm... Aren't both things kinda independent

[jira] [Commented] (KAFKA-15602) Breaking change in 3.4.0 ByteBufferSerializer

2023-10-26 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17780013#comment-17780013 ] Matthias J. Sax commented on KAFKA-15602: - > Ah, nah, ByteBuffer.wrap("test".getBy

[jira] [Commented] (KAFKA-15602) Breaking change in 3.4.0 ByteBufferSerializer

2023-10-24 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17779216#comment-17779216 ] Matthias J. Sax commented on KAFKA-15602: - {quote}I'm not entirely sure I understand Matthias's

[jira] [Comment Edited] (KAFKA-15602) Breaking change in 3.4.0 ByteBufferSerializer

2023-10-23 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17778731#comment-17778731 ] Matthias J. Sax edited comment on KAFKA-15602 at 10/23/23 4:20 PM

[jira] [Commented] (KAFKA-15602) Breaking change in 3.4.0 ByteBufferSerializer

2023-10-23 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17778731#comment-17778731 ] Matthias J. Sax commented on KAFKA-15602: - Btw: also left a comment on K4852: https

[jira] [Commented] (KAFKA-4852) ByteBufferSerializer not compatible with offsets

2023-10-23 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17778727#comment-17778727 ] Matthias J. Sax commented on KAFKA-4852: As reported on https://issues.apache.org/jira/browse

[jira] [Commented] (KAFKA-15602) Breaking change in 3.4.0 ByteBufferSerializer

2023-10-23 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17778719#comment-17778719 ] Matthias J. Sax commented on KAFKA-15602: - Sounds fair. – Let me revert K4852 in all applicable

[jira] [Resolved] (KAFKA-15666) Добавить функцию поиска по почте

2023-10-23 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-15666. - Resolution: Invalid [~noraverba] – We can only take tickets in English. – Also piped

[jira] [Resolved] (KAFKA-15666) Добавить функцию поиска по почте

2023-10-23 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-15666. - Resolution: Invalid [~noraverba] – We can only take tickets in English. – Also piped

[jira] [Created] (KAFKA-15672) Add 3.6 to streams system tests

2023-10-23 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-15672: --- Summary: Add 3.6 to streams system tests Key: KAFKA-15672 URL: https://issues.apache.org/jira/browse/KAFKA-15672 Project: Kafka Issue Type: Test

[jira] [Created] (KAFKA-15672) Add 3.6 to streams system tests

2023-10-23 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-15672: --- Summary: Add 3.6 to streams system tests Key: KAFKA-15672 URL: https://issues.apache.org/jira/browse/KAFKA-15672 Project: Kafka Issue Type: Test

[jira] [Comment Edited] (KAFKA-15602) Breaking change in 3.4.0 ByteBufferSerializer

2023-10-22 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17778511#comment-17778511 ] Matthias J. Sax edited comment on KAFKA-15602 at 10/23/23 4:09 AM

[jira] [Comment Edited] (KAFKA-15602) Breaking change in 3.4.0 ByteBufferSerializer

2023-10-22 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17778511#comment-17778511 ] Matthias J. Sax edited comment on KAFKA-15602 at 10/23/23 4:06 AM

[jira] [Updated] (KAFKA-15664) Add 3.4.0 streams upgrade/compatibility tests

2023-10-22 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-15664: Component/s: streams system tests > Add 3.4.0 streams upgr

[jira] [Updated] (KAFKA-15664) Add 3.4.0 streams upgrade/compatibility tests

2023-10-22 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-15664: Priority: Critical (was: Major) > Add 3.4.0 streams upgrade/compatibility te

[jira] [Updated] (KAFKA-15664) Add 3.4.0 streams upgrade/compatibility tests

2023-10-22 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-15664: Affects Version/s: 3.5.0 > Add 3.4.0 streams upgrade/compatibility te

[jira] [Updated] (KAFKA-15664) Add 3.4.0 streams upgrade/compatibility tests

2023-10-22 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-15664: Fix Version/s: 3.5.2 3.7.0 3.6.1 > Add 3.

[jira] [Commented] (KAFKA-15602) Breaking change in 3.4.0 ByteBufferSerializer

2023-10-22 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17778511#comment-17778511 ] Matthias J. Sax commented on KAFKA-15602: - Hey, [~pnee] pointed me to this ticket. I am

[jira] [Updated] (KAFKA-15662) Implement support for clientInstanceIds in Kafka Stream

2023-10-22 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-15662: Component/s: streams > Implement support for clientInstanceIds in Kafka Str

[jira] [Resolved] (KAFKA-15378) Rolling upgrade system tests are failing

2023-10-20 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-15378. - Fix Version/s: 3.4.2 3.5.2 3.7.0

[jira] [Resolved] (KAFKA-15378) Rolling upgrade system tests are failing

2023-10-20 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-15378. - Fix Version/s: 3.4.2 3.5.2 3.7.0

Re: [DISCUSS] Apache Kafka 3.5.2 release

2023-10-20 Thread Matthias J. Sax
Thanks for the info Luke. We did backport all but one PR in the mean time. The missing PR is a RocksDB version bump. We want to consider it for 3.5.2, because it addresses a CVE. Cf https://github.com/apache/kafka/pull/14216 However, RocksDB versions bumps are a little bit more tricky, and

Re: [DISCUSS] KIP-988 Streams Standby Task Update Listener

2023-10-20 Thread Matthias J. Sax
Forgot one thing: We could also pass `currentLag()` into `onBachLoaded()` instead of end-offset. -Matthias On 10/20/23 10:56 AM, Matthias J. Sax wrote: Thanks for digging into this Bruno. The JavaDoc on the consumer does not say anything specific about `endOffset` guarantees: Get

Re: [DISCUSS] KIP-988 Streams Standby Task Update Listener

2023-10-20 Thread Matthias J. Sax
ds within the state. That is clearly not the meaning of the event for which the listener should be called. Best, Bruno On 10/19/23 2:12 AM, Matthias J. Sax wrote: Thanks for the KIP. Seems I am almost late to the party. About naming (fun, fun, fun): I like the current proposal overall, except `on

Re: [DISCUSS] KIP-992 Proposal to introduce IQv2 Query Types: TimestampedKeyQuery and TimestampedRangeQuery

2023-10-20 Thread Matthias J. Sax
Thanks for the KIP Hanyu, One questions: To address this inconsistency, we propose that KeyQuery should be restricted to querying kv-stores only, ensuring that it always returns a plain V type, making the behavior of the aforementioned code more predictable. Similarly, RangeQuery should

[jira] [Updated] (KAFKA-13973) block-cache-capacity metrics worth twice as much as normal

2023-10-20 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13973: Fix Version/s: 3.5.2 > block-cache-capacity metrics worth twice as much as nor

[jira] [Commented] (KAFKA-7699) Improve wall-clock time punctuations

2023-10-19 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1550#comment-1550 ] Matthias J. Sax commented on KAFKA-7699: Happy to support you. The KIP wiki page describes how

Re: Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #2305

2023-10-19 Thread Matthias J. Sax
You would need to unsubscribe from the dev list. I would recommend to setup a filter with you email provider if you don't want these and re-direct them directly to trash. -Matthias On 10/19/23 4:49 AM, Shyam P wrote: how to unsubscribe this ? On Thu, Oct 19, 2023 at 1:30 PM Apache Jenkins

[jira] [Commented] (KAFKA-7699) Improve wall-clock time punctuations

2023-10-19 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1368#comment-1368 ] Matthias J. Sax commented on KAFKA-7699: [~hermankj] – thanks for your comment. – This change

[jira] [Updated] (KAFKA-15616) Define client telemetry states and their transitions

2023-10-18 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-15616: Fix Version/s: 3.7.0 > Define client telemetry states and their transiti

[jira] [Updated] (KAFKA-13973) block-cache-capacity metrics worth twice as much as normal

2023-10-18 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13973: Fix Version/s: 3.6.1 > block-cache-capacity metrics worth twice as much as nor

[jira] [Updated] (KAFKA-15338) The metric group documentation for metrics added in KAFKA-13945 is incorrect

2023-10-18 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-15338: Affects Version/s: (was: 3.4.0) (was: 3.3.1

[jira] [Updated] (KAFKA-15338) The metric group documentation for metrics added in KAFKA-13945 is incorrect

2023-10-18 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-15338: Fix Version/s: 3.3.3 3.4.2 3.5.2 > The metric gr

[jira] [Updated] (KAFKA-15629) proposal to introduce IQv2 Query Types: TimeStampKeyQuery and TimeStampRangeQuery

2023-10-18 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-15629: Description: KIP-992: [https://cwiki.apache.org/confluence/display/KAFKA/KIP-992%3A

[jira] [Updated] (KAFKA-15629) proposal to introduce IQv2 Query Types: TimeStampKeyQuery and TimeStampRangeQuery

2023-10-18 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-15629: Labels: kip (was: ) > proposal to introduce IQv2 Query Types: TimeStampKeyQu

Re: [DISCUSS] KIP-988 Streams Standby Task Update Listener

2023-10-18 Thread Matthias J. Sax
Thanks for the KIP. Seems I am almost late to the party. About naming (fun, fun, fun): I like the current proposal overall, except `onBachLoaded`, but would prefer `onBatchUpdated`. It better aligns to everything else: - it's an update-listener, not loaded-listener - `StateRestoreListener`

[jira] [Commented] (KAFKA-6520) When a Kafka Stream can't communicate with the server, it's Status stays RUNNING

2023-10-17 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17776381#comment-17776381 ] Matthias J. Sax commented on KAFKA-6520: Could we use Admin.describeCluster() which returns

Re: [DISCUSS] Apache Kafka 3.5.2 release

2023-10-17 Thread Matthias J. Sax
Thanks -- there is a few fixed for Kafka Streams we are considering to cherry-pick to get into 3.5.2 release -- what timeline do you target for the release? -Matthias On 10/17/23 8:47 AM, Divij Vaidya wrote: Thank you for volunteering Luke. -- Divij Vaidya On Tue, Oct 17, 2023 at 3:26 

Re: [VOTE] KIP-985 Add reverseRange and reverseAll query over kv-store in IQv2

2023-10-16 Thread Matthias J. Sax
+1 (binding) On 10/13/23 9:24 AM, Hanyu (Peter) Zheng wrote: Hello everyone, I would like to start a vote for KIP-985 that Add reverseRange and reverseAll query over kv-store in IQv2. Sincerely, Hanyu On Fri, Oct 13, 2023 at 9:15 AM Hanyu (Peter) Zheng wrote:

[jira] [Commented] (KAFKA-13152) Replace "buffered.records.per.partition" & "cache.max.bytes.buffering" with "{statestore.cache}/{input.buffer}.max.bytes"

2023-10-14 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17775325#comment-17775325 ] Matthias J. Sax commented on KAFKA-13152: - [~guozhang] would you have interest to help getting

[jira] [Commented] (KAFKA-15594) Add 3.6.0 to streams upgrade/compatibility tests

2023-10-14 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17775323#comment-17775323 ] Matthias J. Sax commented on KAFKA-15594: - This ticket is to include upgrade test from 3.6

[jira] [Commented] (KAFKA-15594) Add 3.6.0 to streams upgrade/compatibility tests

2023-10-14 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17775324#comment-17775324 ] Matthias J. Sax commented on KAFKA-15594: - This ticket is to include upgrade test from 3.6

[jira] [Commented] (KAFKA-15593) Add 3.6.0 to broker/client upgrade/compatibility tests

2023-10-14 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17775322#comment-17775322 ] Matthias J. Sax commented on KAFKA-15593: - This ticket is to include upgrade test from 3.6

Re: Requesting permission for contributions

2023-10-13 Thread Matthias J. Sax
Done. You should be all set. -Matthias On 10/13/23 8:21 AM, Apoorv Mittal wrote: Hi, Can I please get permission to contribute KIP and assign Jiras to myself. Wiki and Jira Id: apoorvmittal10 Email: apoorvmitta...@gmail.com Regards, Apoorv Mittal +44 7721681581

<    1   2   3   4   5   6   7   8   9   10   >