[jira] [Created] (KAFKA-17024) add integration test for TransactionsCommand

Chia-Ping Tsai created KAFKA-17024: -- Summary: add integration test for TransactionsCommand Key: KAFKA-17024 URL: https://issues.apache.org/jira/browse/KAFKA-17024 Project: Kafka Issue Type:

Re: [DISCUSS] KIP-1027 Add MockFixedKeyProcessorContext

Thanks for the update. About the wiki account. Creating the account was done by Infra, but setting permissions is on us. Fixed. About the KIP: Should we pass-in key/value/ts/headers and mimic the constructors for `TestRecord` (ie, have similar createXxx(...) overloads as factory methods as

Re: [VOTE] KIP-1022 Formatting and Updating Features

Thanks for the update Colin. The changes make sense to me. Are you planning to update the KIP to reflect this new RPC version? It would be good to document the semantics explained above in the KIP. Thanks! On Fri, Jun 21, 2024 at 8:22 PM Justine Olshan wrote: > > Ok makes sense. I will update m

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

See

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

See

Re: [DISCUSS] KIP-1027 Add MockFixedKeyProcessorContext

Hi Matthias, That makes sense to me! I updated the code, definitely want to get your perspective on whether or not we want to support the `createFixedKeyRecord(Record)` method, since we already have the `TestRecord` defined in the utils, it might be cleaner to just support the `createFixedKeyRecor

[jira] [Created] (KAFKA-17023) add PCollectionsImmutableMap to ConcurrentMapBenchmark

Chia-Ping Tsai created KAFKA-17023: -- Summary: add PCollectionsImmutableMap to ConcurrentMapBenchmark Key: KAFKA-17023 URL: https://issues.apache.org/jira/browse/KAFKA-17023 Project: Kafka Is

[jira] [Created] (KAFKA-17022) Fix error-prone in KafkaApis#handleFetchRequest

Chia-Ping Tsai created KAFKA-17022: -- Summary: Fix error-prone in KafkaApis#handleFetchRequest Key: KAFKA-17022 URL: https://issues.apache.org/jira/browse/KAFKA-17022 Project: Kafka Issue Ty

[jira] [Resolved] (KAFKA-12227) Add method "Producer#send" to return CompletionStage instead of Future

[ https://issues.apache.org/jira/browse/KAFKA-12227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12227. Resolution: Duplicate > Add method "Producer#send" to return CompletionStage instead of F

[jira] [Created] (KAFKA-17021) Migrate AclCommandTest to new test infra

Chia-Ping Tsai created KAFKA-17021: -- Summary: Migrate AclCommandTest to new test infra Key: KAFKA-17021 URL: https://issues.apache.org/jira/browse/KAFKA-17021 Project: Kafka Issue Type: Impr

[jira] [Resolved] (KAFKA-15713) KRaft support in SaslClientsWithInvalidCredentialsTest

[ https://issues.apache.org/jira/browse/KAFKA-15713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-15713. Fix Version/s: 3.9.0 Resolution: Fixed > KRaft support in SaslClientsWithInvalidCre

Enabling Retry for Meta Data Fetch

Hi Apache kafka team, As per the documentation, the kafka producer directly communicates with the leader of the topic partition to produce a message. In order to fetch the leader information, it makes a meta data fetch call before its first produce, further caches it and refreshes depending upon m