Re: [VOTE] KIP-799: Align behaviour for producer callbacks with documented behaviour

Hi Séamus, Thanks for the update. Looks better now! Thank you. Luke On Sat, Dec 4, 2021 at 12:57 AM Séamus Ó Ceanainn < seamus.oceana...@zalando.ie> wrote: > Hey Luke, > > Thanks for the feedback. I've updated the relevant section to hopefully > make it more clear from the KIP itself what

Re: [VOTE] KIP-792: Add "generation" field into consumer protocol

Hi Colin, Thanks for your comment. > How are we going to avoid the situation where the broker restarts, and the same generation number is reused? Actually, this KIP doesn't have anything to do with the brokers. The "generation" field I added, is in the subscription metadata, which will not be

[jira] [Created] (KAFKA-13507) GlobalProcessor ignored user specified names

Matthias J. Sax created KAFKA-13507: --- Summary: GlobalProcessor ignored user specified names Key: KAFKA-13507 URL: https://issues.apache.org/jira/browse/KAFKA-13507 Project: Kafka Issue

Re: KIP-769: Connect API to retrieve connector configuration definitions

One more thing, inline below: Randall On Fri, Dec 3, 2021 at 10:38 AM Mickael Maison wrote: > > Thanks Randall for the feedback! > > 1. Done > > 2. Yes that makes sense. I've updated the KIP > > 3.a I've updated to explicitly mention the plugin can be provided > using the fully qualified class

[jira] [Created] (KAFKA-13506) IQv2: Transmit position to standbys

John Roesler created KAFKA-13506: Summary: IQv2: Transmit position to standbys Key: KAFKA-13506 URL: https://issues.apache.org/jira/browse/KAFKA-13506 Project: Kafka Issue Type: Sub-task

Re: KIP-769: Connect API to retrieve connector configuration definitions

Thanks for the quick response, Mickael. Responses inline below. Randall On Fri, Dec 3, 2021 at 10:38 AM Mickael Maison wrote: > > Thanks Randall for the feedback! > > 1. Done > > 2. Yes that makes sense. I've updated the KIP > > 3.a I've updated to explicitly mention the plugin can be provided

[DISCUSS] KIP-807: Refactor KafkaStreams exposed metadata hierarchy

Hi all, I've created KIP-807 to refactor KafaStreams exposed metadata hierarchy. Here you can find the document: https://cwiki.apache.org/confluence/x/TpiqCw Please take a look at the proposal and let me know what you think, Thanks in advance, -- Josep Prat *Aiven Deutschland GmbH*

Re: [VOTE] KIP-799: Align behaviour for producer callbacks with documented behaviour

Hey Luke, Thanks for the feedback. I've updated the relevant section to hopefully make it more clear from the KIP itself what placeholder value would be returned. Regards, Séamus. On Tue, 30 Nov 2021 at 09:52, Luke Chen wrote: > Hi Séamus, > Thanks for the KIP! > We definitely want to keep

Re: KIP-769: Connect API to retrieve connector configuration definitions

Hi Mickael and Randall, I think there's a decent use case for exposing worker plugins. If a cluster administrator wants to enable a worker plugin on their cluster, it may make things easier if they can verify ahead of time that that plugin is available on every worker in the cluster (and possibly

Re: KIP-769: Connect API to retrieve connector configuration definitions

Thanks Randall for the feedback! 1. Done 2. Yes that makes sense. I've updated the KIP 3.a I've updated to explicitly mention the plugin can be provided using the fully qualified class or the alias. 3.b Only concrete classes will be returned. I made the mistake when I crafted the examples by

Re: requesting contributor access

You're all set now. -Bill On Fri, Dec 3, 2021 at 10:13 AM Andras Katona wrote: > Hey folks, > > Could you grant me contributor access in wiki, please? > wiki id: akatona > (jira id: akatona is already okay, just I forgot to create wiki too back > then) > > Thanks, > Andras >

requesting contributor access

Hey folks, Could you grant me contributor access in wiki, please? wiki id: akatona (jira id: akatona is already okay, just I forgot to create wiki too back then) Thanks, Andras

[jira] [Created] (KAFKA-13505) Kafka Connect should respect Avro 1.10.X enum defaults spec

Guus De Graeve created KAFKA-13505: -- Summary: Kafka Connect should respect Avro 1.10.X enum defaults spec Key: KAFKA-13505 URL: https://issues.apache.org/jira/browse/KAFKA-13505 Project: Kafka

[jira] [Created] (KAFKA-13504) Retry connect internal topics' creation in case of InvalidReplicationFactorException

Andras Katona created KAFKA-13504: - Summary: Retry connect internal topics' creation in case of InvalidReplicationFactorException Key: KAFKA-13504 URL: https://issues.apache.org/jira/browse/KAFKA-13504

Re: [DISCUSS] Apache Kafka 3.1.0 release

Hi Rajini, Interesting bug. The patch seems to be low risk so I suppose that it is fine to keep it in 3.1.0. Thanks, David On Fri, Dec 3, 2021 at 2:26 PM David Jacot wrote: > > Hi Colin, > > Thanks for the heads up. It makes sense to include it in order > to keep the KRaft inline with ZK

Re: [DISCUSS] Apache Kafka 3.1.0 release

Hi Colin, Thanks for the heads up. It makes sense to include it in order to keep the KRaft inline with ZK behavior. Thanks, David On Fri, Dec 3, 2021 at 9:44 AM Rajini Sivaram wrote: > > Hi David, > > Sorry, I had completely forgotten about code freeze and merged >

Jenkins build is unstable: Kafka » Kafka Branch Builder » 3.1 #29

See

Re: [DISCUSS] Apache Kafka 3.1.0 release

Hi David, Sorry, I had completely forgotten about code freeze and merged https://issues.apache.org/jira/browse/KAFKA-13461 to 3.1 branch yesterday. Can you take a look and see if we want it in 3.1.0? It is not a regression in 3.1, but we see this issue in tests and when it happens, the controller