[jira] [Created] (KAFKA-14768) proposal to reduce the first message's send time cost and max block time for safety

fujian created KAFKA-14768: -- Summary: proposal to reduce the first message's send time cost and max block time for safety Key: KAFKA-14768 URL: https://issues.apache.org/jira/browse/KAFKA-14768 Project:

Kafka back-pressure | Proposal for dynamic config

Hi Team, I am looking for an effective back pressure solution in Kafka Please find below my use case and detail. Use case: I need to run “some execution” when receiving a Kafka record. Some execution could be an external API call, And it is possible that sometimes this API may not perform

Re: [DISCUSS] KIP-909: Allow clients to rebootstrap DNS lookup failure

Hey Chris, Thanks again for the feedback! For the preflight DNS check (are we basically trying to resolve the DNS there?): Maybe it makes more sense to add it to the Config modules? I would like to hear what the community says as I'm not familiar with the Connect use case. A "slower failing"

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

See

[jira] [Created] (KAFKA-14767) Gradle build fails with missing commitId after git gc

Greg Harris created KAFKA-14767: --- Summary: Gradle build fails with missing commitId after git gc Key: KAFKA-14767 URL: https://issues.apache.org/jira/browse/KAFKA-14767 Project: Kafka Issue

RE: [VOTE] KIP-907: Add Boolean Serde to public interface

+1 (binding)

Re: [VOTE] KIP-907: Add Boolean Serde to public interface

+1, thanks! On Fri, Feb 24, 2023 at 5:43 AM SpacRocket wrote: > Hi Everyone, > > I'd like to call for a vote on KIP-907, which proposes new public classes > to the package org.apache.kafka.common.serialization: > - BooleanSerde > - BooleanSerializer > - BooleanDeserializer > > KIP: >

[jira] [Resolved] (KAFKA-14468) Refactor Commit Logic

