Re: Re: [DISCUSS] KIP-842: Add richer group offset reset mechanisms

I think so too, what about Guozhang Wang and Luke Chen? Can I initiate a voting process? Best, hudeqi > -原始邮件- > 发件人: "邓子明" > 发送时间: 2022-06-07 10:23:37 (星期二) > 收件人: dev@kafka.apache.org > 抄送: > 主题: Re: [DISCUSS] KIP-842: Add richer group offset reset mechanisms >

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

See

[jira] [Created] (KAFKA-13962) KRaft StripedReplicaPlacer should handle replicas in controlled shutdown

David Jacot created KAFKA-13962: --- Summary: KRaft StripedReplicaPlacer should handle replicas in controlled shutdown Key: KAFKA-13962 URL: https://issues.apache.org/jira/browse/KAFKA-13962 Project: Kafka

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

Hi Chris, Thank you for your positive feed back, And sorry about late reply ( I didn’t recognize your reply email… TT ) And I update KIP and PR with your review https://cwiki.apache.org/confluence/display/KAFKA/KIP+678%3A+New+Kafka+Connect+SMT+for+plainText+%3D%3E+Struct%28or+Map%29+with+Regex 1

[jira] [Created] (KAFKA-13963) Topology Description ignores context.forward

Tomasz Kaszuba created KAFKA-13963: -- Summary: Topology Description ignores context.forward Key: KAFKA-13963 URL: https://issues.apache.org/jira/browse/KAFKA-13963 Project: Kafka Issue Type:

Re: [VOTE] KIP-840: Config file option for MessageReader/MessageFormatter in ConsoleProducer/ConsoleConsumer

Hi! A little reminder to vote for this KIP. Thanks. Le mer. 1 juin 2022 à 10:58, Alexandre Garnier a écrit : > > Hi everyone! > > I propose to start voting for KIP-840: > https://cwiki.apache.org/confluence/x/bBqhD > > Thanks, > -- > Alex

[jira] [Resolved] (KAFKA-13335) Upgrading connect from 2.7.0 to 2.8.0 causes worker instability

[ https://issues.apache.org/jira/browse/KAFKA-13335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Gray resolved KAFKA-13335. --- Resolution: Not A Problem Finally got back to this after a long time. This is no bug or fault of Kaf

Re: [DISCUSS] KIP-714: Client metrics and observability

Hey Jun, I've clarified the scope of the standard metrics in the KIP, but basically: * We define a standard set of generic metrics that should be relevant to most client implementations, e.g., each producer implementation probably has some sort of per-partition message queue. * A client impleme

RE: [External] WELCOME to dev@kafka.apache.org

Hi, I'm contacting you to please ask for an ETA, if it is planned, for the release in the following link: [KAFKA-9366] Upgrade log4j to log4j2 - ASF JIRA (apache.org) Hope to hear from you soon, Thanks, Nicola Nozza -Original Message- From: dev-h...@kafka.apache.org Sent: martedì 7

Upgrade log4j to log4j2

Hi, I'm contacting you to please ask for an ETA, if it is planned, for the release in the following link: [KAFKA-9366] Upgrade log4j to log4j2 - ASF JIRA (apache.org) Hope to hear from you soon, Thanks, Nicola Nozza _

Upgrade log4j to log4j2

Hi, I'm contacting you to please ask for an ETA, if it is planned, for the release in the following link: [KAFKA-9366] Upgrade log4j to log4j2 - ASF JIRA (apache.org) Hope to hear from you soon, Thanks, Nicola Nozza This message is for the designa

Re: [DISCUSS] KIP-827: Expose logdirs total and usable space via Kafka API

Hi Cong, Some of use cases I have in mind are more around validation that an operation was successful. - Let's say you trigger a reassignment to even out disk usage on some brokers. Your tool will submit the reassignment and wait for completion using the AlterPartitionReassignments and ListPartiti

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.1 #127

See Changes: -- [...truncated 506055 lines...] [2022-06-07T16:54:05.646Z] > Task :metadata:testClasses UP-TO-DATE [2022-06-07T16:54:06.579Z] > Task :clients:generateMetadataF

[jira] [Created] (KAFKA-13964) kafka-configs.sh end with UnsupportedVersionException when describing TLS user with quotas

Jakub Stejskal created KAFKA-13964: -- Summary: kafka-configs.sh end with UnsupportedVersionException when describing TLS user with quotas Key: KAFKA-13964 URL: https://issues.apache.org/jira/browse/KAFKA-13964

Re: [DISCUSS] KIP-844: Transactional State Stores

Hi, As a status update, I did the following changes to the KIP: * replaced configuration via the top-level config with configuration via Stores factory and StoreSuppliers, * added IQv2 and elaborated how readCommitted will work when the store is not transactional, * removed claims about ALOS. I a

Re: [DISCUSS] KIP-714: Client metrics and observability

Hi, Magnus, Thanks for the reply. So, the standard set of generic metrics is just a recommendation and not a requirement? This sounds good to me since it makes the adoption of the KIP easier. Regarding the metric names, I have two concerns. (1) If a client already has an existing metric similar

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

Hi whsoul, Thanks for the updates. I have a few more thoughts but this is looking pretty good: 1. The name "ToStructByRegexTransform" is a little unwieldy. What do you think about something shorter like ParseStruct, ParseRegex, or ParseStructByRegex? 2. What happens if a line that the SMT sees d

[jira] [Resolved] (KAFKA-13942) LogOffsetTest occasionally hangs during Jenkins build

[ https://issues.apache.org/jira/browse/KAFKA-13942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-13942. - Resolution: Fixed > LogOffsetTest occasionally hangs during Jenkins build >

[jira] [Created] (KAFKA-13965) Document broker-side socket-server-metrics

James Cheng created KAFKA-13965: --- Summary: Document broker-side socket-server-metrics Key: KAFKA-13965 URL: https://issues.apache.org/jira/browse/KAFKA-13965 Project: Kafka Issue Type: Improvem

[jira] [Created] (KAFKA-13966) Flaky test `QuorumControllerTest.testUnregisterBroker`

Jason Gustafson created KAFKA-13966: --- Summary: Flaky test `QuorumControllerTest.testUnregisterBroker` Key: KAFKA-13966 URL: https://issues.apache.org/jira/browse/KAFKA-13966 Project: Kafka

[jira] [Created] (KAFKA-13967) Guarantees for producer callbacks on transaction commit should be documented

Chris Egerton created KAFKA-13967: - Summary: Guarantees for producer callbacks on transaction commit should be documented Key: KAFKA-13967 URL: https://issues.apache.org/jira/browse/KAFKA-13967 Projec

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

See Changes: -- [...truncated 634096 lines...] [2022-06-08T04:31:11.461Z] [2022-06-08T04:31:11.461Z] org.apache.kafka.streams.integration.StoreUpgradeIntegrationTest > sh

[jira] [Created] (KAFKA-13968) Broker should not generator snapshot until been unfenced

dengziming created KAFKA-13968: -- Summary: Broker should not generator snapshot until been unfenced Key: KAFKA-13968 URL: https://issues.apache.org/jira/browse/KAFKA-13968 Project: Kafka Issue Ty