[jira] [Created] (KAFKA-14704) Follower should truncate before incrementing high watermark

David Jacot created KAFKA-14704: --- Summary: Follower should truncate before incrementing high watermark Key: KAFKA-14704 URL: https://issues.apache.org/jira/browse/KAFKA-14704 Project: Kafka

[jira] [Resolved] (KAFKA-14513) Add broker side PartitionAssignor interface

[ https://issues.apache.org/jira/browse/KAFKA-14513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-14513. - Resolution: Fixed > Add broker side PartitionAssignor interface >

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

See Changes: -- [...truncated 531413 lines...] [2023-02-10T00:04:00.353Z] > Task :streams:classes UP-TO-DATE [2023-02-10T00:04:00.353Z] > Task

[jira] [Created] (KAFKA-14703) Don't resign when failing to replay uncommitted records

José Armando García Sancio created KAFKA-14703: -- Summary: Don't resign when failing to replay uncommitted records Key: KAFKA-14703 URL: https://issues.apache.org/jira/browse/KAFKA-14703

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

See

[DISCUSS] KIP-905: Broker interceptors

Hi everyone, I'd like to get a discussion going for KIP-905 , which proposes the addition of broker interceptors to the stack. The KIP contains the motivation, and lists the new public interfaces that this change

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

David Jacot created KAFKA-14701: --- Summary: More broker side assignor to common Key: KAFKA-14701 URL: https://issues.apache.org/jira/browse/KAFKA-14701 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-14702) Extend server side assignor to support rack aware replica placement

David Jacot created KAFKA-14702: --- Summary: Extend server side assignor to support rack aware replica placement Key: KAFKA-14702 URL: https://issues.apache.org/jira/browse/KAFKA-14702 Project: Kafka

Re: [DISCUSS] KIP-903: Replicas with stale broker epoch should not be allowed to join the ISR

Hi Alexandre, 104: I am not aware of any proposals around the up-to-date replica election. It can be a good place to dig deeper. 105: Yes, it almost puts nothing on the performance. Thanks, Calvin On Thu, Feb 9, 2023 at 1:26 AM Alexandre Dupriez < alexandre.dupr...@gmail.com> wrote: > Hi,

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

See

[jira] [Created] (KAFKA-14700) Produce request interceptors

David Mariassy created KAFKA-14700: -- Summary: Produce request interceptors Key: KAFKA-14700 URL: https://issues.apache.org/jira/browse/KAFKA-14700 Project: Kafka Issue Type: Improvement

Re: [DISCUSS] KIP-793: Sink Connectors: Support topic-mutating SMTs for async connectors (preCommit users)

Hi Yash, > So it looks like with the current state of affairs, sink tasks that only instantiate writers in the SinkTask::open method (and don't do the lazy instantiation in SinkTask::put that you mentioned) might fail when used with topic/partition mutating SMTs even if they don't do any

[jira] [Resolved] (KAFKA-9981) Running a dedicated mm2 cluster with more than one nodes,When the configuration is updated the task is not aware and will lose the update operation.

[ https://issues.apache.org/jira/browse/KAFKA-9981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-9981. -- Fix Version/s: 3.5.0 Resolution: Fixed > Running a dedicated mm2 cluster with more than

[jira] [Resolved] (KAFKA-14697) KRaft controller should not send LISR to KRaft brokers during migration

[ https://issues.apache.org/jira/browse/KAFKA-14697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur resolved KAFKA-14697. -- Fix Version/s: (was: 3.5.0) (was: 3.4.1) Resolution:

[jira] [Created] (KAFKA-14699) Kafka Connect framework errors.tolerance improvement

Miguel Costa created KAFKA-14699: Summary: Kafka Connect framework errors.tolerance improvement Key: KAFKA-14699 URL: https://issues.apache.org/jira/browse/KAFKA-14699 Project: Kafka Issue

[jira] [Created] (KAFKA-14698) Received request api key LEADER_AND_ISR which is not enabled

Mickael Maison created KAFKA-14698: -- Summary: Received request api key LEADER_AND_ISR which is not enabled Key: KAFKA-14698 URL: https://issues.apache.org/jira/browse/KAFKA-14698 Project: Kafka

[jira] [Created] (KAFKA-14697) KRaft controller should not send LISR to KRaft brokers during migration

David Arthur created KAFKA-14697: Summary: KRaft controller should not send LISR to KRaft brokers during migration Key: KAFKA-14697 URL: https://issues.apache.org/jira/browse/KAFKA-14697 Project:

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

See

Re: [DISCUSS] KIP-793: Sink Connectors: Support topic-mutating SMTs for async connectors (preCommit users)

Hi Chris, Thanks for the feedback. 1) That's a fair point; while I did scan everything publicly available on GitHub, you're right in that it won't cover all possible SMTs that are out there. Thanks for the example use-case as well, I've updated the KIP to add the two new proposed methods. 2) So

[GitHub] [kafka-site] mimaison merged pull request #490: Fixed typos in KRaft related metrics documentation

mimaison merged PR #490: URL: https://github.com/apache/kafka-site/pull/490 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [kafka-site] ppatierno opened a new pull request, #490: Fixed typos in KRaft related metrics documentation

ppatierno opened a new pull request, #490: URL: https://github.com/apache/kafka-site/pull/490 Trivial PR about fixing a couple of typos on KRaft related metrics documentation. As requested by @mimaison here https://github.com/apache/kafka/pull/13222 -- This is an automated message

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

See

[GitHub] [kafka-site] showuon closed pull request #489: MINOR: explicitly set listener host name

showuon closed pull request #489: MINOR: explicitly set listener host name URL: https://github.com/apache/kafka-site/pull/489 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

[GitHub] [kafka-site] showuon commented on pull request #489: MINOR: explicitly set listener host name

showuon commented on PR #489: URL: https://github.com/apache/kafka-site/pull/489#issuecomment-1423947505 I was wrong. It won't fix it. Please ignore it. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

[GitHub] [kafka-site] showuon commented on pull request #489: MINOR: explicitly set listener host name

showuon commented on PR #489: URL: https://github.com/apache/kafka-site/pull/489#issuecomment-1423932927 @mimaison @mumrah , call for review -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [kafka-site] showuon opened a new pull request, #489: MINOR: explicitly set listener host name

showuon opened a new pull request, #489: URL: https://github.com/apache/kafka-site/pull/489 Workaround the error: ``` org.apache.kafka.common.errors.InvalidRequestException: Received request api key LEADER_AND_ISR which is not enabled [2023-02-08 12:06:25,776] ERROR Exception while

[jira] [Created] (KAFKA-14696) CVE-2023-25194: Apache Kafka: Possible RCE/Denial of service attack via SASL JAAS JndiLoginModule configuration using Kafka Connect

MillieZhang created KAFKA-14696: --- Summary: CVE-2023-25194: Apache Kafka: Possible RCE/Denial of service attack via SASL JAAS JndiLoginModule configuration using Kafka Connect Key: KAFKA-14696 URL:

Re: [DISCUSS] KIP-903: Replicas with stale broker epoch should not be allowed to join the ISR

Hi, Calvin, Many thanks for the replies. 103. Thanks for confirming the testing strategy. Exercising the right sequence of requests is a good idea. 104. Out of scope here, but the KIP reminds that currently, the controller does not attempt to detect data loss on the latest replica in the ISR

Re: [DISCUSS] Apache Kafka 3.5.0 release

Thanks, Mickael! Best, Bruno On 09.02.23 03:15, Luke Chen wrote: 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

[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 to

[jira] [Resolved] (KAFKA-14679) Add new __consumer_offsets records

[ https://issues.apache.org/jira/browse/KAFKA-14679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-14679. - Fix Version/s: 3.5.0 Reviewer: Mickael Maison Resolution: Fixed > Add new

[jira] [Resolved] (KAFKA-14391) Add ConsumerGroupHeartbeat API

[ https://issues.apache.org/jira/browse/KAFKA-14391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-14391. - Fix Version/s: 3.5.0 Reviewer: Jason Gustafson Resolution: Fixed > Add