Re: [VOTE] KIP-769: Connect APIs to list all connector plugins and retrieve their configuration definitions

Hi Mickael, +1 (binding), thanks! Tom On Wed, 26 Jan 2022 at 09:42, Viktor Somogyi-Vass wrote: > Hi Michael, > > +1 (non-binding) from me. > > Viktor > > On Thu, Jan 13, 2022 at 11:32 AM Mickael Maison > wrote: > > > Bumping this vote. > > > > We have 2 non-binding votes so far. Please take

Re: [VOTE] KIP-591: Add Kafka Streams config to set default state store

Thanks for updating the KIP. It's much clearer now. I think the improvement to `Materialized` is a good one. However, I still have doubts about `Stores`. While the API change itself seems ok (even if I don't see a large benefit), it adds a dependency from the DSL classes (ie, package

Re: [VOTE] KIP-814: Static membership protocol should let the leader skip assignment

Hi David, Thanks for the KIP. I'm +1(non-binding) Thanks. Luke Jason Gustafson 於 2022年2月1日 週二 上午7:11 寫道： > +1 Thanks! > > On Mon, Jan 31, 2022 at 12:17 AM David Jacot wrote: > > > Hi all, > > > > I'd like to start a vote about KIP-814: Static membership protocol > > should let the leader >

[VOTE] KIP-801 new authorizer for kip-500 kraft mode

Hi all, It looks like people using gmail are seeing the previous vote thread as merged with the discuss thread, so let me create a new thread in order to avoid confusion. Usually using a very different thread title works well enough to avoid the merging. Original vote thread:

Re: [VOTE] KIP-801: Implement an Authorizer that stores metadata in __cluster_metadata

On Mon, Jan 31, 2022, at 16:20, Jason Gustafson wrote: > Hi Colin, > > The updates look good to me. I wanted to clarify a few details about the > AUTHORIZER_NOT_READY error code: > > 1. Only the Authorizer implementation will know when it is finished > initialization. I had imagined that any

Re: [VOTE] KIP-801: Implement an Authorizer that stores metadata in __cluster_metadata

Hi Colin, The updates look good to me. I wanted to clarify a few details about the AUTHORIZER_NOT_READY error code: 1. Only the Authorizer implementation will know when it is finished initialization. I had imagined that any request received in this state which cannot be authorized based on

Re: [VOTE] KIP-814: Static membership protocol should let the leader skip assignment

+1 Thanks! On Mon, Jan 31, 2022 at 12:17 AM David Jacot wrote: > Hi all, > > I'd like to start a vote about KIP-814: Static membership protocol > should let the leader > skip assignment. > > The KIP is here: https://cwiki.apache.org/confluence/x/C5-kCw. > > Best, > David >

Re: [VOTE] KIP-704: Send a hint to partition leader to recover the partition

+1 Thanks! On Wed, Jan 26, 2022 at 10:48 AM José Armando García Sancio wrote: > Hi all, > > I'd like to start a vote on KIP-704: Send a hint to the partition > leader to recover the partition. > > KIP wiki: https://cwiki.apache.org/confluence/x/kAZRCg > Discussion thread: >

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

Jun Following are the answers for some the questions raised by you. >> 26. client-metrics entity: >> 26.1 It seems that we could add multiple entities that match to the same >> client. Which one takes precedent? All the matching client metrics would be compiled into a single list and send to

Re: [VOTE] KIP-801: Implement an Authorizer that stores metadata in __cluster_metadata

Hi all, Thanks, everyone. I've updated the KIP. I reorganized the design section to explain bootstrapping a bit better, and put it first. (It was always weird that the design section came after the interface changes section :) ). I also added early.start.listeners and a section on the other

Re: [DISCUSS] KIP-801: Implement an Authorizer that stores metadata in __cluster_metadata

Thanks for the KIP. LGTM once we get consensus on bootstrapping logic. 1. When do we say, ACL is created (or deleted)? Is it after we persist it durably by a majority of peers?. 2. Can we add a metric for total acl count (This was missing in ZK Authoriser). On Thu, Jan 13, 2022 at 2:26 AM David

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

Hi, I have updated the KIP accordingly. Thanks, Mickael On Fri, Jan 28, 2022 at 7:01 PM Chris Egerton wrote: > > I think a simple approach here is fine. +1 for removing versioning for > other plugins. > > On Fri, Jan 28, 2022 at 11:17 AM Mickael Maison > wrote: > > > Thanks Chris and Tom for

[jira] [Created] (KAFKA-13634) false information to the Debezium Connector in case the heartbeat topic does not exists

Andreas Gillmann created KAFKA-13634: Summary: false information to the Debezium Connector in case the heartbeat topic does not exists Key: KAFKA-13634 URL: https://issues.apache.org/jira/browse/KAFKA-13634

[DISCUSS] KIP-819: Merge multiple KStreams in one operation

Hi everyone, I'd like to discuss KIP 819: https://cwiki.apache.org/confluence/display/KAFKA/KIP-819%3A+Merge+multiple+KStreams+in+one+operation This is a simple KIP that adds/modifies the KStream#merge API to enable many streams to be merged in a single graph node. Regards, Nick Telford

[jira] [Created] (KAFKA-13633) Merging multiple KStreams in one operation

Nicholas Telford created KAFKA-13633: Summary: Merging multiple KStreams in one operation Key: KAFKA-13633 URL: https://issues.apache.org/jira/browse/KAFKA-13633 Project: Kafka Issue

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #647

See

Re: [VOTE] KIP-815: Replace KafkaConsumer with AdminClient in GetOffsetShell

Hey, Thanks for the KIP. I have a few comments: 1. I think that it would be better to name the KIP: "GetOffsetShell should support max-timestamp" or something like that as this is the initial intent of the change. 2. There is a typo: `OffsetSpce` -> `OffsetSpec`. 3. It would be great if we

[jira] [Created] (KAFKA-13632) MirrorMaker 2.0 NPE and Warning "Failure to commit records" for filtered records

Bert Baron created KAFKA-13632: -- Summary: MirrorMaker 2.0 NPE and Warning "Failure to commit records" for filtered records Key: KAFKA-13632 URL: https://issues.apache.org/jira/browse/KAFKA-13632

[VOTE] KIP-814: Static membership protocol should let the leader skip assignment

Hi all, I'd like to start a vote about KIP-814: Static membership protocol should let the leader skip assignment. The KIP is here: https://cwiki.apache.org/confluence/x/C5-kCw. Best, David

[jira] [Created] (KAFKA-13631) Warning "Ignoring await stop request for non-present connector..." when shuting down connector via API in distributed mode

Simon Schall created KAFKA-13631: Summary: Warning "Ignoring await stop request for non-present connector..." when shuting down connector via API in distributed mode Key: KAFKA-13631 URL: