[jira] [Created] (KAFKA-17014) ScramFormatter should not use String for password.

Tsz-wo Sze created KAFKA-17014: -- Summary: ScramFormatter should not use String for password. Key: KAFKA-17014 URL: https://issues.apache.org/jira/browse/KAFKA-17014 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-16531) Fix check-quorum calculation to not assume that the leader is in the voter set

[ https://issues.apache.org/jira/browse/KAFKA-16531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-16531. --- Resolution: Fixed > Fix check-quorum calculation to not assume that the leader is in the voter set

[jira] [Created] (KAFKA-17013) RequestManager#toString() should use %s

dujian0068 created KAFKA-17013: -- Summary: RequestManager#toString() should use %s Key: KAFKA-17013 URL: https://issues.apache.org/jira/browse/KAFKA-17013 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-17012) Enable testMeasureCommitSyncDuration, testMeasureCommittedDurationOnFailure, testInvalidGroupMetadata, testMeasureCommittedDuration, testOffsetsForTimesTimeout, testBegi

Chia-Ping Tsai created KAFKA-17012: -- Summary: Enable testMeasureCommitSyncDuration, testMeasureCommittedDurationOnFailure, testInvalidGroupMetadata, testMeasureCommittedDuration, testOffsetsForTimesTimeout, testBeginningOffsetsTimeout and

Re: [DISCUSS] KIP-1059: Enable the Producer flush() method to clear the latest send() error

> I thought we still wait for requests (and their errors) to come in and could handle fatal errors appropriately. We do wait for requests, but my understanding is that when commitTransaction("ignore send errors") we want to ignore errors. So if we do 1. send 2. commitTransaction("ignore send

Re: [DISCUSS] KIP-1059: Enable the Producer flush() method to clear the latest send() error

I'm a bit late to the party, but the discussion here looks reasonable. Moving the logic to a transactional method makes sense to me and makes me feel a bit better about keeping the complexity in the methods relevant to the issue. > One minor concern is that if we set "ignore send errors" (or

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

See Changes: -- [...truncated 527369 lines...] [2024-06-20T23:43:34.727Z] Gradle Test Run :core:test > Gradle Test Executor 97 > ZkMigrationClientTest >

RE: [DISCUSS] KIP-1052: Enable warmup in producer performance test

Hi Divij, Thanks for your response. You raise some very important points. I've updated the KIP to clarify the changes discussed here. 1. I agree that warmup stats should be printed separately. I see two cases here, both of which would have two summary lines printed at the end of the

Re: [DISCUSS] KIP-1059: Enable the Producer flush() method to clear the latest send() error

Hi Matthias (and other folks who suggested ideas), > maybe `commitTransaction(CommitOptions)` or similar could be a good way forward? I like this approach. One minor concern is that if we set "ignore send errors" (or whatever we decide to name it) option without explicit flush, it'll actually

[jira] [Created] (KAFKA-17011) SupportedFeatures.MinVersion incorrectly blocks v0

Colin McCabe created KAFKA-17011: Summary: SupportedFeatures.MinVersion incorrectly blocks v0 Key: KAFKA-17011 URL: https://issues.apache.org/jira/browse/KAFKA-17011 Project: Kafka Issue

Re: [DISCUSS] KIP-1059: Enable the Producer flush() method to clear the latest send() error

Seems the option to use a config does not get a lot of support. So we need to go with some form or "overload / new method". I think Chris' point about not coupling it to `flush()` but rather `commitTransaction()` is actually a very good one; for non-tx case, the different flush variants would

[jira] [Created] (KAFKA-17010) Remove ReplicaInfo

Chia-Ping Tsai created KAFKA-17010: -- Summary: Remove ReplicaInfo Key: KAFKA-17010 URL: https://issues.apache.org/jira/browse/KAFKA-17010 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-17009) Add unit test to query nonexistent replica by describeReplicaLogDirs

Chia-Ping Tsai created KAFKA-17009: -- Summary: Add unit test to query nonexistent replica by describeReplicaLogDirs Key: KAFKA-17009 URL: https://issues.apache.org/jira/browse/KAFKA-17009 Project:

[jira] [Created] (KAFKA-17008) Update zookeeper to 3.8.4 or 3.9.2 to address CVE-2024-23944

Arushi Helms created KAFKA-17008: Summary: Update zookeeper to 3.8.4 or 3.9.2 to address CVE-2024-23944 Key: KAFKA-17008 URL: https://issues.apache.org/jira/browse/KAFKA-17008 Project: Kafka

[jira] [Resolved] (KAFKA-4230) HistogramSample needs override Sample's reset method

[ https://issues.apache.org/jira/browse/KAFKA-4230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-4230. --- Resolution: Duplicate it was fixed by KAFKA-5900 > HistogramSample needs override Sample's

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

See

Re: [DISCUSS] Apache Kafka 3.8.0 release

Thanks for the heads up Justine! On Thu, Jun 20, 2024 at 5:54 PM Justine Olshan wrote: > Sorry to derail this conversation, but just wanted to share we have a > system test blocker with https://issues.apache.org/jira/browse/KAFKA-16990 > . > Hopefully we can fix this in the next day or so. > >

Re: [DISCUSS] KIP-1059: Enable the Producer flush() method to clear the latest send() error

Hi Alieh, Thanks for the KIP. I *really* don’t like adding a config which changes the behaviour of the flush() method. We already have too many configs. But I totally understand the problem that you’re trying to solve and some of the other suggestions in this thread seem neater. Personally, I

Re: [DISCUSS] KIP-1057: Add remote log metadata flag to the dump log tool

Hi Federico, Thanks for the KIP! +1 from me. On Wed, Jun 19, 2024, 17:36 Luke Chen wrote: > Hi Federico, > > Thanks for the KIP! > It's helpful for debugging the tiered storage issues. > +1 from me. > > Thanks. > Luke > > On Tue, Jun 18, 2024 at 12:18 AM Satish Duggana > wrote: > > > Thanks

Re: [DISCUSS] Apache Kafka 3.8.0 release

Sorry to derail this conversation, but just wanted to share we have a system test blocker with https://issues.apache.org/jira/browse/KAFKA-16990. Hopefully we can fix this in the next day or so. Justine On Mon, Jun 17, 2024 at 12:19 PM David Jacot wrote: > I meant it from a time perspective,

[jira] [Created] (KAFKA-17007) Fix SourceAndTarget#equal

Chia-Ping Tsai created KAFKA-17007: -- Summary: Fix SourceAndTarget#equal Key: KAFKA-17007 URL: https://issues.apache.org/jira/browse/KAFKA-17007 Project: Kafka Issue Type: Bug

Re: [VOTE] KIP-1017: A health check endpoint for Kafka Connect

Hi all, Thanks for the votes! KIP-1017 passes with no -1s or +0s and the following +1s: - Andrew Schofield - Mickael Maison (binding) - Hector Geraldino - Greg Harris (binding) - Edoardo Comar (binding) - Adrian Preston - Federico Valeri I'll also tack on an additional +1 (binding) from myself.

[jira] [Created] (KAFKA-17006) Kafka Metrics showing type as "Untyped"

Dharani created KAFKA-17006: --- Summary: Kafka Metrics showing type as "Untyped" Key: KAFKA-17006 URL: https://issues.apache.org/jira/browse/KAFKA-17006 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-17005) Online protocol migration integration tests

Dongnuo Lyu created KAFKA-17005: --- Summary: Online protocol migration integration tests Key: KAFKA-17005 URL: https://issues.apache.org/jira/browse/KAFKA-17005 Project: Kafka Issue Type:

Re: [DISCUSS] KIP-1059: Enable the Producer flush() method to clear the latest send() error

Hi all, thanks for the KIP Alieh! LM1. Totally agree with Artem's point about the config not being the most explicit/flexible way to express this capability. Getting then to Matthias 4 options, what I don't like about 3 and 4 is that it seems they might not age very well? Aren't we going to be

[jira] [Created] (KAFKA-17004) MINOR: Remove extra synchronized blocks in SharePartitionManager

Abhinav Dixit created KAFKA-17004: - Summary: MINOR: Remove extra synchronized blocks in SharePartitionManager Key: KAFKA-17004 URL: https://issues.apache.org/jira/browse/KAFKA-17004 Project: Kafka

[jira] [Created] (KAFKA-17003) Implement SharePartitionManager close functionality

Abhinav Dixit created KAFKA-17003: - Summary: Implement SharePartitionManager close functionality Key: KAFKA-17003 URL: https://issues.apache.org/jira/browse/KAFKA-17003 Project: Kafka Issue

[jira] [Created] (KAFKA-17002) Integrate partition leader epoch in Share Partition

Apoorv Mittal created KAFKA-17002: - Summary: Integrate partition leader epoch in Share Partition Key: KAFKA-17002 URL: https://issues.apache.org/jira/browse/KAFKA-17002 Project: Kafka Issue

[jira] [Resolved] (KAFKA-16463) Automatically delete metadata log directory on ZK brokers

[ https://issues.apache.org/jira/browse/KAFKA-16463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur resolved KAFKA-16463. -- Resolution: Fixed > Automatically delete metadata log directory on ZK brokers >

[jira] [Resolved] (KAFKA-16725) Add broker configurations

[ https://issues.apache.org/jira/browse/KAFKA-16725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield resolved KAFKA-16725. -- Resolution: Fixed > Add broker configurations > - > >

[jira] [Created] (KAFKA-17001) Consider using another class to replace `AbstractConfig` to be class which alwasy returns the up-to-date configs

Chia-Ping Tsai created KAFKA-17001: -- Summary: Consider using another class to replace `AbstractConfig` to be class which alwasy returns the up-to-date configs Key: KAFKA-17001 URL:

Re: [VOTE] 3.7.1 RC2

Hi Igor, I had run system tests against this RC2, and all passed except: kafkatest.tests.core.upgrade_test failed at lz4 and snappy tests: KAFKA-16962 --> This test tested the upgrade from version [0.9 ~ 3.6] to v3.7, and only v0.9 failed,

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

See

[jira] [Created] (KAFKA-17000) Occasional AuthorizerTest thread leak

Andras Katona created KAFKA-17000: - Summary: Occasional AuthorizerTest thread leak Key: KAFKA-17000 URL: https://issues.apache.org/jira/browse/KAFKA-17000 Project: Kafka Issue Type: Test

Re: [VOTE] KIP-1035: StateStore managed changelog offsets

Hi everyone, By my count, it passes with 4 binding +1s and no -1s. Thanks for your votes, review and discussion. I'll update the KIP and start opening PRs! Regards, Nick On Wed, 19 Jun 2024 at 09:16, Lucas Brutschy wrote: > Thanks, Nick! > > +1 (binding) > > On Wed, Jun 19, 2024 at 10:14 AM

[jira] [Resolved] (KAFKA-16973) Fix caught-up condition

[ https://issues.apache.org/jira/browse/KAFKA-16973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16973. - Fix Version/s: 3.9.0 Resolution: Fixed > Fix caught-up condition >