[jira] [Created] (KAFKA-15344) Kafka Streams should include the message leader epoch when committing offsets

David Mao created KAFKA-15344: - Summary: Kafka Streams should include the message leader epoch when committing offsets Key: KAFKA-15344 URL: https://issues.apache.org/jira/browse/KAFKA-15344 Project: Kafk

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

See

[jira] [Created] (KAFKA-15345) KRaft leader should notify the listener only when it has read up to the leader's epoch

José Armando García Sancio created KAFKA-15345: -- Summary: KRaft leader should notify the listener only when it has read up to the leader's epoch Key: KAFKA-15345 URL: https://issues.apache.org/jira/br

Re: [DISCUSS] KIP-960: Support interactive queries (IQv2) for versioned state stores

Hi all, thanks to all for the great points you mentioned. Addressed reviews are listed as follows: 1. The methods are defined as composable, as Lucas suggested. Now we have even more types of single-key_multi-timestamp queries. As Matthias suggested in his first review, now with composable methods

[jira] [Created] (KAFKA-15346) Single-Key_single-multi-timestamp IQs with versioned state stores

Alieh Saeedi created KAFKA-15346: Summary: Single-Key_single-multi-timestamp IQs with versioned state stores Key: KAFKA-15346 URL: https://issues.apache.org/jira/browse/KAFKA-15346 Project: Kafka

[jira] [Created] (KAFKA-15347) Single-Key_multi-timestamp IQs with versioned state stores

Alieh Saeedi created KAFKA-15347: Summary: Single-Key_multi-timestamp IQs with versioned state stores Key: KAFKA-15347 URL: https://issues.apache.org/jira/browse/KAFKA-15347 Project: Kafka Is

[jira] [Created] (KAFKA-15348) Range IQs with versioned state stores

Alieh Saeedi created KAFKA-15348: Summary: Range IQs with versioned state stores Key: KAFKA-15348 URL: https://issues.apache.org/jira/browse/KAFKA-15348 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-15349) ducker-ak should fail fast when gradlew systemTestLibs fails

Greg Harris created KAFKA-15349: --- Summary: ducker-ak should fail fast when gradlew systemTestLibs fails Key: KAFKA-15349 URL: https://issues.apache.org/jira/browse/KAFKA-15349 Project: Kafka I

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

See Changes: -- [...truncated 403991 lines...] Gradle Test Run :streams:test > Gradle Test Executor 85 > StoreQueryIntegrationTest > shouldQueryOnlyActivePartitionStoresB

[jira] [Created] (KAFKA-15350) MetadataLoaderMetrics has ClassNotFoundException in system tests

Greg Harris created KAFKA-15350: --- Summary: MetadataLoaderMetrics has ClassNotFoundException in system tests Key: KAFKA-15350 URL: https://issues.apache.org/jira/browse/KAFKA-15350 Project: Kafka

[jira] [Resolved] (KAFKA-15350) MetadataLoaderMetrics has ClassNotFoundException in system tests

[ https://issues.apache.org/jira/browse/KAFKA-15350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-15350. - Resolution: Invalid I believe this was an environmental problem, due to some stale artifacts. A

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

See

[jira] [Resolved] (KAFKA-15329) Make default `remote.log.metadata.manager.class.name` as topic based RLMM

[ https://issues.apache.org/jira/browse/KAFKA-15329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-15329. --- Resolution: Fixed > Make default `remote.log.metadata.manager.class.name` as topic based RLMM >

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.4 #160

See Changes: -- [...truncated 522289 lines...] Gradle Test Run :core:integrationTest > Gradle Test Executor 167 > KafkaZkClientTest > testGetDataAndStat() PASSED Gradle Tes

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.1 #150

See Changes: -- [...truncated 439938 lines...] CreateTopicsRequestWithForwardingTest > testForwardToController() PASSED DelegationTokenRequestsTest > testDelegationTokenRequ

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.5 #59

See Changes: -- [...truncated 282303 lines...] Gradle Test Run :core:integrationTest > Gradle Test Executor 178 > ZooKeeperClientTest > testStateChangeHandlerForAuthFailure()

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.3 #187

See Changes: -- [...truncated 503740 lines...] org.apache.kafka.streams.integration.StandbyTaskCreationIntegrationTest > shouldCreateStandByTasksForMaterializedAndOptimizedS

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

See Changes: -- [...truncated 422811 lines...] Gradle Test Run :streams:test > Gradle Test Executor 85 > StoreQueryIntegrationTest > shouldQuerySpecificStalePartitionSto

Re: Feedback of using the 'confluent-kafka-go' for reliablity and performance

Hi Kenneth, Recently we noticed that there's an issue in the Sarama client's broker address management. Although the Sarama client fetches the latest broker information and stores it in the brokers list, the seedbrokers

[jira] [Created] (KAFKA-15351) Update log-start-offset after leader election for topics enabled with remote storage

Kamal Chandraprakash created KAFKA-15351: Summary: Update log-start-offset after leader election for topics enabled with remote storage Key: KAFKA-15351 URL: https://issues.apache.org/jira/browse/KAFKA-153

[jira] [Created] (KAFKA-15352) Ensure consistency while deleting the remote log segments

Kamal Chandraprakash created KAFKA-15352: Summary: Ensure consistency while deleting the remote log segments Key: KAFKA-15352 URL: https://issues.apache.org/jira/browse/KAFKA-15352 Project: Kaf