[ https://issues.apache.org/jira/browse/KAFKA-14468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True resolved KAFKA-14468. --- Resolution: Fixed [~pnee] can you fill in the details on the fixed versions? Thanks! > Refactor

[jira] [Resolved] (KAFKA-14264) Refactor coordinator code

[ https://issues.apache.org/jira/browse/KAFKA-14264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True resolved KAFKA-14264. --- Resolution: Fixed [~pnee] can you fill in the details on the fixed versions? Thanks! > Refactor

Re: [VOTE] KIP-904: Kafka Streams - Guarantee subtractor is called before adder if key has not changed

+1. On Sun, Feb 26, 2023 at 4:27 PM Fq Public wrote: > > Hi everyone, > > I'd like to start the vote on KIP-904: Kafka Streams - Guarantee subtractor > is called before adder if key has not changed. > The KIP is available here: https://cwiki.apache.org/confluence/x/P5VbDg > The easiest way to

Re: [VOTE] KIP-898: Modernize Connect plugin discovery

+1 (binding). Thanks for the KIP! On Mon, Feb 27, 2023 at 12:51 PM Greg Harris wrote: > Hi, > > I'd like to call a vote for KIP-898 which aims to improve the performance > of Connect startup by allowing discovery of plugins via the ServiceLoader. > > KIP: >

[VOTE] KIP-898: Modernize Connect plugin discovery

Hi, I'd like to call a vote for KIP-898 which aims to improve the performance of Connect startup by allowing discovery of plugins via the ServiceLoader. KIP: https://cwiki.apache.org/confluence/display/KAFKA/KIP-898 %3A+Modernize+Connect+plugin+discovery Discussion thread:

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

Hi Jason, Updated the fields accordingly. Also, rename the BrokerState to ReplicaState. Thanks. On Wed, Feb 22, 2023 at 4:38 PM Jason Gustafson wrote: > Hi Calvin, > > The `BrokerState` struct I suggested would replace the `BrokerId` field in > older versions. > > { "name": "ReplicaId",

Re: [DISCUSS] KIP-909: Allow clients to rebootstrap DNS lookup failure

Hi Philip, Yeah, "DNS resolution should occur..." seems like a better fit.  One other question I have is whether we should expose some kind of public API for performing preflight validation of the bootstrap URLs. If we change the behavior of a client configured with a silly typo (e.g.,

[jira] [Created] (KAFKA-14766) Improve performance of VarInt encoding/decoding

Divij Vaidya created KAFKA-14766: Summary: Improve performance of VarInt encoding/decoding Key: KAFKA-14766 URL: https://issues.apache.org/jira/browse/KAFKA-14766 Project: Kafka Issue Type:

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

See Changes: -- [...truncated 535704 lines...] [2023-02-27T17:11:10.578Z] [2023-02-27T17:11:10.578Z] Gradle Test Run :core:integrationTest > Gradle Test Executor 173 >

Re: [VOTE] KIP-864: Add End-To-End Latency Metrics to Connectors

+1 (non binding) On Mon, Feb 27, 2023 at 11:21 AM Chris Egerton wrote: > Hi all, > > I could have sworn I +1'd this but I can't seem to find a record of that. > > In the hopes that this action is idempotent, +1 (binding). Thanks for the > KIP! > > Cheers, > > Chris > > On Mon, Feb 27, 2023 at

Re: [VOTE] KIP-864: Add End-To-End Latency Metrics to Connectors

Hi all, I could have sworn I +1'd this but I can't seem to find a record of that. In the hopes that this action is idempotent, +1 (binding). Thanks for the KIP! Cheers, Chris On Mon, Feb 27, 2023 at 6:28 AM Mickael Maison wrote: > Thanks for the KIP > > +1 (binding) > > On Thu, Jan 26, 2023

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

Hi David > > - The new interface looks good to me. Note that the javadoc does not > reflect the new interface though. > - Could we precise how errors will be handled? For instance, say that the > iterator could translate the input stream to a record. Would calling the > next method on the

[jira] [Created] (KAFKA-14765) Support SCRAM for brokers at bootstrap

Proven Provenzano created KAFKA-14765: - Summary: Support SCRAM for brokers at bootstrap Key: KAFKA-14765 URL: https://issues.apache.org/jira/browse/KAFKA-14765 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-14764) Metadata API ignores topic names if at least one topic is provided with an id

David Jacot created KAFKA-14764: --- Summary: Metadata API ignores topic names if at least one topic is provided with an id Key: KAFKA-14764 URL: https://issues.apache.org/jira/browse/KAFKA-14764 Project:

[jira] [Resolved] (KAFKA-14387) kafka.common.KafkaException | kafka_2.12-3.3.1.jar

[ https://issues.apache.org/jira/browse/KAFKA-14387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andras Katona resolved KAFKA-14387. --- Resolution: Information Provided > kafka.common.KafkaException | kafka_2.12-3.3.1.jar >

[jira] [Resolved] (KAFKA-14738) Topic disappears from kafka_topic.sh --list after modifying it with kafka_acl.sh

[ https://issues.apache.org/jira/browse/KAFKA-14738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andras Katona resolved KAFKA-14738. --- Resolution: Not A Bug > Topic disappears from kafka_topic.sh --list after modifying it with

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

See Changes: -- [...truncated 449191 lines...] [2023-02-27T14:35:09.782Z] Gradle Test Run :streams:integrationTest > Gradle Test Executor 182 >

[jira] [Resolved] (KAFKA-14060) Replace EasyMock and PowerMock with Mockito in AbstractWorkerSourceTaskTest

[ https://issues.apache.org/jira/browse/KAFKA-14060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-14060. --- Resolution: Done > Replace EasyMock and PowerMock with Mockito in

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

Thanks for the update. - The new interface looks good to me. Note that the javadoc does not reflect the new interface though. - Could we precise how errors will be handled? For instance, say that the iterator could translate the input stream to a record. Would calling the next method on the

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

See Changes: -- [...truncated 541816 lines...] [2023-02-27T12:00:39.044Z] [2023-02-27T12:00:39.044Z] Gradle Test Run :core:integrationTest > Gradle Test Executor 177 >

Re: [VOTE] KIP-864: Add End-To-End Latency Metrics to Connectors

Thanks for the KIP +1 (binding) On Thu, Jan 26, 2023 at 4:36 PM Jorge Esteban Quilcate Otoya wrote: > > Hi all, > > I'd like to call for a vote on KIP-864, which proposes to add metrics to > measure end-to-end latency in source and sink connectors. > > KIP: >

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

The KIP is accepted with 3 binding votes (Chris, Luke, Mickael) and 1 non-binding vote (Federico). Thank you all. Regards, Tina

[jira] [Created] (KAFKA-14763) Add integration test for DelegationTokenCommand tool

Gantigmaa Selenge created KAFKA-14763: - Summary: Add integration test for DelegationTokenCommand tool Key: KAFKA-14763 URL: https://issues.apache.org/jira/browse/KAFKA-14763 Project: Kafka

[jira] [Reopened] (KAFKA-14206) Upgrade zookeeper to 3.7.1 to address security vulnerabilities

[ https://issues.apache.org/jira/browse/KAFKA-14206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Valeriy Kassenbayev reopened KAFKA-14206: - Still have the same CVEs reported: {code:java}   ✗ Denial of Service (DoS) [High

[jira] [Resolved] (KAFKA-14680) Gradle version upgrade 7 -->> 8

[ https://issues.apache.org/jira/browse/KAFKA-14680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-14680. - Fix Version/s: 3.5.0 Resolution: Fixed > Gradle version upgrade 7 -->> 8 >

[jira] [Resolved] (KAFKA-14749) Re-enable 'spotlessScalaCheck' task (in Jenkinsfile)

[ https://issues.apache.org/jira/browse/KAFKA-14749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-14749. - Assignee: Ismael Juma Resolution: Fixed We found a way to re-enable this when running