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

See

Re: [DISCUSS] KIP-613: Add end-to-end latency metrics to Streams

Hi Chaimaa, Interesting... That basis for those metrics is the difference between a record's timestamp and the current system time while processing it. I wonder if it's negative because of a difference in the way that the producer sets the records' timestamps versus the current time on the

Re: [DISCUSS] KIP-829: (console-consumer) add print.topic property

Hi Evans, Thanks for the KIP! I agree with Mickael; it would be good to see an example in the KIP. Otherwise, I'm in favor. Thanks, -John On Fri, Apr 15, 2022, at 04:33, Mickael Maison wrote: > Hi, > > I can't believe this was missing! Thanks for addressing this. > Can you add an example of

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

See

Jenkins build is unstable: Kafka » Kafka Branch Builder » 3.2 #33

See

[VOTE] 3.2.0 RC0

Hello Kafka users, developers and client-developers, This is the first candidate for release of Apache Kafka 3.2.0. * log4j 1.x is replaced with reload4j (KAFKA-9366) * StandardAuthorizer for KRaft (KIP-801) * Send a hint to the partition leader to recover the partition (KIP-704) * Top-level

Re: [VOTE] KIP-825: introduce a new API to control when aggregated results are produced

Hi Guozhang, Thanks for the suggestion. 1. I have no problem with window-aggregate-final-emit-(rate | total) and window-aggregate-final-emit-latency-(avg | max) 2. Good question, it should be the time to emit final when it COULD be emitted. Will update KIP and PR. Hao On Thu, Apr 14, 2022

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

See Changes: -- [...truncated 527016 lines...] [2022-04-15T18:27:02.792Z] org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest >

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.2 #32

See Changes: -- [...truncated 523771 lines...] [2022-04-15T17:02:35.639Z] org.apache.kafka.streams.integration.RocksDBMetricsIntegrationTest >

[jira] [Resolved] (KAFKA-13624) Add Metric for Store Cache Size

[ https://issues.apache.org/jira/browse/KAFKA-13624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sagar Rao resolved KAFKA-13624. --- Resolution: Won't Fix Taken care as part of KIP-770 > Add Metric for Store Cache Size >

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

See

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

Hi Luke, 7. I've updated the KIP to clarify these sizes are in bytes. Thanks, Mickael On Fri, Apr 15, 2022 at 12:16 PM Luke Chen wrote: > > Hi Mickael, > > Thanks for the KIP! > This is a good improvement. > > (3) +1 for not adding the number of files in the directory. Counting the > file

Re: maxParallelForks while running tests

I am not running into any specific issue with kafka code. Was just curious to know if there were any specific fixes done to handle this issue. On Fri, Apr 15, 2022 at 8:24 AM Luke Chen wrote: > Hi Unmesh, > > Are you running into any issue with that? > > So far, the `maxParallelForks` can be

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

See

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.2 #31

See

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

See

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

Hi Mickael, Thanks for the KIP! This is a good improvement. (3) +1 for not adding the number of files in the directory. Counting the file numbers should be slow. (7) Could you make the fields clear in `DescribeLogDirsResponse`, to mention the returned number is size in Byte (or not?) Thank you.

Re: [DISCUSS] KIP-829: (console-consumer) add print.topic property

Hi, I can't believe this was missing! Thanks for addressing this. Can you add an example of the expected output with the topic in the KIP? Thanks, Mickael On Sat, Apr 9, 2022 at 12:11 PM Evans Jahja wrote: > > Good evening. > > My name is Evans, I am proposing KIP-829. > > Brief: Using

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

Hi, Thanks for the feedback. 3. Yes that's right. Also the number of file descriptors is really not a property of log directories. Administrators typically tracked that count per process and for the whole operating system. 5. That's a good point, I've updated the KIP to mention sizes will be

[jira] [Created] (KAFKA-13831) Kafka retention can use old value of retention.ms

Maciej Bryński created KAFKA-13831: -- Summary: Kafka retention can use old value of retention.ms Key: KAFKA-13831 URL: https://issues.apache.org/jira/browse/KAFKA-13831 Project: Kafka Issue