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

See

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

See

Re: [DISCUSS] KIP-794: Strictly Uniform Sticky Partitioner

Hi Jun, 1. Updated the KIP to add a couple paragraphs about implementation necessities in the Proposed Changes section. 2. Sorry if my reply was confusing, what I meant to say (and I elaborated on that in point #3) is that there could be patterns for which 16KB wouldn't be the most effective sett

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

See

Re: [DISCUSS] KIP-820: Extend KStream process with new Processor API

Hi all, Appreciate very much all the great feedback received so far. > After applying that interface change, I don't see any syntax errors in our tests (which use those methods), and the StreamBuilderTest still passes for me. This is awesome John, thank you for your efforts here. > Jorge, do yo

Re: KAFKA- UNDER_REPLICATED_PARTIONS - AUTOMATE

Maybe this could help? https://github.com/dimas/kafka-reassign-tool Cheers, Malcolm McFarland Cavulus On Fri, Feb 25, 2022 at 9:00 AM Kafka Life wrote: > Dear Experts > > do you have any solution for this please > > On Tue, Feb 22, 2022 at 8:31 PM Kafka Life wrote: > > > Dear Kafka Experts >

[jira] [Created] (KAFKA-13698) KRaft authorizer should check host address instead of name

Jason Gustafson created KAFKA-13698: --- Summary: KRaft authorizer should check host address instead of name Key: KAFKA-13698 URL: https://issues.apache.org/jira/browse/KAFKA-13698 Project: Kafka

[jira] [Created] (KAFKA-13697) KRaft authorizer should handle AclOperation.ALL

Jason Gustafson created KAFKA-13697: --- Summary: KRaft authorizer should handle AclOperation.ALL Key: KAFKA-13697 URL: https://issues.apache.org/jira/browse/KAFKA-13697 Project: Kafka Issue T

[jira] [Created] (KAFKA-13696) Topic partition leader should always send AlterPartition when transitioning from RECOVRING TO RECOVERD

Jose Armando Garcia Sancio created KAFKA-13696: -- Summary: Topic partition leader should always send AlterPartition when transitioning from RECOVRING TO RECOVERD Key: KAFKA-13696 URL: https://issues.ap

Re: [DISCUSS] KIP-820: Extend KStream process with new Processor API

Oh, one more thing Jorge, I think the other outstanding question for you is whether the output key type for processValues should be K or Void. I get the impression that all of us don't feel too strongly about it, so I think the ball is in your court to consider everyone's points and make a call (w

Re: [DISCUSS] KIP-761: Add total blocked time metric to streams

Thanks Rohan, I've reviewed the new PR and had a question regarding whether we should have the new metric in ms or ns, maybe we can first discuss about that before we finalize the KIP? Guozhang On Fri, Feb 25, 2022 at 5:48 AM Bruno Cadonna wrote: > Hi Rohan, > > Thank you for the heads up! >

Re: [DISCUSS] KIP-820: Extend KStream process with new Processor API

Hello all, I'll chime in again in the interest of trying to do a better job of keeping KIPs moving forward... Matthias raised some very good questions about whether the change is really source compatible. I just checked out the code and make the interface change that Jorge specified in the KIP:

Re: KAFKA- UNDER_REPLICATED_PARTIONS - AUTOMATE

Dear Experts do you have any solution for this please On Tue, Feb 22, 2022 at 8:31 PM Kafka Life wrote: > Dear Kafka Experts > > Does anyone have a dynamically generated Json file based on the Under > replicated partition in the kafka cluster. > Everytime when the URP is increased to over 500 ,

Re: [DISCUSS] KIP-761: Add total blocked time metric to streams

Hi Rohan, Thank you for the heads up! Yes, please update the KIP and send this message also to the VOTE thread of the KIP. Best, Bruno On 25.02.22 04:01, Rohan Desai wrote: Hello, I discovered a bug in the design of this metric. The bug is documented here: https://github.com/apache/kafka/p

[jira] [Created] (KAFKA-13695) Low-traffic topics don't roll (and therefore compact) nor delete tombstones

Marc created KAFKA-13695: Summary: Low-traffic topics don't roll (and therefore compact) nor delete tombstones Key: KAFKA-13695 URL: https://issues.apache.org/jira/browse/KAFKA-13695 Project: Kafka

[jira] [Resolved] (KAFKA-12260) PartitionsFor should not return null value

[ https://issues.apache.org/jira/browse/KAFKA-12260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-12260. --- Resolution: Fixed > PartitionsFor should not return null value > ---

Re: [VOTE] KIP-815: Support max-timestamp in GetOffsetShell

Hello Maison, I think you suggestion makes sense, it’s better to support querying by "earliest" "latest" "max-timestamp”, I will add this to the KIP. > On Feb 23, 2022, at 8:54 PM, Mickael Maison wrote: > > Hi, > > I'm +1 (binding) too. > > Just one minor comment: > Could we make the "time"