Re: [VOTE] KIP-1125: Remove Invalid 'numberOfOpenFiles' Metric from RocksDB State Store

 Thanks everyone for voting and feedback. The vote has passed with 3 binding votes (Chia, Bruno and Matthias). Regards, Swikar > On Jan 21, 2025, at 9:26 PM, Chia-Ping Tsai wrote: > hi Swikar > > for example: https://lists.apache.org/thread/3qlw82pxkb6yb7ojk6f46wpglkhx4kzf > > We need

Re: [VOTE] KIP-1125: Remove Invalid 'numberOfOpenFiles' Metric from RocksDB State Store

hi Swikar for example: https://lists.apache.org/thread/3qlw82pxkb6yb7ojk6f46wpglkhx4kzf We need to count the binding and non-binding votes. Importantly, a KIP requires at least three binding votes to pass, so we usually announce the vote count to ensure its validity. Best, Chia-Ping > Swikar

Re: [VOTE] KIP-1125: Remove Invalid 'numberOfOpenFiles' Metric from RocksDB State Store

How > On Jan 21, 2025, at 7:58 PM, Chia-Ping Tsai wrote: > > hi Swikar > > We typically announce the vote results during the final, so could you please > adhere to that pattern? > > Thanks, > Chia-Ping > > > >> Swikar Patel 於 2025年1月22日 凌晨4:11 寫道： >> >> Okay Closed now and Updated KIP

Re: [DISCUSS] KIP-1124: Providing a clear Kafka Client upgrade path

> - If we support 2.0+ to 4.0 client/KS upgrade it's simpler, but of course > brokers cannot be 4.0 yet -- but I guess this would be something natural? > Given that the clients would be on 2.0, brokers cannot be 4.0 yet, or clients > would have crashed already... Thus, I think I slightly prefer

Re: [VOTE] KIP-1125: Remove Invalid 'numberOfOpenFiles' Metric from RocksDB State Store

hi Swikar We typically announce the vote results during the final, so could you please adhere to that pattern? Thanks, Chia-Ping > Swikar Patel 於 2025年1月22日 凌晨4:11 寫道： > > Okay Closed now and Updated KIP wiki page as [Accepted] > >> On Jan 21, 2025, at 11:01 AM, Matthias J. Sax wrote: >>

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.9 #152

See

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.8 #138

See

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.9 #151

See

Re: Clarification on Metric Description for Kafka Streams Documentation

Noted Thanks Matthias On Tue, 21 Jan 2025 at 20:00, Matthias J. Sax wrote: > The description does not need to be 100% the same in the code and docs. > Of course, we try to align them, but if they differ slightly it's ok, as > long as it's clear what they mean. > > -Matthias > > On 1/21/25 2:01

Re: [VOTE] KIP-1125: Remove Invalid 'numberOfOpenFiles' Metric from RocksDB State Store

Okay Closed now and Updated KIP wiki page as [Accepted] > On Jan 21, 2025, at 11:01 AM, Matthias J. Sax wrote: > > I think we can close the vote on this KIP? > >> On 1/13/25 2:52 PM, Swikar Patel wrote: >> Thanks Chia-Ping I have now added that to KIP. On Jan 13, 2025, at 2:43 PM, Chia-Pi

[jira] [Created] (KAFKA-18617) Support ClusterInstance in BeforeEach/AfterEach fixtures

David Arthur created KAFKA-18617: Summary: Support ClusterInstance in BeforeEach/AfterEach fixtures Key: KAFKA-18617 URL: https://issues.apache.org/jira/browse/KAFKA-18617 Project: Kafka Issu

Re: [VOTE] KIP-1125: Remove Invalid 'numberOfOpenFiles' Metric from RocksDB State Store

I think we can close the vote on this KIP? On 1/13/25 2:52 PM, Swikar Patel wrote: Thanks Chia-Ping I have now added that to KIP. On Jan 13, 2025, at 2:43 PM, Chia-Ping Tsai wrote:  +1（binding) Could you please add the discussion of jira to KIP-1125 to remind readers that discussion phase

Re: Clarification on Metric Description for Kafka Streams Documentation

The description does not need to be 100% the same in the code and docs. Of course, we try to align them, but if they differ slightly it's ok, as long as it's clear what they mean. -Matthias On 1/21/25 2:01 AM, Ukpa Uchechi wrote: Hi Kafka Dev Community, I’m currently working on updating the

[jira] [Created] (KAFKA-18618) Reduce stickiness of share session handlers

Andrew Schofield created KAFKA-18618: Summary: Reduce stickiness of share session handlers Key: KAFKA-18618 URL: https://issues.apache.org/jira/browse/KAFKA-18618 Project: Kafka Issue Typ

Re: Streams component Classes

It's a difficult to explain briefly. KIP-1035 (https://cwiki.apache.org/confluence/display/KAFKA/KIP-1035%3A+StateStore+managed+changelog+offsets) introduced this issue, so maybe reading the KIP as a starting point might help to understand? Btw: The ticket is assigned to Bill as you can see,

Re: [DISCUSS] KIP-1124: Providing a clear Kafka Client upgrade path

