Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2436

See

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

Hi Matthias and everyone— Some clarification is necessary just for posterity. It turns out that, on a fresh standby task before we start polling for records, we wouldn't be able to get the current end offset without a network call. This leaves us three options: A) Make it an Optional or use a

Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #2435

See

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

parameter is somewhat irrelevant to our use case Sounds like a weird justification to change the KIP. Providing more information is usually better than less, so it seems it won't hurt to just keep it (seems useful in general to get the current end offset in this callback) -- you can always

[jira] [Resolved] (KAFKA-15527) Add reverseRange and reverseAll query over kv-store in IQv2

[ https://issues.apache.org/jira/browse/KAFKA-15527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-15527. - Resolution: Fixed > Add reverseRange and reverseAll query over kv-store in IQv2 >

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #2434

See Changes: -- [...truncated 241709 lines...] Progress (3): 2.6/5.6 MB | 358 kB | 341/640 kB Progress (3): 2.6/5.6 MB | 358 kB | 341/640 kB Progress (3): 2.6/5.6 MB | 358

[jira] [Created] (KAFKA-15951) MissingSourceTopicException should include topic names

Matthias J. Sax created KAFKA-15951: --- Summary: MissingSourceTopicException should include topic names Key: KAFKA-15951 URL: https://issues.apache.org/jira/browse/KAFKA-15951 Project: Kafka

[jira] [Resolved] (KAFKA-15629) proposal to introduce IQv2 Query Types: TimestampedKeyQuery and TimestampedRangeQuery

[ https://issues.apache.org/jira/browse/KAFKA-15629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-15629. - Resolution: Fixed > proposal to introduce IQv2 Query Types: TimestampedKeyQuery and >

[jira] [Resolved] (KAFKA-13621) Resign leader on network partition

[ https://issues.apache.org/jira/browse/KAFKA-13621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] José Armando García Sancio resolved KAFKA-13621. Resolution: Duplicate > Resign leader on network partition >

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #2433

See Changes: -- [...truncated 23389 lines...] error: unable to read sha1 file of tools/src/test/java/org/apache/kafka/tools/EndToEndLatencyTest.java

Re: [DISCUSS] KIP-997 Support fetch(fromKey, toKey, from, to) to WindowRangeQuery and unify WindowKeyQuery and WindowRangeQuery

new KIP link: https://cwiki.apache.org/confluence/display/KAFKA/KIP-997%3A++update+WindowRangeQuery+and+unify+WindowKeyQuery+and+WindowRangeQuery On Wed, Nov 29, 2023 at 10:12 PM Hanyu (Peter) Zheng wrote: > Thank you Bruno, > 1. Thank you for the notification. I have updated the ticket link >

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

Hello everyone, We have come to the conclusion, during our work on this KIP's implementation, that the #onUpdateStart callback's "currentEndOffset" parameter is somewhat irrelevant to our use case. When this callback is invoked, I think this value is usually unknown. Our choice to delete this

Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #2432

See

[REVIEW REQUEST] ConsumerGroupCommand move to tools

Hello. I prepared a PR to move `ConsumerGroupCommand` to `tools` module. Full changes are pretty huge [1] so I split them into several PR’s. Please, take a look at first PR in the series - https://github.com/apache/kafka/pull/14856 PR adds `ConsumerGroupCommandOptions` class and other command

[REVIEW REQUEST] ConfigType, ConfigEntityName, DynamicConfig moved to server-common

Hello. I’m working one move `ConfigCommand` to tools module. `ConfigCommand` depends on several config classes from core. So that classes must be moved to «server-commons» prior to command migration. I’ve prepared several PR’s to move part of dependencies. All PR’s seems to be very

Jenkins build is unstable: Kafka » Kafka Branch Builder » 3.6 #122

See