[jira] [Resolved] (KAFKA-17061) KafkaController takes long time to connect to newly added broker after registration on large cluster

[ https://issues.apache.org/jira/browse/KAFKA-17061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-17061. Fix Version/s: 3.9.0 Resolution: Fixed > KafkaController takes long time to connect

[jira] [Created] (KAFKA-17124) Fix flaky DumpLogSegmentsTest#testDumpRemoteLogMetadataNonZeroStartingOffset

Chia-Ping Tsai created KAFKA-17124: -- Summary: Fix flaky DumpLogSegmentsTest#testDumpRemoteLogMetadataNonZeroStartingOffset Key: KAFKA-17124 URL: https://issues.apache.org/jira/browse/KAFKA-17124 Proj

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

See

Re: [DISCUSS] Apache Kafka 3.9.0 release

hello KIP-1049 ( https://cwiki.apache.org/confluence/display/KAFKA/KIP-1049%3A+Add+config+log.summary.interval.ms+to+Kafka+Streams) is accepted. And a PR has been submitted (https://github.com/apache/kafka/pull/16509) So could you please include KIP-1049 in 3.9.0? Chia-Ping Tsai 于2024年7月12日周五 0

[jira] [Resolved] (KAFKA-10356) Handle accidental deletion of sink-topics as exceptional failure

[ https://issues.apache.org/jira/browse/KAFKA-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10356. - Resolution: Not A Problem > Handle accidental deletion of sink-topics as exceptional fai

Re: [VOTE] KIP-1067: Remove ReplicaVerificationTool in 4.0 (deprecate in 3.9)

+1 (binding) from me. Thanks Dongjin. Luke On Thu, Jul 11, 2024 at 12:23 AM Justine Olshan wrote: > +1 (binding) > > Thanks, > Justine > > On Mon, Jul 8, 2024 at 1:59 AM Chia-Ping Tsai wrote: > > > > > > > Note that we already have this tracker for tools deprecations, but I'm > > > fine to hav

Re: [VOTE] KIP-1070: Deprecate MockProcessorContext

+1 (binding) On Thu, Jul 11, 2024 at 5:07 PM Sophie Blee-Goldman wrote: > Makes sense to me, +1 (binding) > > On Thu, Jul 11, 2024 at 9:24 AM Matthias J. Sax wrote: > > > Hi, > > > > I want to propose a very small KIP. Skipping the DISCUSS step, and > > calling for a VOTE directly. > > > > > >

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

See

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

See

[jira] [Resolved] (KAFKA-17092) Revisit `KafkaConsumerTest#testBeginningOffsetsTimeout` for AsyncConsumer

[ https://issues.apache.org/jira/browse/KAFKA-17092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-17092. Fix Version/s: 3.9.0 Resolution: Fixed > Revisit `KafkaConsumerTest#testBeginningOf

Re: [DISCUSS] Apache Kafka 3.9.0 release

> KIP-1067 > (https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=311627623) > is accepted. oh, sorry that there are 2 binding votes :( On 2024/07/11 21:09:10 Chia-Ping Tsai wrote: > hi Collin > > KIP-1067 > (https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=311627

Re: [DISCUSS] Apache Kafka 3.9.0 release

hi Collin KIP-1067 (https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=311627623) is accepted. The PR is ready (https://github.com/apache/kafka/pull/16572) and I will merge it later. So could you please include KIP-1067 in 3.9.0? Thanks! Chia-Ping On 2024/06/14 17:55:13 Colin M

Re: [VOTE] KIP-1070: Deprecate MockProcessorContext

Makes sense to me, +1 (binding) On Thu, Jul 11, 2024 at 9:24 AM Matthias J. Sax wrote: > Hi, > > I want to propose a very small KIP. Skipping the DISCUSS step, and > calling for a VOTE directly. > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-1070%3A+deprecate+MockProcessorContext >

[jira] [Resolved] (KAFKA-14710) KRaft cannot initialise storage for valid UUID

[ https://issues.apache.org/jira/browse/KAFKA-14710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-14710. Resolution: Won't Fix > KRaft cannot initialise storage for valid UUID > -

[jira] [Created] (KAFKA-17123) update docs of Storage Tool to clarify that "cluster id" can be non-uuid format after 3.7

Chia-Ping Tsai created KAFKA-17123: -- Summary: update docs of Storage Tool to clarify that "cluster id" can be non-uuid format after 3.7 Key: KAFKA-17123 URL: https://issues.apache.org/jira/browse/KAFKA-17123

[jira] [Created] (KAFKA-17122) Change the type of `clusterId` from `UUID` to `String`

Chia-Ping Tsai created KAFKA-17122: -- Summary: Change the type of `clusterId` from `UUID` to `String` Key: KAFKA-17122 URL: https://issues.apache.org/jira/browse/KAFKA-17122 Project: Kafka Is

Re: [DISCUSS] KIP-1066: Mechanism to cordon brokers and log directories

Hi Mickael, Thanks for the KIP! This is a useful feature which helps to decommission the nodes by essentially creating a new replica exclude broker list. To cordon a list of brokers, we have to apply the config on each of the broker nodes and similarly to see the list of cordoned brokers, we hav

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

See

Re: [DISCUSS] KIP-1051 Statically configured log replication throttling

Hi Harry Fallows, Thanks for the KIP! I went over both the KIP-1051 and KIP-1009. Assuming that the leader.replication.throttled.replicas and follower.replication.throttled.replicas are set to Wildcard (*) to apply for all the partitions in the broker. If we set a static value for leader and foll

[VOTE] KIP-1070: Deprecate MockProcessorContext

Hi, I want to propose a very small KIP. Skipping the DISCUSS step, and calling for a VOTE directly. https://cwiki.apache.org/confluence/display/KAFKA/KIP-1070%3A+deprecate+MockProcessorContext -Matthias

[jira] [Resolved] (KAFKA-10814) improving ability of handling exception in kafka

[ https://issues.apache.org/jira/browse/KAFKA-10814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10814. - Resolution: Incomplete Unclear what the problem is. Closing. > improving ability of han

[jira] [Resolved] (KAFKA-17111) ServiceConfigurationError in JsonSerializer/Deserializer during Plugin Discovery

[ https://issues.apache.org/jira/browse/KAFKA-17111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-17111. - Resolution: Fixed > ServiceConfigurationError in JsonSerializer/Deserializer during Plugin > Di

[jira] [Resolved] (KAFKA-17119) After enabled kafka-ranger-plugin and baned the user for using describe in policy, but that user still can use describe.

[ https://issues.apache.org/jira/browse/KAFKA-17119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-17119. - Resolution: Cannot Reproduce > After enabled kafka-ranger-plugin and baned the user for using de

Re: [DISCUSS] KAFKA-17094: How should unregistered broker nodes be handled in KRaft quorum state?

Hi all, I had left a comment on the JIRA earlier, and thanks to Mickael I was made aware of this thread, so I'll share it here too: I agree it makes sense to make this information available through RPCs, but the Quorum is probably not the right place to represent registered (but inactive

[VOTE] KIP-1051 Statically configured log replication throttling

Hello all, I'd like to call a vote on KIP-1051: https://cwiki.apache.org/confluence/display/KAFKA/KIP-1051%3A+Statically+configured+log+replication+throttling. This is a very small change that will allow replication throttling rates to be configured both statically and dynamically (as opposed t

[jira] [Created] (KAFKA-17121) junit-platform.properties files in published artifacts pollute the test classpath of consumers

Andy Wilkinson created KAFKA-17121: -- Summary: junit-platform.properties files in published artifacts pollute the test classpath of consumers Key: KAFKA-17121 URL: https://issues.apache.org/jira/browse/KAFKA-17121

[jira] [Created] (KAFKA-17120) Race condition in KafkaStreams.close can result in StreamsException "Failed to shut down while in state"

Andy Coates created KAFKA-17120: --- Summary: Race condition in KafkaStreams.close can result in StreamsException "Failed to shut down while in state" Key: KAFKA-17120 URL: https://issues.apache.org/jira/browse/KAFKA-1

[VOTE] KIP-1062: Introduce Pagination for some requests used by Admin API

Hi, I would like to open vote on KIP-1062 https://cwiki.apache.org/confluence/display/KAFKA/KIP-1062%3A+Introduce+Pagination+for+some+requests+used+by+Admin+API. Thanks Omnia

Re: [DISCUSS] KAFKA-17094: How should unregistered broker nodes be handled in KRaft quorum state?

Hi Tina, Thanks for starting the discussion thread. This is indeed a problem if users don't know which node ID need to be unregistered. I'm +1 for adding another field in the response to include registered observer nodes that are inactive. That will make it clear and won't confuse existing users.