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

See

Re: [DISCUSS] KIP-939: Support Participation in 2PC

Hi Rowland, Thank you for your reply. I think I understand what you're saying and just tried to provide a quick summary. The https://cwiki.apache.org/confluence/display/KAFKA/KIP-939%3A+Support+Participation+in+2PC#KIP939:SupportParticipationin2PC-Explicit%E2%80%9Cprepare%E2%80%9DRPC actually

Re: [DISCUSS] KIP-939: Support Participation in 2PC

Hi Artem, I don't think that you understand what I am saying. In any transaction, there is work done before the call to prepareTranscation() and work done afterwards. Any work performed before the call to prepareTransaction() can be aborted after a relatively short timeout if the client fails. It

Re: [DISCUSS] KIP-890 Server Side Defense

Hi, Justine, Thanks for the reply. Since AddPartitions is an inter broker request, will its version be gated only by TV or other features like MV too? For example, if we need to change the protocol for AddPartitions for reasons other than txn verification in the future, will the new version be

Re: [DISCUSS] KIP-890 Server Side Defense

One TV gates the flexible feature version (no rpcs involved, only the transactional records that should only be gated by TV) Another TV gates the ability to turn on kip-890 part 2. This would gate the version of Produce and EndTxn (likely only used by transactions), and specifies a flag in

Re: [DISCUSS] KIP-890 Server Side Defense

Hi, Justine, Which PRC/record protocols will TV guard? Going forward, will those PRC/record protocols only be guarded by TV and not by other features like MV? Thanks, Jun On Mon, Feb 5, 2024 at 2:41 PM Justine Olshan wrote: > Hi Jun, > > Sorry I think I misunderstood your question or

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.7 #90

See

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

See

Re: [DISCUSS] KIP-853: KRaft Controller Membership Changes

Hey Jose, A few more questions: 1. When adding a voter, the KIP proposes to return a timeout error if the voter cannot catch up in time. It might be more useful to return a more specific error so that an operator can understand why the timeout occurred. Alternatively, perhaps we could keep the

Re: [DISCUSS] KIP-890 Server Side Defense

Hi Jun, Sorry I think I misunderstood your question or answered incorrectly. The TV version should ideally be fully independent from MV. At least for the changes I proposed, TV should not affect MV and MV should not affect TV/ I think if we downgrade TV, only that feature should downgrade.

Re: [DISCUSS] KIP-939: Support Participation in 2PC

Hi, Artem, Thanks for the reply. 20. For Flink usage, it seems that the APIs used to abort and commit a prepared txn are not symmetric. To abort, the app will just call producer.initTransactions(false) To commit, the app needs to call producer.initTransactions(true)

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

See

Re: [DISCUSS] KIP-890 Server Side Defense

Hi, Justine, Thanks for the reply. So, if we downgrade TV, we could implicitly downgrade another feature (say MV) that has dependency (e.g. RPC). What would we return for FinalizedFeatures for MV in ApiVersionsResponse in that case? Thanks, Jun On Fri, Feb 2, 2024 at 1:06 PM Justine Olshan

[jira] [Created] (KAFKA-16225) Flaky test suite LogDirFailureTest

Greg Harris created KAFKA-16225: --- Summary: Flaky test suite LogDirFailureTest Key: KAFKA-16225 URL: https://issues.apache.org/jira/browse/KAFKA-16225 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-16221) IllegalStateException from Producer

[ https://issues.apache.org/jira/browse/KAFKA-16221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-16221. - Resolution: Fixed > IllegalStateException from Producer >

[jira] [Created] (KAFKA-16224) Fix handling of deleted topic when auto-committing before revocation

Lianet Magrans created KAFKA-16224: -- Summary: Fix handling of deleted topic when auto-committing before revocation Key: KAFKA-16224 URL: https://issues.apache.org/jira/browse/KAFKA-16224 Project:

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.7 #89

See

Re: [DISCUSS] KIP-971 Expose replication-offset-lag MirrorMaker2 metric

Hi Mickael! Any further thoughts on this? Thanks, Elkhan On Thu, 18 Jan 2024 at 11:53, Mickael Maison wrote: > Hi Elxan, > > Thanks for the updates. > > We used dots to separate words in configuration names, so I think > replication.offset.lag.metric.last-replicated-offset.ttl should be >

[jira] [Resolved] (KAFKA-15717) KRaft support in LeaderEpochIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-15717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-15717. Fix Version/s: 3.8.0 Resolution: Fixed > KRaft support in

[jira] [Created] (KAFKA-16223) Replace EasyMock and PowerMock with Mockito for KafkaConfigBackingStoreTest

Hector Geraldino created KAFKA-16223: Summary: Replace EasyMock and PowerMock with Mockito for KafkaConfigBackingStoreTest Key: KAFKA-16223 URL: https://issues.apache.org/jira/browse/KAFKA-16223

[jira] [Created] (KAFKA-16222) Incorrect default user-principal quota after migration

Dominik created KAFKA-16222: --- Summary: Incorrect default user-principal quota after migration Key: KAFKA-16222 URL: https://issues.apache.org/jira/browse/KAFKA-16222 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-14384) Flaky Test SelfJoinUpgradeIntegrationTest.shouldUpgradeWithTopologyOptimizationOff

[ https://issues.apache.org/jira/browse/KAFKA-14384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy resolved KAFKA-14384. Resolution: Fixed > Flaky Test >

[jira] [Resolved] (KAFKA-14385) Flaky Test QueryableStateIntegrationTest.shouldNotMakeStoreAvailableUntilAllStoresAvailable

[ https://issues.apache.org/jira/browse/KAFKA-14385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy resolved KAFKA-14385. Resolution: Fixed > Flaky Test >

[jira] [Resolved] (KAFKA-8691) Flakey test ProcessorContextTest#shouldNotAllowToScheduleZeroMillisecondPunctuation

[ https://issues.apache.org/jira/browse/KAFKA-8691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy resolved KAFKA-8691. --- Resolution: Fixed > Flakey test >

[jira] [Resolved] (KAFKA-9897) Flaky Test StoreQueryIntegrationTest#shouldQuerySpecificActivePartitionStores

[ https://issues.apache.org/jira/browse/KAFKA-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy resolved KAFKA-9897. --- Resolution: Fixed > Flaky Test

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

See

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.7 #88

See

[jira] [Resolved] (KAFKA-15460) Add group type filter to ListGroups API

[ https://issues.apache.org/jira/browse/KAFKA-15460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-15460. - Fix Version/s: 3.8.0 Resolution: Fixed > Add group type filter to ListGroups API >

Re: [VOTE] 3.7.0 RC2

Thanks Mickael, sounds good. KAFKA-160195 and KAFKA-16157 were both merged! I was made aware of one final blocker, this time for streams - KAFKA-16221. Matthias was prompt with a short hotfix PR: https://github.com/apache/kafka/pull/15315 After that goes into 3.7, I think I will be free to