Re: [DISCUSS] KIP-890 Server Side Defense

Hi Jun, 101.3 I can change "last seen" to "current producer id and epoch" if that was the part that was confusing 110 I can mention this 111 I can do that 112 We still need it. But I am still finalizing the design. I will update the KIP once I get the information finalized. Sorry for the delays.

[jira] [Created] (KAFKA-16180) Full metadata request sometimes fails during zk migration

Colin McCabe created KAFKA-16180: Summary: Full metadata request sometimes fails during zk migration Key: KAFKA-16180 URL: https://issues.apache.org/jira/browse/KAFKA-16180 Project: Kafka

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

See

Re: [DISCUSS] KIP-1014: Managing Unstable Metadata Versions in Apache Kafka

Hi Colin, > I think feature flags are somewhat orthogonal to the stable / unstable discussion I think feature flags can be used as an alternative to achieve similar results as stable / unstable functionality. As well as long-lived feature branches. In my experience, I've seen feature flags to

[jira] [Created] (KAFKA-16179) NPE handle ApiVersions during controller failover

Jason Gustafson created KAFKA-16179: --- Summary: NPE handle ApiVersions during controller failover Key: KAFKA-16179 URL: https://issues.apache.org/jira/browse/KAFKA-16179 Project: Kafka

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

See

[jira] [Created] (KAFKA-16178) AsyncKafkaConsumer doesn't retry joining the group after rediscovering group coordinator

Dongnuo Lyu created KAFKA-16178: --- Summary: AsyncKafkaConsumer doesn't retry joining the group after rediscovering group coordinator Key: KAFKA-16178 URL: https://issues.apache.org/jira/browse/KAFKA-16178

Re: [DISCUSS] KIP-890 Server Side Defense

Hi, Justine, Thanks for the reply. 101.3 In the non-overflow case, the previous ID is the same as the produce ID for the complete marker too, but we set the previous ID in the complete marker. Earlier you mentioned that this is to know that the marker is written by the new client so that we

[jira] [Resolved] (KAFKA-15811) implement capturing client port information from Socket Server

[ https://issues.apache.org/jira/browse/KAFKA-15811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-15811. - Fix Version/s: 3.8.0 Resolution: Fixed merged the PR to trunk. > implement capturing client

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

See

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

Hi Mickael, Thanks for your feedback. I've updated the metric name to "replication-record-lage" and I've modified the property names to use dots instead of hyphes. I'm curious to know what you think of the proposed default values, let me know! Thanks, Elkhan On Thu, 18 Jan 2024 at 11:53,

[jira] [Created] (KAFKA-16177) Flaky test: testBatchSizeZeroNoPartitionNoRecordKey – kafka.api.PlaintextProducerSendTest

Apoorv Mittal created KAFKA-16177: - Summary: Flaky test: testBatchSizeZeroNoPartitionNoRecordKey – kafka.api.PlaintextProducerSendTest Key: KAFKA-16177 URL: https://issues.apache.org/jira/browse/KAFKA-16177

[jira] [Created] (KAFKA-16176) Flaky test: testSendToPartitionWithFollowerShutdownShouldNotTimeout – kafka.api.PlaintextProducerSendTest

Apoorv Mittal created KAFKA-16176: - Summary: Flaky test: testSendToPartitionWithFollowerShutdownShouldNotTimeout – kafka.api.PlaintextProducerSendTest Key: KAFKA-16176 URL:

[jira] [Created] (KAFKA-16175) Flaky test: testAsynchronousAuthorizerAclUpdatesDontBlockRequestThreads – kafka.api.SslAdminIntegrationTest

Apoorv Mittal created KAFKA-16175: - Summary: Flaky test: testAsynchronousAuthorizerAclUpdatesDontBlockRequestThreads – kafka.api.SslAdminIntegrationTest Key: KAFKA-16175 URL:

[jira] [Created] (KAFKA-16174) Flaky test: testDescribeQuorumStatusSuccessful – org.apache.kafka.tools.MetadataQuorumCommandTest

Apoorv Mittal created KAFKA-16174: - Summary: Flaky test: testDescribeQuorumStatusSuccessful – org.apache.kafka.tools.MetadataQuorumCommandTest Key: KAFKA-16174 URL:

[jira] [Created] (KAFKA-16173) Flaky test: testTimeoutMetrics – org.apache.kafka.controller.QuorumControllerMetricsIntegrationTest

Apoorv Mittal created KAFKA-16173: - Summary: Flaky test: testTimeoutMetrics – org.apache.kafka.controller.QuorumControllerMetricsIntegrationTest Key: KAFKA-16173 URL:

[jira] [Created] (KAFKA-16172) Flaky test: testProducerConsumerOverrideLowerQuota – kafka.api.UserQuotaTest

Apoorv Mittal created KAFKA-16172: - Summary: Flaky test: testProducerConsumerOverrideLowerQuota – kafka.api.UserQuotaTest Key: KAFKA-16172 URL: https://issues.apache.org/jira/browse/KAFKA-16172

[jira] [Resolved] (KAFKA-16113) AsyncKafkaConsumer: Add missing offset commit metrics

[ https://issues.apache.org/jira/browse/KAFKA-16113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Philip Nee resolved KAFKA-16113. Resolution: Fixed > AsyncKafkaConsumer: Add missing offset commit metrics >

[jira] [Created] (KAFKA-16171) Controller failover during ZK migration can lead to controller unavailability for ZK brokers

David Arthur created KAFKA-16171: Summary: Controller failover during ZK migration can lead to controller unavailability for ZK brokers Key: KAFKA-16171 URL: https://issues.apache.org/jira/browse/KAFKA-16171

[jira] [Resolved] (KAFKA-16170) Continuous never ending logs observed when running single node kafka in kraft mode with default KRaft properties in 3.7.0 RC2

[ https://issues.apache.org/jira/browse/KAFKA-16170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-16170. Resolution: Duplicate Duplicate of https://issues.apache.org/jira/browse/KAFKA-16144 >

[jira] [Created] (KAFKA-16170) Infinite logs observed when running single node kafka in kraft mode with default KRaft properties in 3.7.0 RC2

Vedarth Sharma created KAFKA-16170: -- Summary: Infinite logs observed when running single node kafka in kraft mode with default KRaft properties in 3.7.0 RC2 Key: KAFKA-16170 URL:

[jira] [Created] (KAFKA-16169) FencedException in commitAsync not propagated without callback

Lucas Brutschy created KAFKA-16169: -- Summary: FencedException in commitAsync not propagated without callback Key: KAFKA-16169 URL: https://issues.apache.org/jira/browse/KAFKA-16169 Project: Kafka

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

See

[jira] [Created] (KAFKA-16168) Implement GroupCoordinator.onPartitionsDeleted

David Jacot created KAFKA-16168: --- Summary: Implement GroupCoordinator.onPartitionsDeleted Key: KAFKA-16168 URL: https://issues.apache.org/jira/browse/KAFKA-16168 Project: Kafka Issue Type: