Re: Re: KIP 678: New Kafka Connect SMT for plainText => Struct(or Map) with Regex

Hi whsoul, Would you mind updating the KIP document ( https://cwiki.apache.org/confluence/display/KAFKA/KIP+678%3A+New+Kafka+Connect+SMT+for+plainText+%3D%3E+Struct%28or+Map%29+with+Regex) with all of these changes? We tend to discuss and vote on what's included in the Wiki as our source of truth,

Re: [DISCUSS] KIP-821: Connect Transforms support for nested structures

Hi Jorge, I've done some more thinking and I hate to say it, but I think the syntax does need to be expanded. Right now it's clear what "a.b" refers to and what "a..b" refers to, but what about "a...b"? Is that referring to subfield ".b" of field "a", or subfield "b" of field "a."? This gets even

Re: [VOTE] KIP-836: Addition of Information in DescribeQuorumResponse about Voter Lag

Thanks for taking a look Gouzhang. That is an accurate summary of the changes. - Niket > On Jun 13, 2022, at 2:19 PM, Guozhang Wang wrote: > > Hello Niket, > > I took a look at the diffs of the wiki page history and it seems the > updates are: > > 1) Removing the topic name from QuorumInfo. >

[jira] [Created] (KAFKA-13987) BlockingConnectorTest causing flakiness in other tests

Chris Egerton created KAFKA-13987: - Summary: BlockingConnectorTest causing flakiness in other tests Key: KAFKA-13987 URL: https://issues.apache.org/jira/browse/KAFKA-13987 Project: Kafka Issu

Jenkins build is back to stable : Kafka » Kafka Branch Builder » trunk #1001

See

Re: [VOTE] KIP-836: Addition of Information in DescribeQuorumResponse about Voter Lag

Hello Niket, I took a look at the diffs of the wiki page history and it seems the updates are: 1) Removing the topic name from QuorumInfo. 2) Making ReplicaState public APIs more aligned with existing ones. 3) Renaming from DescribeQuorumResult to DescribeMetadataQuorumResult. Is that all? If ye

[jira] [Created] (KAFKA-13986) DescribeQuorum does not return the observers (brokers) for the Metadata log

Niket Goel created KAFKA-13986: -- Summary: DescribeQuorum does not return the observers (brokers) for the Metadata log Key: KAFKA-13986 URL: https://issues.apache.org/jira/browse/KAFKA-13986 Project: Kafk

Re: [VOTE] KIP-836: Addition of Information in DescribeQuorumResponse about Voter Lag

Hi all, An update on KIP-836; while iterating on the PR some finer details in the naming of the API handler and related classes in the Admin Client has changed. I have updated the KIP with the changes. Please provide any feedback you may have on the changes made. PR - https://github.com/apache/

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

See

Re: [VOTE] KIP-831: Add metric for log recovery progress

Hi, Luke, Thanks for the KIP. +1 from me. Jun On Mon, Jun 13, 2022 at 8:04 AM Mickael Maison wrote: > +1 (binding) > > Thanks for the KIP! > > Mickael > > On Sun, Jun 12, 2022 at 5:26 PM Yu Kvicii wrote: > > > > +1 non binding. Thanks > > > > > > > On May 16, 2022, at 15:11, Luke Chen wrote:

Re: [VOTE] KIP-831: Add metric for log recovery progress

+1 (binding) Thanks for the KIP! Mickael On Sun, Jun 12, 2022 at 5:26 PM Yu Kvicii wrote: > > +1 non binding. Thanks > > > > On May 16, 2022, at 15:11, Luke Chen wrote: > > > > Hi all, > > > > I'd like to start a vote on KIP to expose metrics for log recovery > > progress. These metrics would

[jira] [Reopened] (KAFKA-13414) Replace Powermock/EasyMock by Mockito in connect.storage package

[ https://issues.apache.org/jira/browse/KAFKA-13414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison reopened KAFKA-13414: My PR only updated some of the classes under connect.storage. The following files still need

[jira] [Resolved] (KAFKA-13436) Omitted BrokerTopicMetrics metrics in the documentation

[ https://issues.apache.org/jira/browse/KAFKA-13436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-13436. Fix Version/s: 3.3.0 Resolution: Fixed > Omitted BrokerTopicMetrics metrics in the

[jira] [Created] (KAFKA-13985) MirrorSourceTask commitRecord throws NPE if SMT is filtering out source record

Jacopo created KAFKA-13985: -- Summary: MirrorSourceTask commitRecord throws NPE if SMT is filtering out source record Key: KAFKA-13985 URL: https://issues.apache.org/jira/browse/KAFKA-13985 Project: Kafka

[jira] [Created] (KAFKA-13984) Fix TopicBasedRemoteLogMetadataManager#initializeResources should return immediately when the result of isPartitionsCountSameAsConfigured method is false

zhaobo created KAFKA-13984: -- Summary: Fix TopicBasedRemoteLogMetadataManager#initializeResources should return immediately when the result of isPartitionsCountSameAsConfigured method is false Key: KAFKA-13984 URL: https

[jira] [Created] (KAFKA-13983) Support special character in Resource name in ACLs operation by sanitizing

Aman Singh created KAFKA-13983: -- Summary: Support special character in Resource name in ACLs operation by sanitizing Key: KAFKA-13983 URL: https://issues.apache.org/jira/browse/KAFKA-13983 Project: Kafk

RE: [External] Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #995

Hi Bruno, Thank you a lot for your feedback. Sorry for the wrong thread mail. I have also written a single mail (in attach). Regards, Nicola Nozza -Original Message- From: Bruno Cadonna Sent: lunedì 13 giugno 2022 11:25 To: dev@kafka.apache.org; Nozza, Nicola Subject: Re: [External]

[jira] [Created] (KAFKA-13982) Replace EasyMock and PowerMock with Mockito for WorkerConfigTransformerTest

Christo Lolov created KAFKA-13982: - Summary: Replace EasyMock and PowerMock with Mockito for WorkerConfigTransformerTest Key: KAFKA-13982 URL: https://issues.apache.org/jira/browse/KAFKA-13982 Project

Re: [External] Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #995

Hi Nicola, The ETA for Kafka 4.0 in which log4j will be updated to version 2 is going to be released in the second half of 2023. In the meanwhile we replaced log4j with reload4j in release 3.2.0. Reload4j closes the known vulnerabilities of log4j1. Out of curiosity, why do you reply to a Je

[jira] [Resolved] (KAFKA-13414) Replace Powermock/EasyMock by Mockito in connect.storage package

[ https://issues.apache.org/jira/browse/KAFKA-13414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Christo Lolov resolved KAFKA-13414. --- Resolution: Fixed > Replace Powermock/EasyMock by Mockito in connect.storage package > -