[jira] [Resolved] (KAFKA-15427) Integration tests in TS test harness detect resource leaks

[ https://issues.apache.org/jira/browse/KAFKA-15427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-15427. --- Resolution: Fixed > Integration tests in TS test harness detect resource leaks > ---

[jira] [Resolved] (KAFKA-15404) Failing Test DynamicBrokerReconfigurationTest#testThreadPoolResize

[ https://issues.apache.org/jira/browse/KAFKA-15404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash resolved KAFKA-15404. -- Resolution: Fixed > Failing Test DynamicBrokerReconfigurationTest#testThreadPo

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

See

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.6 #17

See

Re: [DISCUSS] KIP-971 Expose replication-offset-lag MirrorMaker2 metric

Hi, Eminov. My doubt is: how do you get the LEO of the source cluster for the partition in `poll`? best, hudeqi > -原始邮件- > 发件人: "Elxan Eminov" > 发送时间: 2023-09-02 19:18:23 (星期六) > 收件人: dev@kafka.apache.org > 抄送: > 主题: Re: Re: [DISCUSS] KIP-971 Expose replication-offset-lag MirrorMaker2

Re: KIP-976: Cluster-wide dynamic log adjustment for Kafka Connect

Hi Chris, Thanks for thinking about this useful feature ! I had a question regarding > Since cluster metadata is not required to handle these types of request, they will not be forwarded to the leader And later, we also mention about supporting more scope types in the future. Don't you foresee a

[jira] [Resolved] (KAFKA-9564) Integration Test framework for Tiered Storage

[ https://issues.apache.org/jira/browse/KAFKA-9564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satish Duggana resolved KAFKA-9564. --- Resolution: Fixed > Integration Test framework for Tiered Storage > -

[jira] [Resolved] (KAFKA-15260) RLM Task should wait until RLMM is initialized before copying segments to remote

[ https://issues.apache.org/jira/browse/KAFKA-15260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satish Duggana resolved KAFKA-15260. Resolution: Fixed > RLM Task should wait until RLMM is initialized before copying segments

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

See

Re: KIP-976: Cluster-wide dynamic log adjustment for Kafka Connect

Hi Chris, Thanks for the KIP, this looks like a really useful addition to Kafka Connect's log level REST APIs! I have a few questions and comments: > If no modifications to the namespace have > been made since the worker was started, > they will be null If no modifications to a logging namespace

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.6 #18

See

Re: KIP-976: Cluster-wide dynamic log adjustment for Kafka Connect

> If no modifications to a logging namespace have > been made, won't the namespace itself be omitted > from the response? It looks like we currently only > return loggers that have non-null log levels in the *> **GET /admin/loggers* endpoint. This can be ignored - I didn't account for the fact tha

Re: [DISCUSS] KIP-971 Expose replication-offset-lag MirrorMaker2 metric

Hi huqedi, I've considered two solutions: 1) https://kafka.apache.org/24/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#endOffsets-java.util.Collection- This option requires an additional network call, so not preferable 2) Manually getting the last element of List in the response of

Re: KIP-976: Cluster-wide dynamic log adjustment for Kafka Connect

Hi Chris, thanks. This looks like a useful feature. Due to the idempotent nature of PUT, I guess that the last_modified timestamp won't change if the same request is repeated successively. Should we add a unit test for that? On Mon, Sep 4, 2023 at 6:17 AM Ashwin wrote: > > Hi Chris, > > Thanks f