Re: [DISCUSS] KIP-926: introducing acks=min.insync.replicas config

r KIP. I'm still thinking about it. Thank you. Luke On Fri, May 12, 2023 at 3:59 PM Luke Chen wrote: > Hi David, > > > It can't be in another KIP as it is required for your proposal to work. > This is also an important part to discuss as it requires the controller to

Re: [DISCUSS] KIP-926: introducing acks=min.insync.replicas config

gt; > > Hi Luke, > > > > > > > Yes, on second thought, I think the new leader election is required > to > > > work > > > for this new acks option. I'll think about it and open another KIP for > it. > > > > > > It can't be in

[DISCUSS] KIP-931: Flag to ignore unused message attribute field

Hi all, I'd like to start a discussion for the KIP-931: Flag to ignore unused message attribute field. This KIP is to add a flag in the batch header to indicate if messages inside the batch have attribute field or not, to reduce the message size, thus, save network traffic and storage size (and mo

Re: Requesting permissions to contribute to Apache Kafka.

Hi MJ, Thanks for the interest in Apache kafka. I've granted your JIRA and wiki account. Looking forward to seeing your contribution! Thanks. Luke On Fri, May 12, 2023 at 11:29 AM Mahesh Jayawardena wrote: > Dear Apache Kafka Development Team, > > My name is Mahesh and I am interested in contr

Re: Unable to access JIRA

Hi Ram, Please submit an account creation request and we'll approve it. https://selfserve.apache.org/jira-account.html Thanks. Luke On Thu, May 11, 2023 at 9:50 PM Ramakrishnan Subramanian < ramkris.subraman...@gmail.com> wrote: > Hi Team, > >I am unable to access JIRA. Also, I would like t

Re: [DISCUSS] KIP-926: introducing acks=min.insync.replicas config

"Ismael Juma"写道： > > > Hi Luke, > > As discussed in the other KIP, there are some subtleties when it comes to > the semantics of the system if we don't wait for all members of the isr > before we ack. I don't understand why you say the leader election question

Re: [VOTE] KIP-872: Add Serializer#serializeToByteBuffer() to reduce memory copying

+1(binding) from me. Thanks for the improvement! Luke On Sun, May 7, 2023 at 6:34 PM Divij Vaidya wrote: > Vote +1 (non binding) > > I think that this is a nice improvement as it prevents an unnecessary data > copy for users who are using ByteBuffer serialization on the producer. > > -- > Divij

Re: [DISCUSS] KIP-927: Improve the kafka-metadata-quorum output

Hi Fede, Thanks for the KIP. LGTM. @Divij I think the timestamp is timezone independent, so it should be fine. Luke On Thu, May 11, 2023 at 2:04 AM Divij Vaidya wrote: > Thank you for the KIP. > > The current proposal has the limitation that it uses a duration syntax for > representation of a

[jira] [Created] (KAFKA-14982) Improve the kafka-metadata-quorum output

Luke Chen created KAFKA-14982: - Summary: Improve the kafka-metadata-quorum output Key: KAFKA-14982 URL: https://issues.apache.org/jira/browse/KAFKA-14982 Project: Kafka Issue Type: Improvement

Re: [DISCUSS] KIP-926: introducing acks=min.insync.replicas config

+Quorum-based+Producer+Acknowledgment > ? > > Ismael > > On Tue, May 9, 2023 at 10:14 PM Luke Chen wrote: > > > Hi all, > > > > I'd like to start a discussion for the KIP-926: introducing > > acks=min.insync.replicas config. This KIP is to introduce

Re: [DISCUSS] KIP-926: introducing acks=min.insync.replicas config

am curious to understand the proposal more, but just thought I'd share > this as it came up. > > Justine > > On Tue, May 9, 2023 at 9:44 AM Luke Chen wrote: > > > Hi all, > > > > I'd like to start a discussion for the KIP-926: introducing > > acks=mi

Re: [DISCUSS] Apache Kafka 3.5.0 release

