[jira] [Created] (KAFKA-17717) Remove ConfigUtils#translateDeprecatedConfigs

Chia-Ping Tsai created KAFKA-17717: -- Summary: Remove ConfigUtils#translateDeprecatedConfigs Key: KAFKA-17717 URL: https://issues.apache.org/jira/browse/KAFKA-17717 Project: Kafka Issue Type:

Re: [VOTE] KIP-891: Running multiple versions of Connector plugins

Hi Snehasis, Thanks for the KIP - +1 (non-binding) I just had a question regarding the sample config in https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=235834793#KIP891:RunningmultipleversionsofConnectorplugins-Configuration > "connector.version": "3.8" > "transforms.flatten-ol

[jira] [Resolved] (KAFKA-17714) Fix StorageToolTest.scala to compile under Scala 2.12

[ https://issues.apache.org/jira/browse/KAFKA-17714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-17714. Resolution: Fixed > Fix StorageToolTest.scala to compile under Scala 2.12 > --

[jira] [Resolved] (KAFKA-17540) Create floating tag on trunk for CI cache

[ https://issues.apache.org/jira/browse/KAFKA-17540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] João Pedro Fonseca resolved KAFKA-17540. Resolution: Fixed > Create floating tag on trunk for CI cache > --

Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #80

See

[jira] [Resolved] (KAFKA-17716) remove junit-platform.properties

[ https://issues.apache.org/jira/browse/KAFKA-17716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-17716. Resolution: Won't Fix > remove junit-platform.properties > ---

[jira] [Created] (KAFKA-17716) remove junit-platform.properties

Chia-Ping Tsai created KAFKA-17716: -- Summary: remove junit-platform.properties Key: KAFKA-17716 URL: https://issues.apache.org/jira/browse/KAFKA-17716 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-17715) Remove `force_use_zk_connection` from e2e

Chia-Ping Tsai created KAFKA-17715: -- Summary: Remove `force_use_zk_connection` from e2e Key: KAFKA-17715 URL: https://issues.apache.org/jira/browse/KAFKA-17715 Project: Kafka Issue Type: Sub

[jira] [Resolved] (KAFKA-17624) Remove the E2E uses of accessing ACLs from zk

[ https://issues.apache.org/jira/browse/KAFKA-17624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-17624. Fix Version/s: 4.0.0 Resolution: Fixed > Remove the E2E uses of accessing ACLs from

[jira] [Created] (KAFKA-17714) Fix StorageTool.scala to compile under Scala 2.12

Colin McCabe created KAFKA-17714: Summary: Fix StorageTool.scala to compile under Scala 2.12 Key: KAFKA-17714 URL: https://issues.apache.org/jira/browse/KAFKA-17714 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-16444) Run KIP-848 unit tests under code coverage

[ https://issues.apache.org/jira/browse/KAFKA-16444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True resolved KAFKA-16444. --- Resolution: Won't Do > Run KIP-848 unit tests under code coverage >

Re: [VOTE] KIP-891: Running multiple versions of Connector plugins

Hi Snehashis, Thanks for the KIP. I'm +1 (binding) but have one more non-blocking thought I wanted to share. On the off chance that an existing plugin is designed to accept a "version" property, could we either 1) keep passing that property to plugins instead of stripping it, or 2) rename our new

[jira] [Created] (KAFKA-17713) Ensure snapshots are aligned to batch boundaries

Kevin Wu created KAFKA-17713: Summary: Ensure snapshots are aligned to batch boundaries Key: KAFKA-17713 URL: https://issues.apache.org/jira/browse/KAFKA-17713 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-17711) Minor tidying of ShareConsumeRequestManager

[ https://issues.apache.org/jira/browse/KAFKA-17711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shivsundar R resolved KAFKA-17711. -- Resolution: Fixed > Minor tidying of ShareConsumeRequestManager >

[jira] [Created] (KAFKA-17712) Run recently added integration tests in quarantine

David Arthur created KAFKA-17712: Summary: Run recently added integration tests in quarantine Key: KAFKA-17712 URL: https://issues.apache.org/jira/browse/KAFKA-17712 Project: Kafka Issue Type

Re: [VOTE] KIP-1092: Extend Consumer#close with an option to leave the group or not

Hi TengYao, +1 (non-binding) Thanks for all the work so far on this. Kirk On Mon, Oct 7, 2024, at 4:09 AM, TengYao Chi wrote: > Hi Andrew, > > Thanks for reviewing and participating in the vote. > I have corrected the issue as you pointed out. > > Sincerely, > TengYao > > Andrew Schofield 於

Re: [VOTE] KIP-1089: Allow disabling heartbeats replication in MirrorSourceConnector

Hi, +1 (binding) Thanks, Mickael On Wed, Oct 2, 2024 at 6:39 PM Federico Valeri wrote: > > +1 non binding > > Thanks > > On Wed, Oct 2, 2024 at 3:03 PM Chris Egerton wrote: > > > > +1 (binding), thanks for the KIP! > > > > On Wed, Oct 2, 2024, 06:47 Viktor Somogyi-Vass > > wrote: > > > > > +1

Re: [VOTE] KIP-891: Running multiple versions of Connector plugins

Hey Snehashis, Thanks for the KIP! +1 (binding) Greg On Fri, Oct 4, 2024 at 10:14 PM Snehashis wrote: > Hi everyone > > I would like to call a vote for KIP-891. Please take a moment to review the > proposal and submit your vote. Special thanks to Greg who helped to expand > this to make it muc

RE: [DISCUSS] KIP-1093: Add more observability for MirrorMaker2

Thank you for your insights on Kafka MirrorMaker2's observability. In addition to your proposed metrics, I'm wondering if there are plans to include a metric for replication delay. This could provide vital information about the number of messages yet to be replicated, similar to consumer lag. Co

[jira] [Created] (KAFKA-17711) Minor tidying of ShareConsumeRequestManager

Shivsundar R created KAFKA-17711: Summary: Minor tidying of ShareConsumeRequestManager Key: KAFKA-17711 URL: https://issues.apache.org/jira/browse/KAFKA-17711 Project: Kafka Issue Type: Sub-t

Re: [DISCUSS] Apache Kafka 4.0.0 release

Hi all, I have drafted the release plan for Apache Kafka 4.0.0: https://cwiki.apache.org/confluence/display/KAFKA/Release+Plan+4.0.0. Please take a look and let me know what you think. I would also appreciate it if you could review the list of KIPs that we will ship in this release. I took the li

[jira] [Resolved] (KAFKA-17664) Generate ShareAcknowledgeCommitCallbackEvent only when the callback is configured.

[ https://issues.apache.org/jira/browse/KAFKA-17664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shivsundar R resolved KAFKA-17664. -- Resolution: Fixed > Generate ShareAcknowledgeCommitCallbackEvent only when the callback is >

Re: [VOTE] KIP-1073: Return fenced brokers in DescribeCluster response

Thank you for voting Federico and Luke! Is there anyone else who would like to vote on this KIP please? It still needs 2 more +1 binding :) Regards, Tina On Wed, Sep 25, 2024 at 8:40 AM Federico Valeri wrote: > +1 non binding > > Thanks Tina > > On Wed, Sep 25, 2024 at 5:29 AM Luke Chen wrote

Re: [VOTE] KIP-1092: Extend Consumer#close with an option to leave the group or not

Hi Andrew, Thanks for reviewing and participating in the vote. I have corrected the issue as you pointed out. Sincerely, TengYao Andrew Schofield 於 2024年10月7日 週一 下午6:44寫道： > Thanks for the KIP. > > +1 (non-binding) > > I have one tiny nit that in the text but not the code snippet, you mention

Re: [VOTE] KIP-1092: Extend Consumer#close with an option to leave the group or not

Thanks for the KIP. +1 (non-binding) I have one tiny nit that in the text but not the code snippet, you mention methods called CloseOption.withTimeoutFluent(Duration timeout) and CloseOption.withGroupMembershipOperationFluent(GroupMembershipOperation operation). I expect you meant to remove "Fl

[jira] [Resolved] (KAFKA-15889) Make General Assignor's rebalance incremental

[ https://issues.apache.org/jira/browse/KAFKA-15889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-15889. - Resolution: Won't Fix > Make General Assignor's rebalance incremental >

[jira] [Resolved] (KAFKA-14955) Validate that all partitions are assigned in TargetAssignmentBuilder

[ https://issues.apache.org/jira/browse/KAFKA-14955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-14955. - Resolution: Won't Fix > Validate that all partitions are assigned in TargetAssignmentBuilder > -

[jira] [Resolved] (KAFKA-17707) Remove zk from BaseConsumerTest

[ https://issues.apache.org/jira/browse/KAFKA-17707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-17707. Fix Version/s: 4.0.0 Resolution: Fixed > Remove zk from BaseConsumerTest >

Re: [VOTE] KIP-1094 Add a new constructor method with nextOffsets to ConsumerRecords

Hi Alieh, Thanks for the KIP! +1 (binding) Best, Bruno On 07.10.24 11:28, Andrew Schofield wrote: Thanks for the KIP. Looks good to me. +1 (non-binding) Andrew From: Lucas Brutschy Sent: 04 October 2024 07:42 To: dev@kafka.apache.org Subject: Re:

Re: [VOTE] KIP-1094 Add a new constructor method with nextOffsets to ConsumerRecords

Thanks for the KIP. Looks good to me. +1 (non-binding) Andrew From: Lucas Brutschy Sent: 04 October 2024 07:42 To: dev@kafka.apache.org Subject: Re: [VOTE] KIP-1094 Add a new constructor method with nextOffsets to ConsumerRecords +1 (binding) Thanks

[jira] [Resolved] (KAFKA-17317) Validate and maybe trigger downgrade after static member replacement

[ https://issues.apache.org/jira/browse/KAFKA-17317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-17317. - Fix Version/s: 4.0.0 Resolution: Fixed > Validate and maybe trigger downgrade after stati

Re: [VOTE] KIP-1092: Extend Consumer#close with an option to leave the group or not

Hi Chia-Ping, Thanks for pointing that out. I originally wrote the full version to show the equivalent semantic example, but you're absolutely right—it can be simplified by omitting `.withGroupMembershipOperation(GroupMembershipOperation.DEFAULT)` since it's the default value. This actually gave

Re: [DISCUSS] KIP-1071: Streams Rebalance Protocol

Hi all, we did some major changes to this KIP that we would like the community to review. The changes are the following: 1. We merged the Streams group initialize RPC into the Streams group heartbeat RPC. We decided to merge them because it simplifies the sychronization between initializatio

[jira] [Resolved] (KAFKA-17564) Move BrokerFeatures to server module

[ https://issues.apache.org/jira/browse/KAFKA-17564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-17564. Fix Version/s: 4.0.0 Resolution: Fixed > Move BrokerFeatures to server module > ---