[jira] [Resolved] (KAFKA-16912) Migrate ConsumerNetworkThreadTest.testPollResultTimer() to NetworkClientDelegateTest

[ https://issues.apache.org/jira/browse/KAFKA-16912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16912. Fix Version/s: 3.9.0 Resolution: Fixed > Migrate ConsumerNetworkThreadTest.testPoll

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.8 #19

See

Re: [DISCUSS] KIP-1052: Align the naming convention for config and default variables in *Config classes

Hi Divij, Thanks for the response, you are right that changing the external interface leads to some repetition. The main benefit is that the variables would follow the normalized naming convention. It was a concern brought up in this ticket . Als

[DISCUSS] KIP-1052: Enable warmup in producer performance test

Hello all, I'd like to propose a change that would allow the producer performance test to have a warmup phase where the statistics gathered could be separated from statistics gathered during steady state. Although startup is an important phase of Kafka operations and special attention should b

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

See

[jira] [Resolved] (KAFKA-16223) Replace EasyMock and PowerMock with Mockito for KafkaConfigBackingStoreTest

[ https://issues.apache.org/jira/browse/KAFKA-16223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16223. Fix Version/s: 3.9.0 (was: 3.8.0) Resolution: Fixed > Replac

Re: [DISCUSS] KIP-1046: Expose producer.id.expiration.check.interval.ms as dynamic broker configuration

Hey Jorge I understand the pain point which is driving this KIP. An operator should be able to proactively mitigate an impending OOM due to large number of producers. I would like to hear your thoughts on alternative ways to solve this problem. As an example, we could potentially add an operator

Re: [DISCUSS] KIP-1052: Align the naming convention for config and default variables in *Config classes

Hi Eric Thank you for writing the KIP. Standardizing the internal variables and classes as per a convention is a good idea. Even better would be to enforce that convention using check style rules so that the convention is enforced via a mechanism in the future code. You don’t need a KIP for it.

[jira] [Created] (KAFKA-16912) Migrate ConsumerNetworkThreadTest.testPollResultTimer() to NetworkClientDelegateTest

Brenden DeLuna created KAFKA-16912: -- Summary: Migrate ConsumerNetworkThreadTest.testPollResultTimer() to NetworkClientDelegateTest Key: KAFKA-16912 URL: https://issues.apache.org/jira/browse/KAFKA-16912

[jira] [Created] (KAFKA-16911) Kafka Streams topology optimization docs incomplete

Matthias J. Sax created KAFKA-16911: --- Summary: Kafka Streams topology optimization docs incomplete Key: KAFKA-16911 URL: https://issues.apache.org/jira/browse/KAFKA-16911 Project: Kafka Iss

[jira] [Resolved] (KAFKA-16903) Task should consider producer error previously occurred for different task

[ https://issues.apache.org/jira/browse/KAFKA-16903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-16903. - Resolution: Fixed > Task should consider producer error previously occurred for differen

[jira] [Resolved] (KAFKA-14701) More broker side partition assignor to common

[ https://issues.apache.org/jira/browse/KAFKA-14701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-14701. - Fix Version/s: 3.8.0 Resolution: Fixed > More broker side partition assignor to common >

Re: [DISCUSS] KIP-1052: Align the naming convention for config and default variables in *Config classes

Hi, I wanted to follow-up on the discussion thread since I have not received anything yet. Best regards, Eric On Thu, Jun 6, 2024 at 12:39 PM Eric Lu wrote: > Hi, > > I'd like to start a discussion thread for my KIP: > KIP-1052: Align the naming convention for config and default variables in

Re: [DISCUSS] KIP-1045 Decide MockAdminClient to move to public api or not

Hi Jiang, Thank you for your response. I agree that people might use it as valid code for creating topics. I don't have a compelling argument beyond the benefits it offers developers in certain use cases and maintaining consistency with MockProducer and MockConsumer. If I don't receive any furthe

Re: Access to Apache Pony Mail

Hi Eric, If I understand correctly your problem I think you might be all set. Apache Pony mail is mostly used as an archive for emails (yes, Apache members can log in and send emails through it) but for the purpose of a KIP you don't need any account there. In case this is what you might be having

[jira] [Resolved] (KAFKA-15204) Replication Throttling: Re-add ReplicationThrottledRate to Server Config

[ https://issues.apache.org/jira/browse/KAFKA-15204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nikos Kostoulas resolved KAFKA-15204. - Resolution: Duplicate > Replication Throttling: Re-add ReplicationThrottledRate to Serve

[DISCUSS] KIP-1051 Statically configured log replication throttling

Hi everyone, I would like to propose a change to allow the static configuration of leader and follower replication throttling rates. These configurations are very useful for preventing client traffic from getting throttled by replication traffic during events that cause a spike in replication.

[DISCUSS] KIP-1052: Align the naming convention for config and default variables in *Config classes

Hi, I'd like to start a discussion thread for my KIP: KIP-1052: Align the naming convention for config and default variables in *Config classes https://cwiki.apache.org/confluence/display/KAFKA/KIP-1052%3A+Align+the+naming+convention+for+config+and+default+variables+in+*Config+classes Thanks,

[jira] [Created] (KAFKA-16910) Move leader and follower replication throttling rate configuration values to KafkaConfig

Harry Fallows created KAFKA-16910: - Summary: Move leader and follower replication throttling rate configuration values to KafkaConfig Key: KAFKA-16910 URL: https://issues.apache.org/jira/browse/KAFKA-16910

[jira] [Created] (KAFKA-16909) Refactor GroupCoordinatorConfig with AbstractConfig

Chia-Ping Tsai created KAFKA-16909: -- Summary: Refactor GroupCoordinatorConfig with AbstractConfig Key: KAFKA-16909 URL: https://issues.apache.org/jira/browse/KAFKA-16909 Project: Kafka Issue

[jira] [Created] (KAFKA-16908) Refactor QuorumConfig with AbstractConfig

Chia-Ping Tsai created KAFKA-16908: -- Summary: Refactor QuorumConfig with AbstractConfig Key: KAFKA-16908 URL: https://issues.apache.org/jira/browse/KAFKA-16908 Project: Kafka Issue Type: Imp

Access to Apache Pony Mail

Hi, *My last email might have went through, if it did, you can disregard this one* Thanks for setting my account up. I am currently writing a KIP. However, I am experiencing some issues with creating a discussion thread on Apache Pony mail. I am unable to login to Apache Pony Mail with my creden

Re: Request permission to Create KIP

Hi Eric, I don't think you need to log into Pony Mail to start a discussion thread. You can just send an email to the dev list with [DISCUSS] in the title and that should be sufficient. Cheers, Chris On Thu, Jun 6, 2024 at 12:01 PM Eric Lu wrote: > Hi, > > Thanks for setting my account up. I

Re: Request permission to Create KIP

Hi, Thanks for setting my account up. I am currently writing a KIP. However, I am experiencing some issues with creating a discussion thread on Apache Pony mail. I am unable to login to Apache Pony Mail with my credentials: ericlu95. Who should I contact to deal with this problem? What should I do

[jira] [Created] (KAFKA-16907) Remove ClassDataAbstractionCoupling warning suppression from RaftUtils

José Armando García Sancio created KAFKA-16907: -- Summary: Remove ClassDataAbstractionCoupling warning suppression from RaftUtils Key: KAFKA-16907 URL: https://issues.apache.org/jira/browse/KAFKA-16907

[jira] [Created] (KAFKA-16906) Add consistent error handling for Transactions

Kaushik Raina created KAFKA-16906: - Summary: Add consistent error handling for Transactions Key: KAFKA-16906 URL: https://issues.apache.org/jira/browse/KAFKA-16906 Project: Kafka Issue Type:

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

+1 non-binding This will be a great addition to Kafka Connect On Thu, Apr 25, 2024 at 2:41 PM Sagar wrote: > > Hey All, > > Bumping the vote thread after a long time! > > Thanks! > Sagar. > > On Fri, Feb 2, 2024 at 4:24 PM Sagar wrote: > > > Thanks Yash! > > > > I am hoping to have this release

[jira] [Created] (KAFKA-16905) Thread block in describe topics API in Admin Client

Apoorv Mittal created KAFKA-16905: - Summary: Thread block in describe topics API in Admin Client Key: KAFKA-16905 URL: https://issues.apache.org/jira/browse/KAFKA-16905 Project: Kafka Issue T

Re: [DISCUSS] KIP-1050: Consistent error handling for Transactions

Hi Kaushik, Thanks for the KIP. This is definitely an area that needs clearing up so it’s good to see it. A few initial questions. 1. If I understand correctly, you are proposing to change the superclass of all subclasses of o.a.k.common.errors.ApiException which can be thrown by the producer o

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

See

Re: [DISCUSS] KIP-655: Add deduplication processor in kafka-streams

Hi Matthias, Thank you for your review ! 100. I agree. I changed the name of the parameter to "idSelector". Because this id may be computed, It is better to call it "id" rather than field or attribute. 101. The reason I added the methods `keySerde()` and `valueSerde()` was to have the same capab

[DISCUSS] KIP-1050: Consistent error handling for Transactions

Hi everyone, I would like to start a discussion thread for KIP-1050: Consistent error handling for Transactions https://cwiki.apache.org/confluence/display/KAFKA/KIP-1050%3A+Consistent+error+handling+for+Transactions Thanks Kaushik Raina

Re: [DISCUSS] KIP-1043: Administration of groups

Hi Kirk, Thanks for your comments. 1. I’m a big fan of consistency in these things and the method signatures match ListConsumerGroupsResult and ListShareGroupsResult. 2. Yes, client-side filtering. 3. I didn’t offer “classic” as an option for --group-type. I’ve kicked the options around in my m

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

See

Re: [DISCUSS] KIP-1045 Decide MockAdminClient to move to public api or not

hi Thank you KIP， but I don't agree with putting mock methods or classes into src folder ， Unless there is a reason to put the mock class in the src folder (for example: multi-threaded execution cannot be verified under @Test) Placing the mock class under src will increase maintenance costs, and

Re: [DISCUSS] KIP-1035: StateStore managed changelog offsets

Hi Matthias, Thanks for your thorough review. 200. (#managesOffsets requirements) Done 201. (#commit atomicity recommendation vs. guarantee) There are possible StateStore implementations, including existing ones, that can't guarantee atomicity - because the underlying database/system doesn't sup

[jira] [Created] (KAFKA-16904) Metric to measure the latency of remote read requests

Kamal Chandraprakash created KAFKA-16904: Summary: Metric to measure the latency of remote read requests Key: KAFKA-16904 URL: https://issues.apache.org/jira/browse/KAFKA-16904 Project: Kafka

Re: [DISCUSS] KIP-1045 Decide MockAdminClient to move to public api or not

Hi, I have updated this KIP to a proposal now. Hoping to get any thoughts or opinions. - Moving MockAdminClient to the src folder and making it public making it similar to MockProducer and MockConsu

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.8 #16

See

Re: Requesting permissions to create KIP

Thank you for your interest in Apache Kafka. Updated the permissions. On Thu, Jun 6, 2024 at 1:15 PM Kaushik Raina wrote: > > Hello, > Please provide permissions to create KIP. I indent to contribute to Apache > kafka > > Wiki Id: kra...@confluent.io > Jira ID: k-raina

Requesting permissions to create KIP

Hello, Please provide permissions to create KIP. I indent to contribute to Apache kafka Wiki Id: kra...@confluent.io Jira ID: k-raina

[jira] [Created] (KAFKA-16903) Task should consider producer error previously occurred for different task

Bruno Cadonna created KAFKA-16903: - Summary: Task should consider producer error previously occurred for different task Key: KAFKA-16903 URL: https://issues.apache.org/jira/browse/KAFKA-16903 Project: