Re: Apache Kafka 3.6.0 release

Hi Satish, KIP-793 [1] just passed voting and we should be able to wrap up the implementation in time for the 3.6.0 feature freeze. Could we add it to the release plan? [1] - https://cwiki.apache.org/confluence/display/KAFKA/KIP-793%3A+Allow+sink+connectors+to+be+used+with+topic-mutating+SMTs

Re: [VOTE] KIP-793: Allow sink connectors to be used with topic-mutating SMTs

Hi all, Thanks to everyone who participated in the voting and the discussion. I'll close the voting since it has been open for over 72 hours and we have a sufficient number of votes. KIP-793 has been accepted with the following +1 votes (and no +0 or -1 votes): - Chris Egerton (binding) -

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

See

Re: Permission to contribute to Apache Kafka

Hi Shay, Your accounts are all set. Thanks. Luke On Fri, Jul 7, 2023 at 7:08 AM Shay Lin wrote: > Hi all, > > Could you give me the appropriate access (edit Wiki/KIP, Jira etc) to > contribute to AK? > > My confluence and Jira IDs are the same: lqxshay > > Thanks in advance, > Shay >

Permission to contribute to Apache Kafka

Hi all, Could you give me the appropriate access (edit Wiki/KIP, Jira etc) to contribute to AK? My confluence and Jira IDs are the same: lqxshay Thanks in advance, Shay

Re: [VOTE] KIP-944 Support async runtimes in consumer, votes needed!

Dear PMCs, So far there have been 0 responses to KIP-944. I understand this may not be something that keeps you busy, but this KIP is important to people that use async runtimes like Zio, Cats and Kotlin. Is there anything you need to come to a decision? Kind regards,     Erik. Op

[GitHub] [kafka-site] stevenbooke commented on pull request #521: KAFKA-14995: Automate asf.yaml collaborators refresh

stevenbooke commented on PR #521: URL: https://github.com/apache/kafka-site/pull/521#issuecomment-1624159774 @mimaison Could you review this and merge if there is no issues please? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

Re: [VOTE] KIP-793: Allow sink connectors to be used with topic-mutating SMTs

Hi, Yash. Thanks for the KIP and for fixing this long standing issue. +1 (binding) Randall On Tue, Jul 4, 2023 at 8:32 AM Mickael Maison wrote: > Hi, > > +1 (binding) > Thanks for the KIP > > Mickael > > > On Mon, Jul 3, 2023 at 8:18 PM Greg Harris > wrote: > > > > Hey Yash, > > > > Thanks

[jira] [Resolved] (KAFKA-15069) Refactor scanning hierarchy out of DelegatingClassLoader

