[jira] [Resolved] (KAFKA-14956) Flaky test org.apache.kafka.connect.integration.OffsetsApiIntegrationTest#testGetSinkConnectorOffsetsDifferentKafkaClusterTargeted

[ https://issues.apache.org/jira/browse/KAFKA-14956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya resolved KAFKA-14956. Resolution: Fixed > Flaky test > org.apache.kafka.connect.integration.OffsetsApiIntegrationTest#t

[GitHub] [kafka-site] Dionakra opened a new pull request, #517: MINOR: Added missing Kafka Broker docs for metrics.jmx.(include|exclude) configs

Dionakra opened a new pull request, #517: URL: https://github.com/apache/kafka-site/pull/517 Added documentation about Kafka Brokers JMX configurable beans. This was introduced by [KIP-544](https://cwiki.apache.org/confluence/display/KAFKA/KIP-544%3A+Make+metrics+exposed+via+JMX+configurabl

Re: [DISCUSS] KIP-932: Queues for Kafka

Hi Andrew, Thanks for the KIP. Some high level questions: 1. How do we handle "fetch from follower" case? It looks like in current design, each call needs to go to "shared partition leader", where the shared state stored. Is my understanding correct? 2. Where does the state info stored? It looks

[jira] [Created] (KAFKA-15033) Failed to close repository in stagingRepositories

Luke Chen created KAFKA-15033: - Summary: Failed to close repository in stagingRepositories Key: KAFKA-15033 URL: https://issues.apache.org/jira/browse/KAFKA-15033 Project: Kafka Issue Type: Task

[jira] [Created] (KAFKA-15034) Improvement of ReplaceField performance for long list

BDeus created KAFKA-15034: - Summary: Improvement of ReplaceField performance for long list Key: KAFKA-15034 URL: https://issues.apache.org/jira/browse/KAFKA-15034 Project: Kafka Issue Type: Improveme

Re: [DISCUSS] KIP-910: Update Source offsets for Source Connectors without producing records

Hi, Bumping this thread again for further reviews. Thanks! Sagar. On Fri, May 12, 2023 at 3:38 PM Sagar wrote: > Hi All, > > Thanks for the comments/reviews. I have updated the KIP > https://cwiki.apache.org/confluence/display/KAFKA/KIP-910%3A+Update+Source+offsets+for+Source+Connectors+withou

[jira] [Created] (KAFKA-15035) Consumer offsets can be deleted immediately if kafka does not detect a consumer as dead

Sam Cantero created KAFKA-15035: --- Summary: Consumer offsets can be deleted immediately if kafka does not detect a consumer as dead Key: KAFKA-15035 URL: https://issues.apache.org/jira/browse/KAFKA-15035

RE: [DISCUSS] KIP-932: Queues for Kafka

Hello, thank you for the proposal! A very interesting read. I do have one question, though. When you subscribe to a topic using consumer groups, it might happen that one consumer has processed all messages from its partitions, while another one still has a lot of work to do (this might be due

[jira] [Created] (KAFKA-15036) Kraft leader change fails when invoking getFinalizedFeatures

Deng Ziming created KAFKA-15036: --- Summary: Kraft leader change fails when invoking getFinalizedFeatures Key: KAFKA-15036 URL: https://issues.apache.org/jira/browse/KAFKA-15036 Project: Kafka I

Re: [DISCUSS] KIP-899: Allow clients to rebootstrap

Hi Chris and all, > I believe the logic you've linked is only applicable for the producer and > consumer clients; the admin client does something different (see [1]). I see, thank you for the pointer. It seems the admin client is fairly different from the producer and consumer. Probably it makes

Re: [DISCUSS] KIP-917: Additional custom metadata for remote log segment

Hi all, I want to bring this to a conclusion (positive or negative), so if there are no more questions in a couple of days, I'll put the KIP to the vote. Best, Ivan On Fri, 5 May 2023 at 18:42, Ivan Yurchenko wrote: > Hi Alexandre, > > > combining custom > > metadata with rlmMetadata increase