Thanks Ismael. Sounds like a good idea to split the specific 4.0 question and the long term policy. For 4.0, it's a little tricky and could be confusing for users no matter what we do. - If only support 2.1+ to 4.0 client/KS upgrade, it's a weird cut-off version - If we support 2.0+ to 4

[jira] [Created] (KAFKA-18616) Refactor DumpLogSegments's MessageParsers

David Jacot created KAFKA-18616: --- Summary: Refactor DumpLogSegments's MessageParsers Key: KAFKA-18616 URL: https://issues.apache.org/jira/browse/KAFKA-18616 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-18615) StreamThread *-ratio metrics suffer from sampling bias

Rafał Sumisławski created KAFKA-18615: - Summary: StreamThread *-ratio metrics suffer from sampling bias Key: KAFKA-18615 URL: https://issues.apache.org/jira/browse/KAFKA-18615 Project: Kafka

[jira] [Created] (KAFKA-18614) Add StreamsGroupDescribe handler in group coordinator

Lucas Brutschy created KAFKA-18614: -- Summary: Add StreamsGroupDescribe handler in group coordinator Key: KAFKA-18614 URL: https://issues.apache.org/jira/browse/KAFKA-18614 Project: Kafka Iss

[jira] [Created] (KAFKA-18613) Add StreamsGroupHeartbeat handler in the group coordinator

Lucas Brutschy created KAFKA-18613: -- Summary: Add StreamsGroupHeartbeat handler in the group coordinator Key: KAFKA-18613 URL: https://issues.apache.org/jira/browse/KAFKA-18613 Project: Kafka

[jira] [Resolved] (KAFKA-15820) Add a metric to track the number of partitions under min ISR

[ https://issues.apache.org/jira/browse/KAFKA-15820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Calvin Liu resolved KAFKA-15820. Resolution: Won't Fix We can use the kafka.replication.under_min_isr to track this info > Add a m

[jira] [Resolved] (KAFKA-18302) Update CoordinatorRecord

[ https://issues.apache.org/jira/browse/KAFKA-18302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-18302. - Fix Version/s: 4.1.0 Resolution: Fixed > Update CoordinatorRecord > -

[jira] [Created] (KAFKA-18612) Update ApiMessageFormatter

David Jacot created KAFKA-18612: --- Summary: Update ApiMessageFormatter Key: KAFKA-18612 URL: https://issues.apache.org/jira/browse/KAFKA-18612 Project: Kafka Issue Type: Sub-task Rep

[jira] [Created] (KAFKA-18611) Update MV to enable transaction version 2 by default for 4.0

Justine Olshan created KAFKA-18611: -- Summary: Update MV to enable transaction version 2 by default for 4.0 Key: KAFKA-18611 URL: https://issues.apache.org/jira/browse/KAFKA-18611 Project: Kafka

[jira] [Created] (KAFKA-18610) Add flush metrics to runtime

Jeff Kim created KAFKA-18610: Summary: Add flush metrics to runtime Key: KAFKA-18610 URL: https://issues.apache.org/jira/browse/KAFKA-18610 Project: Kafka Issue Type: Sub-task Reporte

[jira] [Created] (KAFKA-18609) Write test that emulate resigned leader Fetch handling

José Armando García Sancio created KAFKA-18609: -- Summary: Write test that emulate resigned leader Fetch handling Key: KAFKA-18609 URL: https://issues.apache.org/jira/browse/KAFKA-18609 Pro

[jira] [Resolved] (KAFKA-18585) Fix fail test ValuesTest#shouldConvertDateValues

[ https://issues.apache.org/jira/browse/KAFKA-18585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 黃竣陽 resolved KAFKA-18585. - Resolution: Fixed > Fix fail test ValuesTest#shouldConvertDateValues >

[jira] [Resolved] (KAFKA-18370) Fix to Kraft or remove tests associate with Zk Broker config in ReplicaFetcherThreadTest

[ https://issues.apache.org/jira/browse/KAFKA-18370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TaiJuWu resolved KAFKA-18370. - Resolution: Fixed > Fix to Kraft or remove tests associate with Zk Broker config in > ReplicaFetcherThr

[jira] [Resolved] (KAFKA-18526) CustomQuotaCallbackTest should run for async consumer

[ https://issues.apache.org/jira/browse/KAFKA-18526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 黃竣陽 resolved KAFKA-18526. - Resolution: Not A Problem > CustomQuotaCallbackTest should run for async consumer >

[jira] [Resolved] (KAFKA-18487) Remove ReplicaManager#stopReplicas

[ https://issues.apache.org/jira/browse/KAFKA-18487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-18487. - Fix Version/s: 4.0.0 Resolution: Fixed > Remove ReplicaManager#stopReplicas > ---

Clarification on Metric Description for Kafka Streams Documentation

Hi Kafka Dev Community, I’m currently working on updating the Kafka Streams documentation, specifically the monitoring section. While reviewing the codebase, I noticed that many of the descriptions are decoupled and defined in different parts of the code, such as in statements like private static

Kafka Partitions using Helidon framework.

I want to use Helidon SE 4.1.6 and produce the data to a specific partition of Apache Kafka using the producer. Detail : I have gone through the https://helidon.io/docs/latest/se/reactive-messaging#_kafka_connectorpage and written below code which is able to send the data using kafka producer to t