[ https://issues.apache.org/jira/browse/KAFKA-15069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-15069. - Reviewer: Chris Egerton Resolution: Fixed > Refactor scanning hierarchy out of

[GitHub] [kafka-site] stevenbooke commented on pull request #521: KAFKA-14995: Automate asf.yaml collaborators refresh

stevenbooke commented on PR #521: URL: https://github.com/apache/kafka-site/pull/521#issuecomment-1624069492 Ok, I will make the change now. -- 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

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

Thanks for the KIP. It seems we are in very early stage, and some very important sections in the KIP are still marked as TODO. In particular, I am curious about the protocol changes, how the "queuing state" will be represented and made durable, and all the error edge case / fail-over /

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

See Changes: -- [...truncated 397495 lines...] Gradle Test Run :streams:integrationTest > Gradle Test Executor 180 > TableTableJoinIntegrationTest > [caching enabled =

[GitHub] [kafka-site] mimaison commented on pull request #521: KAFKA-14995: Automate asf.yaml collaborators refresh

mimaison commented on PR #521: URL: https://github.com/apache/kafka-site/pull/521#issuecomment-1623947447 The latest committer is Divij Vaidya, see at the bottom of https://kafka.apache.org/committers. His Github username is `divijvaidya`. -- This is an automated message from the

[GitHub] [kafka-site] stevenbooke commented on pull request #521: KAFKA-14995: Automate asf.yaml collaborators refresh

stevenbooke commented on PR #521: URL: https://github.com/apache/kafka-site/pull/521#issuecomment-1623938985 Who is the new Committer? What is their Github username? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Created] (KAFKA-15159) Update minor dependencies in preparation for 3.5.1

Divij Vaidya created KAFKA-15159: Summary: Update minor dependencies in preparation for 3.5.1 Key: KAFKA-15159 URL: https://issues.apache.org/jira/browse/KAFKA-15159 Project: Kafka Issue

[jira] [Resolved] (KAFKA-15153) Use Python `is` instead of `==` to compare for None

[ https://issues.apache.org/jira/browse/KAFKA-15153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Divij Vaidya resolved KAFKA-15153. -- Reviewer: Divij Vaidya Resolution: Fixed > Use Python `is` instead of `==` to compare

[jira] [Created] (KAFKA-15158) Add metrics for RemoteRequestsPerSec

Divij Vaidya created KAFKA-15158: Summary: Add metrics for RemoteRequestsPerSec Key: KAFKA-15158 URL: https://issues.apache.org/jira/browse/KAFKA-15158 Project: Kafka Issue Type: Sub-task

Re: Permission to contribute to Apache Kafka

Hi, Thanks for your interest in contributing! You should be all set to go now. Cheers, Chris On Thu, Jul 6, 2023 at 9:18 AM Jacob wrote: > Hi master, > > Could you help grant me permissions to contribute to Kafka? > > Wiki ID: zixuanbai > Jira ID: zixuan > > Thanks a lot! > > Best regards,

[jira] [Created] (KAFKA-15157) Print startup time for RemoteIndexCache

Divij Vaidya created KAFKA-15157: Summary: Print startup time for RemoteIndexCache Key: KAFKA-15157 URL: https://issues.apache.org/jira/browse/KAFKA-15157 Project: Kafka Issue Type: Sub-task

Permission to contribute to Apache Kafka

Hi master, Could you help grant me permissions to contribute to Kafka? Wiki ID: zixuanbai Jira ID: zixuan Thanks a lot! Best regards,

Re: [DISCUSS] KIP-943: Add independent "offset.storage.segment.bytes" for connect-distributed.properties

Also, just adding to the above point - we don't necessarily need to explicitly add a new worker configuration right? Instead, we could potentially just use the new proposed default value internally which can be overridden by users through setting a value for "offset.storage.segment.bytes" (via the

Re: [DISCUSS] KIP-943: Add independent "offset.storage.segment.bytes" for connect-distributed.properties

Hi hudeqi, Thanks for the KIP! Just to clarify - since KIP-605 ( https://cwiki.apache.org/confluence/display/KAFKA/KIP-605%3A+Expand+Connect+Worker+Internal+Topic+Settings) already allows configuring "segment.bytes" for the Connect cluster's offsets topic via a worker configuration

[jira] [Resolved] (KAFKA-15151) Missing connector-stopped-task-count metric

[ https://issues.apache.org/jira/browse/KAFKA-15151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-15151. Resolution: Invalid > Missing connector-stopped-task-count metric >

[DISCUSS] KIP-948: Allow custom prefix for internal topic names in Kafka Streams

Hi everyone, I would like to start a discussion on the following KIP: KIP-948: Allow custom prefix for internal topic names in Kafka Streams https://cwiki.apache.org/confluence/display/KAFKA/KIP-948%3A+Allow+custom+prefix+for+internal+topic+names+in+Kafka+Streams The goal is to provide greater

[jira] [Created] (KAFKA-15156) Update cipherInformation correctly in DefaultChannelMetadataRegistry

Divij Vaidya created KAFKA-15156: Summary: Update cipherInformation correctly in DefaultChannelMetadataRegistry Key: KAFKA-15156 URL: https://issues.apache.org/jira/browse/KAFKA-15156 Project: Kafka

[jira] [Created] (KAFKA-15155) Follow PEP 8 best practice in Python to check if a container is empty

Divij Vaidya created KAFKA-15155: Summary: Follow PEP 8 best practice in Python to check if a container is empty Key: KAFKA-15155 URL: https://issues.apache.org/jira/browse/KAFKA-15155 Project: Kafka

[jira] [Created] (KAFKA-15154) Potential bug: We don't acquire lock when reading checkQuotas

Divij Vaidya created KAFKA-15154: Summary: Potential bug: We don't acquire lock when reading checkQuotas Key: KAFKA-15154 URL: https://issues.apache.org/jira/browse/KAFKA-15154 Project: Kafka

[jira] [Created] (KAFKA-15153) Use Python `is` instead of `==` to compare for None

Divij Vaidya created KAFKA-15153: Summary: Use Python `is` instead of `==` to compare for None Key: KAFKA-15153 URL: https://issues.apache.org/jira/browse/KAFKA-15153 Project: Kafka Issue

[jira] [Created] (KAFKA-15152) Fix incorrect format specifiers when formatting string

Divij Vaidya created KAFKA-15152: Summary: Fix incorrect format specifiers when formatting string Key: KAFKA-15152 URL: https://issues.apache.org/jira/browse/KAFKA-15152 Project: Kafka Issue

[jira] [Created] (KAFKA-15151) Missing connector-stopped-task-count metric

Mickael Maison created KAFKA-15151: -- Summary: Missing connector-stopped-task-count metric Key: KAFKA-15151 URL: https://issues.apache.org/jira/browse/KAFKA-15151 Project: Kafka Issue Type: