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

Thanks, Hao! I have no concern about amending the KIP to add metrics. Thanks for thinking of it. Can you comment on the choice to add them as a task-level metric instead of a processor-level metric? This will cause the metrics for all windowed aggregations in a task that use final emission to be

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

See

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

See

Re: [DISCUSS] KIP-821: Connect Transforms support for nested structures

Hi Jorge, Wow, those examples are great! A few more remarks, but I think we're getting close: 1. The examples differ across SMTs with the name of the newly-introduced style property; some of them use "field.style", and some use "fields.style". I think for consistency's sake we should stick with

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

See

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

Hi all, I would like to introduce two metrics in this KIP as well to measure the latency and number of records emitted for emit final. They are named: `emit-final-latency` `emitted-records` I've updated the KIP with details in

[jira] [Created] (KAFKA-13820) Add debug-level logs to explain why a store is filtered out during interactive query

John Roesler created KAFKA-13820: Summary: Add debug-level logs to explain why a store is filtered out during interactive query Key: KAFKA-13820 URL: https://issues.apache.org/jira/browse/KAFKA-13820

[jira] [Created] (KAFKA-13819) Add application.server to Streams assignor logs when set

John Roesler created KAFKA-13819: Summary: Add application.server to Streams assignor logs when set Key: KAFKA-13819 URL: https://issues.apache.org/jira/browse/KAFKA-13819 Project: Kafka

[jira] [Created] (KAFKA-13818) Add generation to consumer assignor logs

John Roesler created KAFKA-13818: Summary: Add generation to consumer assignor logs Key: KAFKA-13818 URL: https://issues.apache.org/jira/browse/KAFKA-13818 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-13817) Schedule nextTimeToEmit to system time every time instead of just once

Hao Li created KAFKA-13817: -- Summary: Schedule nextTimeToEmit to system time every time instead of just once Key: KAFKA-13817 URL: https://issues.apache.org/jira/browse/KAFKA-13817 Project: Kafka

Re: [VOTE] KIP-813 Shared State Stores

Hi, thanks for the KIP. +1 Just a minor note: In the rejected alternatives I read "If B would like to lookup s, there are two possible approaches to take", but then you describe only one. On Tue, Apr 5, 2022, 6:17 PM Bill Bejeck wrote: > Thanks for the KIP, Daan. > > I've caught up on the

[jira] [Created] (KAFKA-13816) Downgrading Connect rebalancing protocol from incremental to eager causes duplicate task instances

Chris Egerton created KAFKA-13816: - Summary: Downgrading Connect rebalancing protocol from incremental to eager causes duplicate task instances Key: KAFKA-13816 URL:

[jira] [Created] (KAFKA-13815) Avoid reinitialization for a replica that is being deleted

Lucas Wang created KAFKA-13815: -- Summary: Avoid reinitialization for a replica that is being deleted Key: KAFKA-13815 URL: https://issues.apache.org/jira/browse/KAFKA-13815 Project: Kafka Issue