Re: [ANNOUNCE] Apache Kafka 3.2.0

Hi James, Thank you! I corrected the mistake. Best, Bruno On 19.05.22 21:30, James Cheng wrote: Bruno, Congrats on the release! There is a small typo on the page. KIP-791 adds method

[jira] [Created] (KAFKA-13919) Add metric for log recovery progress

Luke Chen created KAFKA-13919: - Summary: Add metric for log recovery progress Key: KAFKA-13919 URL: https://issues.apache.org/jira/browse/KAFKA-13919 Project: Kafka Issue Type: New Feature

[jira] [Created] (KAFKA-13920) KafkaProducer.close waits idefinitely on ioThread that is not joining

Oleg Muravskiy created KAFKA-13920: -- Summary: KafkaProducer.close waits idefinitely on ioThread that is not joining Key: KAFKA-13920 URL: https://issues.apache.org/jira/browse/KAFKA-13920 Project: K

[jira] [Created] (KAFKA-13921) Flaky test TopicCommandIntegrationTest testDescribeAtMinIsrPartitions(String).quorum=kraft

Divij Vaidya created KAFKA-13921: Summary: Flaky test TopicCommandIntegrationTest testDescribeAtMinIsrPartitions(String).quorum=kraft Key: KAFKA-13921 URL: https://issues.apache.org/jira/browse/KAFKA-13921

[jira] [Created] (KAFKA-13922) Unable to generate coverage reports for the whole project

Patrik Nagy created KAFKA-13922: --- Summary: Unable to generate coverage reports for the whole project Key: KAFKA-13922 URL: https://issues.apache.org/jira/browse/KAFKA-13922 Project: Kafka Issue

Re: [VOTE] KIP-835: Monitor KRaft Controller Quorum Health

Thanks everyone for your feedback and help. KIP-835 was approved with 3 binding votes from Guozhang, Luke and David. On Thu, May 19, 2022 at 10:21 AM Guozhang Wang wrote: > > That makes sense. Thanks! > > +1 (binding). > > On Thu, May 19, 2022 at 8:46 AM José Armando García Sancio > wrote: > > >

Re: [DISCUSS] KIP-841: Fenced replicas should not be allowed to join the ISR in KRaft

This KIP is pretty straight forward. I will start a vote on Monday if no one objects. Best, David On Wed, May 18, 2022 at 5:55 PM David Jacot wrote: > > Hi, > > I created a small KIP to strengthen the AlterPartition API in KRaft mode: > https://cwiki.apache.org/confluence/x/phmhD > > Let me know

Re: [DISCUSS] KIP-832 Allow creating a producer/consumer using a producer/consumer config

Hi all, KIP-839 has been created to progress on the builder way https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=211884640 Kr, F. Le ven. 13 mai 2022 à 19:15, Colin McCabe a écrit : > I agree. I would really like to see a builder interface here. If you > changed the KIP to add

Re: [DISCUSS] KIP-787 - MM2 Interface to manage Kafka resources

Hi Colin, >Thanks for the clarification. I agree it's reasonable for people to want to use their own implementations of Admin. And we could have a config for this, so that it becomes pluggable (possibly in other places than MirrorMaker, although we don't have to do that in this KIP). > Allowing pe

Re: [DISCUSS] KIP-841: Fenced replicas should not be allowed to join the ISR in KRaft

The KIP LGTM. My only question is why it's an issue with KRaft -- looks like ZK would have the same issue? -Artem On Fri, May 20, 2022 at 8:51 AM David Jacot wrote: > This KIP is pretty straight forward. I will start a vote on Monday > if no one objects. > > Best, > David > > On Wed, May 18, 2

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

Hey Niket, +1 (binding) from me. -David On Thu, May 19, 2022 at 2:07 PM José Armando García Sancio wrote: > Hey Niket, > > I took a look at the latest KIP. It looks like QuorumInfo.ReplicaState > is missing the RPC fields added by this PR. Is the plan to return them > to the Admin Client? E.g.

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

Thanks for the changes to KIP-836 Niket. KIP-836 has the following output for "--describe replication": > bin/kafka-metadata-quorum.sh --describe replication ReplicaId LogEndOffsetLag LastFetchTimeMs LastCaughtUpTimeMsStatus 0 234134 0 tnow

[jira] [Created] (KAFKA-13923) ZooKeeperAuthorizerTest should use standard authorizer for kraft

Jason Gustafson created KAFKA-13923: --- Summary: ZooKeeperAuthorizerTest should use standard authorizer for kraft Key: KAFKA-13923 URL: https://issues.apache.org/jira/browse/KAFKA-13923 Project: Kafka

Re: Are timestamps available for records stored in Kafka Streams state stores?

Added. Feel free to update wiki pages with smaller details like this directly. -Matthias On 5/19/22 2:27 PM, James Cheng wrote: Thanks Guozhang! Based on your comment, I searched through the repo and found the associated pull requests and JIRAs. It looks like most of the support was added i

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

So Ideally the LastCatchUpTimeMs is supposed to be a proxy for lag. We could report this field as lag, but I am personally not in favor of doing that as the LastCaughtUpTimeMs is just an approximation of lag, but not actual lag. I guess it depends on the experience we want through the tool. Do

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

+1 (binding) Thanks for the KIP! David Le ven. 20 mai 2022 à 21:08, David Arthur a écrit : > Hey Niket, +1 (binding) from me. > > -David > > On Thu, May 19, 2022 at 2:07 PM José Armando García Sancio > wrote: > > > Hey Niket, > > > > I took a look at the latest KIP. It looks like QuorumInfo.R