ider performing an update of the minor versions of > the > > > > > dependencies in 3.5 (per > https://github.com/apache/kafka/pull/13673 > > )? > > > > > > > > > > -- > > > > > Divij Vaidya > > > > > > &

Re: apply for permission to contribute to Apache Kafka

Done. Thanks. Luke On Sat, May 6, 2023 at 9:38 PM Doe John wrote: > my Jira ID: johndoe > > on email zh2725284...@gmail.com > > Thanks! >

[DISCUSS] KIP-926: introducing acks=min.insync.replicas config

Hi all, I'd like to start a discussion for the KIP-926: introducing acks=min.insync.replicas config. This KIP is to introduce `acks=min.insync.replicas` config value in producer, to improve the write throughput and still guarantee high durability. Please check the link for more detail: https://cw

[jira] [Resolved] (KAFKA-14662) ACL listings in documentation are out of date

[ https://issues.apache.org/jira/browse/KAFKA-14662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14662. --- Fix Version/s: 3.6.0 Resolution: Fixed > ACL listings in documentation are out of d

Re: Request to contribute to Kafka

Hi Doe, I've added you into the contributor group. Thanks. Luke On Sat, May 6, 2023 at 11:36 AM Doe John wrote: > my Jira ID: JohnDoe > > on email zh2725284...@gmail.com > > Thanks! >

[jira] [Resolved] (KAFKA-14963) Incorrect partition count metrics for kraft controllers

[ https://issues.apache.org/jira/browse/KAFKA-14963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14963. --- Resolution: Fixed > Incorrect partition count metrics for kraft controll

Re: [DISCUSS] Apache Kafka 3.5.0 release

a > > > longer > > > > > > > duration. We > > > > > > > > > > > > can > > > > > > > > > > > > > > >>> take a call on this later after the reviews > are

Re: Access to create a KIP

Hi Ravindra, Your accounts are all set. Thanks. Luke On Tue, May 2, 2023 at 12:30 AM Ravindra Nath Kakarla < ravindhran...@gmail.com> wrote: > Hi, > > I am trying to create a KIP as part of JIRA > https://issues.apache.org/jira/browse/KAFKA-14952 and need access to the > wiki to create a KIP. B

Re: [DISCUSS] Apache Kafka 3.4.1 release

Hi, I've created a release plan for 3.4.1 in the wiki: https://cwiki.apache.org/confluence/display/KAFKA/Release+plan+3.4.1 The release date will be in May 2023. Please take a look at the plan. This date is approximate at best and subject to change. Bug fix releases are driven both by the impac

Re: [DISCUSS] Adding non-committers as Github collaborators

Hi David, Thanks for the suggestion. I'm +1. This is also a good way to show appreciation from Kafka community to some great contributors who haven't qualified to become committers. Luke On Fri, Apr 28, 2023 at 2:45 AM David Arthur wrote: > Hey folks, > > I stumbled across this wiki page from

Re: Requesting permissions to contribute to Apache Kafka

Hi Keith, Your accounts are all set. Thanks. Luke On Thu, Apr 27, 2023 at 8:44 PM Keith Wall wrote: > Hello, > > I'm following > https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals#KafkaImprovementProposals-GettingStarted > and have reached step 4. > > wiki ID: kwall

Re: KIP-919: Allow AdminClient to Talk Directly with the KRaft Controller Quorum

Hi Colin, Some comments: 1. I agree we should set "top-level" errors for metadata response 2. In the "brokers" field of metadata response from controller, it'll respond with "Controller endpoint information as given in controller.quorum.voters", instead of the "alive" controllers(voters). That wi

[jira] [Resolved] (KAFKA-14944) Reduce CompletedFetch#parseRecord() memory copy

[ https://issues.apache.org/jira/browse/KAFKA-14944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14944. --- Fix Version/s: 3.6.0 Resolution: Fixed > Reduce CompletedFetch#parseRecord() memory c

[jira] [Reopened] (KAFKA-14945) Add Serializer#serializeToByteBuffer() to reduce memory copying

[ https://issues.apache.org/jira/browse/KAFKA-14945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reopened KAFKA-14945: --- > Add Serializer#serializeToByteBuffer() to reduce memory copy

[jira] [Resolved] (KAFKA-14945) Add Serializer#serializeToByteBuffer() to reduce memory copying

[ https://issues.apache.org/jira/browse/KAFKA-14945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14945. --- Fix Version/s: 3.6.0 Resolution: Fixed > Add Serializer#serializeToByteBuffer() to red

[DISCUSS] Apache Kafka 3.4.1 release

Hi all, I'd like to volunteer as release manager for the Apache Kafka 3.4.1 release. If there are no objections, I'll start building a release plan in the wiki in the next couple of days. Thank you. Luke

[jira] [Resolved] (KAFKA-14908) Sporadic "Address already in use" when starting kafka cluster embedded within tests

[ https://issues.apache.org/jira/browse/KAFKA-14908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14908. --- Fix Version/s: 3.6.0 Resolution: Fixed > Sporadic "Address already in use"

Re: Apache Kafka 3.6.0 release

Thanks for volunteering! +1 Luke On Mon, Apr 17, 2023 at 2:03 AM Ismael Juma wrote: > Thanks for volunteering Satish. +1. > > Ismael > > On Sun, Apr 16, 2023 at 10:08 AM Satish Duggana > wrote: > > > Hi, > > I would like to volunteer as release manager for the next release, > > which will be

[jira] [Resolved] (KAFKA-14883) Broker state should be "observer" in KRaft quorum

[ https://issues.apache.org/jira/browse/KAFKA-14883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14883. --- Fix Version/s: 3.5.0 Resolution: Fixed > Broker state should be "observer" in

[jira] [Resolved] (KAFKA-9550) RemoteLogManager - copying eligible log segments to remote storage implementation

[ https://issues.apache.org/jira/browse/KAFKA-9550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-9550. -- Resolution: Fixed > RemoteLogManager - copying eligible log segments to remote stor

Re: [DISCUSS] Apache Kafka 3.5.0 release

t; > > > > > > > wrote: > > > > > >>>>>> > > > > > >>>>>> Thanks Mickael. A couple of notes: > > > > > >>>>>> > > > > > >>>>>> 1. We typically choose a Wednesday for th

[jira] [Resolved] (KAFKA-14889) RemoteLogManager - allow consumer fetch records from remote storage implementation

[ https://issues.apache.org/jira/browse/KAFKA-14889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14889. --- Resolution: Duplicate > RemoteLogManager - allow consumer fetch records from remote stor

[jira] [Created] (KAFKA-14889) RemoteLogManager - allow consumer fetch records from remote storage implementation

Luke Chen created KAFKA-14889: - Summary: RemoteLogManager - allow consumer fetch records from remote storage implementation Key: KAFKA-14889 URL: https://issues.apache.org/jira/browse/KAFKA-14889

[jira] [Created] (KAFKA-14888) RemoteLogManager - deleting expired/size breached log segments to remote storage implementation

Luke Chen created KAFKA-14888: - Summary: RemoteLogManager - deleting expired/size breached log segments to remote storage implementation Key: KAFKA-14888 URL: https://issues.apache.org/jira/browse/KAFKA-14888

Failing tests in Kafka stream is under investigation now

Hi all, Just want to let you know, our current CI test results will contain many(more than 600 in build 1738 ) failed tests. I'm already investigating them now, and have identified some errors and a PR

[jira] [Created] (KAFKA-14877) refactor

Luke Chen created KAFKA-14877: - Summary: refactor Key: KAFKA-14877 URL: https://issues.apache.org/jira/browse/KAFKA-14877 Project: Kafka Issue Type: Sub-task Reporter: Luke Chen

[jira] [Created] (KAFKA-14850) Introduce InMemoryLeaderEpochCheckpoint to allow quick write/read

Luke Chen created KAFKA-14850: - Summary: Introduce InMemoryLeaderEpochCheckpoint to allow quick write/read Key: KAFKA-14850 URL: https://issues.apache.org/jira/browse/KAFKA-14850 Project: Kafka

Re: [VOTE] KIP-911: Add source tag to MirrorSourceConnector metrics

+1 from me. Thanks for the KIP. Luke On Fri, Mar 17, 2023 at 10:56 PM Hector Geraldino (BLOOMBERG/ 919 3RD A) < hgerald...@bloomberg.net> wrote: > +1 (non-binding) > > From: dev@kafka.apache.org At: 03/15/23 07:08:33 UTC-4:00To: > dev@kafka.apache.org > Subject: [VOTE] KIP-911: Add source tag t

Re: [VOTE] KIP-581: Value of optional null field which has default value

+1 (binding) from me. Thank you. Luke On Fri, Mar 17, 2023 at 11:07 PM Tom Bentley wrote: > +1 (binding), thanks again Mickael. > > On Fri, 17 Mar 2023 at 14:56, Chris Egerton > wrote: > > > +1 (binding), thanks Mickael! > > > > On Fri, Mar 17, 2023, 10:11 Mickael Maison > > wrote: > > > > >

Re: [Discuss] KIP-581: Value of optional null field which has default value

Thanks Mickael and Cheng! This KIP LGTM! Thanks. Luke On Fri, Mar 17, 2023 at 7:27 PM Mickael Maison wrote: > Thanks Tom and Chris for your feedback! > > I agree one configuration is enough. I've renamed it to > 'replace.null.with.default'. > Since you both seemed happy with the KIP overall, I'

Re: [DISCUSSION] MirrorMaker2 offset translation for compacted, filtered, and transactional source topics

Hi Greg, Thanks for your summary. I'm not very familiar with MM2, actually, but I'd like to give my answer to some of the questions below: Q1. Would an improvement to allow translation from earlier in the topic be reasonable to propose in a KIP? --> I checked the proposed 5 solutions in KAFKA-146

Re: [VOTE] KIP-906 Tools migration guidelines

+1 from me. Luke On Wed, Mar 15, 2023 at 4:11 PM Federico Valeri wrote: > Hi everyone, > > I'd like to start the vote on KIP-906 Tools migration guidelines. > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-906%3A+Tools+migration+guidelines > > Discussion thread: > https://lists.apach

Re: Request for Permission

Hi Jeff. Your accounts are all set. Thank you. Luke On Wed, Mar 15, 2023 at 7:12 AM Jeff Kim wrote: > Hi, > > I would like to request permission to contribute to the Apache Kafka wiki. > For > > JIRA ID: jeffkbkim > Wiki ID: jeff.kim > > Thanks, > Jeff >

Re: [DISCUSS] Migrating documentation to Markdown/Hugo

Hi Jorge, Maintaining the HTML doc is pretty troublesome. So, I'm +1 to have this migration! My thought is that we can have old version and new(Hugo) version co-existed in kafka-site for a period of time, and then replace the old one. Thank you. Luke On Wed, Mar 8, 2023 at 5:25 AM Jorge Esteban

Re: [ANNOUNCE] New Kafka PMC Member: Chris Egerton

Congratulations, Chris! On Fri, Mar 10, 2023 at 9:57 AM Yash Mayya wrote: > Congratulations Chris! > > On Thu, Mar 9, 2023, 23:42 Jun Rao wrote: > > > Hi, Everyone, > > > > Chris Egerton has been a Kafka committer since July 2022. He has been > very > > instrumental to the community since becom

Re: [ANNOUNCE] New Kafka PMC Member: David Arthur

Congratulations, David! On Fri, Mar 10, 2023 at 9:56 AM Yash Mayya wrote: > Congrats David! > > On Thu, Mar 9, 2023, 23:42 Jun Rao wrote: > > > Hi, Everyone, > > > > David Arthur has been a Kafka committer since 2013. He has been very > > instrumental to the community since becoming a committer

Re: Requesting permissions to contribute to Apache Kafka

Hi Jian, You wiki account is all set. For the JIRA account, please create an account request via here: https://selfserve.apache.org/jira-account.html Thank you. Luke On Mon, Mar 6, 2023 at 10:09 AM jian fu wrote: > [image: image.png] > I think the issue related to this request. Thanks for your

Re: Need Contributer Access (JIRAID- ganeshsahu)

Hi Ganesh, Your account is all set. Thank you. Luke On Fri, Mar 3, 2023 at 12:26 PM Ganesh S wrote: > Hello Team,i have got my JIRA ID created. > Would like to know if I need an additional contributor access to start > contributing. > I would appreciate it if you could inform me if yes. > > My

Re: [DISCUSS] KIP-902: Upgrade Zookeeper to 3.8.1

Hi Christo, Thanks for the KIP. The motivation of upgrading ZK makes sense. And thanks for the great analysis for the ZK upgrading. One question: Since we are going to remove ZK in v4.0, and we don't need the latest feature in the "current release" ZK 3.8.1, why can't we choose the "stable releas

[jira] [Resolved] (KAFKA-14729) The kafakConsumer pollForFetches(timer) method takes up a lot of cpu due to the abnormal exit of the heartbeat thread

[ https://issues.apache.org/jira/browse/KAFKA-14729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14729. --- Fix Version/s: 3.5.0 Resolution: Fixed > The kafakConsumer pollForFetches(timer) met

[jira] [Resolved] (KAFKA-14371) quorum-state file contains empty/unused clusterId field

[ https://issues.apache.org/jira/browse/KAFKA-14371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14371. --- Fix Version/s: 3.5.0 Resolution: Fixed > quorum-state file contains empty/unused cluste

[jira] [Resolved] (KAFKA-14743) MessageConversionsTimeMs for fetch request metric is not updated

[ https://issues.apache.org/jira/browse/KAFKA-14743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14743. --- Fix Version/s: 3.5.0 3.4.1 Resolution: Fixed > MessageConversionsTim

Re: [VOTE] KIP-641 An new java interface to replace 'kafka.common.MessageReader'

+1 from me. Thank you Luke On Sat, Feb 25, 2023 at 8:39 AM Chia-Ping Tsai wrote: > Dear all, > > All comments are addressed , and so please take look at this KIP. It needs > vote and love :) > > thanks.

[jira] [Created] (KAFKA-14756) improve exactly-once-demo example and ExactlyOnceMessageProcessor

Luke Chen created KAFKA-14756: - Summary: improve exactly-once-demo example and ExactlyOnceMessageProcessor Key: KAFKA-14756 URL: https://issues.apache.org/jira/browse/KAFKA-14756 Project: Kafka

[jira] [Created] (KAFKA-14755) improve java-producer-consumer-demo

Luke Chen created KAFKA-14755: - Summary: improve java-producer-consumer-demo Key: KAFKA-14755 URL: https://issues.apache.org/jira/browse/KAFKA-14755 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-14753) improve producer under example package

Luke Chen created KAFKA-14753: - Summary: improve producer under example package Key: KAFKA-14753 URL: https://issues.apache.org/jira/browse/KAFKA-14753 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-14754) improve consumer under example package

Luke Chen created KAFKA-14754: - Summary: improve consumer under example package Key: KAFKA-14754 URL: https://issues.apache.org/jira/browse/KAFKA-14754 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-14752) improve kafka examples under examples package

Luke Chen created KAFKA-14752: - Summary: improve kafka examples under examples package Key: KAFKA-14752 URL: https://issues.apache.org/jira/browse/KAFKA-14752 Project: Kafka Issue Type

[jira] [Created] (KAFKA-14743) MessageConversionsTimeMs metric is not updated

Luke Chen created KAFKA-14743: - Summary: MessageConversionsTimeMs metric is not updated Key: KAFKA-14743 URL: https://issues.apache.org/jira/browse/KAFKA-14743 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-14495) Improve the RemoteIndexCacheTest

[ https://issues.apache.org/jira/browse/KAFKA-14495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14495. --- Fix Version/s: 3.5.0 Resolution: Fixed > Improve the RemoteIndexCacheT

Re: [DISCUSS] KIP-900: KRaft kafka-storage.sh API additions to support SCRAM

Hi Proven, Thanks for the KIP. Some questions: 1. During ZK migrating to KRaft, should we format the KRaft controller with the SCRAM info, or it'll sync from ZK? 2. In the KIP, you provided a link to a doc from Confluent (i.e. this line: See Configuring SCRAM

Re: [VOTE] KIP-894: Use incrementalAlterConfigs API for syncing topic configurations

+1 (binding) from me. Thank you. Luke On Thu, Jan 26, 2023 at 11:24 PM Federico Valeri wrote: > +1 (non binding) > > Thanks. > > On Thu, Jan 26, 2023 at 2:30 PM Gantigmaa Selenge > wrote: > > > > Hi > > > > I'd like to call for a vote on KIP-894, which updates MirrorMaker to use > > Incrementa

Re: Request permissions to contribute to Kafka

Hi, I can't find your wiki ID. Have you created the account in the confluence system ? Luke On Tue, Feb 21, 2023 at 12:05 AM ze zhang wrote: > Hi, > I'd like to request permissions to contribute to Kafka to propos

Re: Requesting permissions to contribute to Apache Kafka.

Hi Jakub, Your wiki account is all set. Thank you. Luke On Fri, Feb 17, 2023 at 4:23 AM Jakub Miroś wrote: > Hello Everyone :) > > According to this guide: > > https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals > Could you give me permissions to contribute to Apache

Re: [DISCUSS] KIP-641 An new java interface to replace 'kafka.common.MessageReader'

Hi Chia-Ping, Thanks for the KIP! Overall LGTM, just one minor comment: Could we log warning messages to users when using deprecated MessageReader? Thank you. Luke On Fri, Feb 17, 2023 at 2:04 PM Chia-Ping Tsai wrote: > hi Bentley > > I have updated the KIP to make RecordReader extend Config

Re: [ANNOUNCE] New committer: Lucas Bradstreet

Congratulations, Lucas! Luke On Fri, Feb 17, 2023 at 8:57 AM Guozhang Wang wrote: > Congratulations, Lucas! > > On Thu, Feb 16, 2023 at 3:18 PM Kowshik Prakasam > wrote: > > > > Congratulations, Lucas! > > > > > > Cheers, > > Kowshik > > > > On Thu, Feb 16, 2023, 2:07 PM Justine Olshan > > >

[jira] [Resolved] (KAFKA-14621) Don't startup in migration mode if an authorizer is enabled

[ https://issues.apache.org/jira/browse/KAFKA-14621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14621. --- Fix Version/s: 3.4.0 Resolution: Done Close this since this is completed in kafka v3.4.0

Re: [DISCUSS] KIP-906 Tools migration guidelines

, currently, KIP-641 is still under discussion, not passing the votes. Do we have any alternative if KIP-641 is rejected? Thank you. Luke On Thu, Feb 16, 2023 at 4:56 PM Federico Valeri wrote: > Hi Luke, thanks for the feedback. > > On Thu, Feb 16, 2023 at 9:33 AM Luke Chen wrote:

Re: [DISCUSS] KIP-906 Tools migration guidelines

Hi Federico, Thanks for the KIP. It's really helpful to have a general guideline for tools migration so that contributors and reviewers can be clear what to be expected. One question: In the broker link tool, you said we should directly deprecate it. But does that mean this tool will keep broken?

Re: Kafka design docs

Hi Arun, The official doc should be good enough: https://kafka.apache.org/documentation/#design For detailed design doc, you can check the Kafka Improvement Proposals: https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals Thank you Luke On Thu, Feb 16, 2023 at 7:27 AM Aru

[jira] [Resolved] (KAFKA-14708) Remove kafka.examples.Consumer dependancy on ShutdownableThread

[ https://issues.apache.org/jira/browse/KAFKA-14708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14708. --- Fix Version/s: 3.5.0 Resolution: Fixed > Remove kafka.examples.Consumer dependancy

[jira] [Resolved] (KAFKA-14695) broker will get LEADER_AND_ISR is not enabled error while ZK migrating to KRaft

[ https://issues.apache.org/jira/browse/KAFKA-14695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14695. --- Resolution: Duplicate > broker will get LEADER_AND_ISR is not enabled error while ZK migrating

[jira] [Created] (KAFKA-14695) broker will get LEADER_AND_ISR is not enabled error while ZK migrating to KRaft

Luke Chen created KAFKA-14695: - Summary: broker will get LEADER_AND_ISR is not enabled error while ZK migrating to KRaft Key: KAFKA-14695 URL: https://issues.apache.org/jira/browse/KAFKA-14695 Project

Re: [DISCUSS] Apache Kafka 3.5.0 release

Hi Mickael, Thanks for volunteering! Luke On Thu, Feb 9, 2023 at 6:23 AM Chris Egerton wrote: > Thanks for volunteering, Mickael! > > On Wed, Feb 8, 2023 at 1:12 PM José Armando García Sancio > wrote: > > > Thanks for volunteering Mickael. > > > > -- > > -José > > >

Re: Request for access

Hi David, Your JIRA (with id: davidmariassy) and wiki account is all set. Thank you. Luke On Thu, Feb 9, 2023 at 4:46 AM David Mariassy wrote: > Hi, > > I'd like to request access to JIRA and permission to contribute to Apache > Kafka. My wiki ID is david.mariassy. If JIRA usernames don't supp

Re: [Possible bug] Failing to use multiple client for multiple cluster using SASL channel.

Hi Sourav, Your JIRA account is all set. Thank you. Luke On Wed, Feb 8, 2023 at 4:24 PM Sourav Biswas wrote: > Hello Chen, > > Please use followings for jira account. > > Email: sourav_biswa...@yahoo.com > > User name: bsourav85 > > Display Name: "Sourav Biswas" or "Sourav" > > > ~ Thanks > >

Re: [Possible bug] Failing to use multiple client for multiple cluster using SASL channel.

Hi Sourav, To create a JIRA account, in addition to email address, we also need your preferred username, display name. Thank you. Luke On Wed, Feb 8, 2023 at 2:01 PM Sourav Biswas wrote: > May I get a jira account > Email id: sourav_biswa...@yahoo.com > > > > > On Sunday, 5 February, 2023

Re: [DISCUSS] KIP-894: Use incrementalAlterConfigs API for syncing topic configurations

Hi Tina, Thanks for the KIP to fix the issue. Some comments: 1. In the compatibility section, you said: `By default, the new setting will be set to false so it does not change the current behaviour.` I'm confused, what is the config we need to set to `false` to avoid breaking compatibility? All

Re: Re: Request for JIRA account creation

t; fqpublic > fqoss > fqsnowstorm > fqfuchsia > > Thanks, > Farooq > > On 2023/02/05 06:29:54 Luke Chen wrote: > > Hi Farooq, > > > > Your wiki ID is all set. > > But for the JIRA account, the user name cannot allow the special > character: > >

Re: Request for JIRA account creation

Hi Farooq, Your wiki ID is all set. But for the JIRA account, the user name cannot allow the special character: ".". Could you provide another user name without special characters? Thank you. Luke On Sun, Feb 5, 2023 at 2:02 AM Fq Public wrote: > Also, I would like permission to contribute to

Re: A query on log truncation.

Hi Vinoth, I'm wondering what's the use case or pain point you're trying to resolve? Like you said, the client will be notified the data is not successfully sent or propagated and handle the error, why should we keep the un-commited records? Could you elaborate more on the motivation? Thank you.

Re: [DISCUSS] Add "Security Implications" section to KIP template

Hi Chris, I like this idea. Thanks for raising this! One question to the template bullet: • Does it make Kafka or any of its components more difficult to run in a fully-secured fashion? I don't quite understand what it means. Could you elaborate on it? Thank you. Luke On Wed, Jan 11, 2023 at 1

[jira] [Created] (KAFKA-14604) SASL session expiration time will be overflowed when calculation

Luke Chen created KAFKA-14604: - Summary: SASL session expiration time will be overflowed when calculation Key: KAFKA-14604 URL: https://issues.apache.org/jira/browse/KAFKA-14604 Project: Kafka

Re: [ANNOUNCE] New committer: Edoardo Comar

Congratulations, Edoardo! Luke On Sat, Jan 7, 2023 at 7:58 AM Mickael Maison wrote: > Congratulations Edo! > > > On Sat, Jan 7, 2023 at 12:05 AM Jun Rao wrote: > > > > Hi, Everyone, > > > > The PMC of Apache Kafka is pleased to announce a new Kafka committer > Edoardo > > Comar. > > > > Edoard

Re: [ANNOUNCE] New committer: Justine Olshan

Congratulations, Justine! Well deserved! Luke On Fri, Dec 30, 2022 at 9:15 AM Ron Dagostino wrote: > Congratulations, Justine!Well-deserved., and I’m very happy for you. > > Ron > > > On Dec 29, 2022, at 6:13 PM, Israel Ekpo wrote: > > > > Congratulations Justine! > > > > > >> On Thu, Dec

[jira] [Created] (KAFKA-14556) log cleaner throttler start time is correct

Luke Chen created KAFKA-14556: - Summary: log cleaner throttler start time is correct Key: KAFKA-14556 URL: https://issues.apache.org/jira/browse/KAFKA-14556 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-14553) RecordAccumulator hangs in infinite NOP loop

[ https://issues.apache.org/jira/browse/KAFKA-14553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14553. --- Fix Version/s: 3.4.0 3.3.2 Resolution: Duplicate > RecordAccumula

Re: [ANNOUNCE] New committer: Satish Duggana

Congratulations, Satish! On Sat, Dec 24, 2022 at 4:12 AM Federico Valeri wrote: > Hi Satish, congrats! > > On Fri, Dec 23, 2022, 8:46 PM Viktor Somogyi-Vass > wrote: > > > Congrats Satish! > > > > On Fri, Dec 23, 2022, 19:38 Mickael Maison > > wrote: > > > > > Congratulations Satish! > > > > >

Re: Kafka issue

Hi Amoli, > The code is working fine with 100 threads and 100 partition topic. It's good to know you have a workable solution. For 500 threads in 500 partitions, could you firstly make sure the topic is created successfully? If topic cannot be created successfully, no records will be sent even if

Re: [DISCUSS] Apache Kafka 3.4.0 release

t > use this method today. > > Ismael > > On Wed, Dec 21, 2022 at 2:22 AM Luke Chen wrote: > > > Hi Sophie and devs, > > > > KAFKA-14540 <https://issues.apache.org/jira/browse/KAFKA-14540> is > > reported > > (from Michael Marshall, thanks!) that

Re: [DISCUSS] Apache Kafka 3.4.0 release

Hi Sophie and devs, KAFKA-14540 is reported (from Michael Marshall, thanks!) that we might write corrupted data to the output stream due to the wrong buffer position set in DataOutputStreamWritable#writeByteBuffer. Had a search in the project, it

Re: [ANNOUNCE] New committer: Josep Prat

Congratulations, Josep! Luke On Wed, Dec 21, 2022 at 6:26 AM Viktor Somogyi-Vass wrote: > Congrats Josep! > > On Tue, Dec 20, 2022, 21:56 Matthias J. Sax wrote: > > > Congrats! > > > > On 12/20/22 12:01 PM, Josep Prat wrote: > > > Thank you all! > > > > > > ——— > > > Josep Prat > > > > > > Aiv

[jira] [Created] (KAFKA-14529) fix failed KafkaServerKRaftRegistrationTest

Luke Chen created KAFKA-14529: - Summary: fix failed KafkaServerKRaftRegistrationTest Key: KAFKA-14529 URL: https://issues.apache.org/jira/browse/KAFKA-14529 Project: Kafka Issue Type: Test

[jira] [Created] (KAFKA-14498) flaky org.apache.kafka.tools.MetadataQuorumCommandTest

Luke Chen created KAFKA-14498: - Summary: flaky org.apache.kafka.tools.MetadataQuorumCommandTest Key: KAFKA-14498 URL: https://issues.apache.org/jira/browse/KAFKA-14498 Project: Kafka Issue Type

[jira] [Created] (KAFKA-14495) Improve the RemoteIndexCacheTest

Luke Chen created KAFKA-14495: - Summary: Improve the RemoteIndexCacheTest Key: KAFKA-14495 URL: https://issues.apache.org/jira/browse/KAFKA-14495 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-14285) Delete quota node in zookeeper when configs are empty

[ https://issues.apache.org/jira/browse/KAFKA-14285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14285. --- Fix Version/s: 3.4.1 3.5.0 Resolution: Fixed > Delete quota node

Re: Kafka AdminClient DEFAULT_API_TIMEOUT_MS_CONFIG property not working as expected

Hi Shruti, Are you sure it creates admin client successfully after setting default.api.timeout.ms=2000 ? It should fail at this check: https://github.com/apache/kafka/blob/trunk/clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java#L618-L621 Try also set request.timeout.ms=20

Re: [DISCUSS] KIP-866 ZooKeeper to KRaft Migration

Thanks for the reply. Yes, I think adding a section in Rejected Alternatives to explain the rationale why we don't support combined mode upgrade in this KIP is helpful. Thank you. Luke On Wed, Nov 30, 2022 at 8:47 AM Jun Rao wrote: > Hi, David, > > Thanks for the reply. No other comments from m

Re: Granting permission for Create KIP and contribute to kafka

Hi t-mac, I've granted your JIRA account. But I can't find the wiki id: "ws" in the wiki system. Are your sure you registered with "ws" here ? Any more info you can provide to us, like account full name? Thank you. L

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