[jira] [Resolved] (KAFKA-15659) Flaky test RestoreIntegrationTest.shouldInvokeUserDefinedGlobalStateRestoreListener

[ https://issues.apache.org/jira/browse/KAFKA-15659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Levani Kokhreidze resolved KAFKA-15659. --- Resolution: Fixed > Flaky test > RestoreIntegrationTest.shouldInvokeUserDefinedGlob

Re: [DISCUSS] KIP-974 Docker Image for GraalVM based Native Kafka Broker

Hi Manikumar, Thanks for the feedback. This image signifies 2 things: 1. Image should be used for the local development and testing purposes with fast startup times. (kafka-local) 2. To achieve (1) - we are providing a native executable for Apache Kafka in the docker image. (kafka-nat

[jira] [Created] (KAFKA-15701) Allow use of user policy in CreateTopicPolicy

Jiao Zhang created KAFKA-15701: -- Summary: Allow use of user policy in CreateTopicPolicy Key: KAFKA-15701 URL: https://issues.apache.org/jira/browse/KAFKA-15701 Project: Kafka Issue Type: Improv

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

See Changes: -- [...truncated 322688 lines...] Gradle Test Run :connect:runtime:test > Gradle Test Executor 47 > org.apache.kafka.connect.util.SinkUtilsTest > testValida

[VOTE] KIP-975: Docker Image for Apache Kafka

Hi, I'd like to call a vote on KIP-975 which aims to publish an official docker image for Apache Kafka. KIP - https://cwiki.apache.org/confluence/display/KAFKA/KIP-975%3A+Docker+Image+for+Apache+Kafka Discussion thread - https://lists.apache.org/thread/3g43hps2dmkyxgglplrlwpsf7vkywkyy Regards, K

[jira] [Resolved] (KAFKA-15390) FetchResponse.preferredReplica may contains fenced replica in KRaft mode

[ https://issues.apache.org/jira/browse/KAFKA-15390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming resolved KAFKA-15390. - Fix Version/s: 3.6.0 Resolution: Fixed > FetchResponse.preferredReplica may contains fenc

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

See Changes: -- [...truncated 319922 lines...] Gradle Test Run :core:test > Gradle Test Executor 93 > ZkMigrationClientTest > testEmptyWrite() STARTED Gradle Test Run :co

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

See Changes: -- [...truncated 426588 lines...] Gradle Test Run :connect:runtime:test > Gradle Test Executor 44 > org.apache.kafka.connect.storage.MemoryStatusBackingStore

Re: [DISCUSS] KIP-992 Proposal to introduce IQv2 Query Types: TimestampedKeyQuery and TimestampedRangeQuery

Thanks for the KIP Hanyu! One question: why not return an iterator of `ValueAndTimestamp` for `TimestampedKeyQuery`? I suppose for a ts-kv-store, there could be multiple timestamps associated with the same key? Hao On Thu, Oct 26, 2023 at 10:23 AM Matthias J. Sax wrote: > Would we really get a

Jenkins build is unstable: Kafka » Kafka Branch Builder » 3.5 #90

See

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.6 #102

See Changes: -- [...truncated 309389 lines...] Gradle Test Run :streams:test > Gradle Test Executor 88 > DefaultStateUpdaterTest > shouldNotResumeStandbyTaskInRemovedTasks()

[jira] [Created] (KAFKA-15700) FetchFromFollowerIntegrationTest is flaky

Calvin Liu created KAFKA-15700: -- Summary: FetchFromFollowerIntegrationTest is flaky Key: KAFKA-15700 URL: https://issues.apache.org/jira/browse/KAFKA-15700 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-15699) MirrorConnectorsIntegrationBaseTest is flaky

Calvin Liu created KAFKA-15699: -- Summary: MirrorConnectorsIntegrationBaseTest is flaky Key: KAFKA-15699 URL: https://issues.apache.org/jira/browse/KAFKA-15699 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-15698) KRaft mode brokers should clean up stray partitions from migration

David Arthur created KAFKA-15698: Summary: KRaft mode brokers should clean up stray partitions from migration Key: KAFKA-15698 URL: https://issues.apache.org/jira/browse/KAFKA-15698 Project: Kafka

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.6 #101

See Changes: -- [...truncated 411102 lines...] Gradle Test Run :connect:runtime:test > Gradle Test Executor 44 > org.apache.kafka.connect.storage.KafkaStatusBackingStoreForma

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

See Changes: -- [...truncated 373707 lines...] Gradle Test Run :connect:runtime:test > Gradle Test Executor 45 > org.apache.kafka.connect.util.TopicAdminTest > throwsWith

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

See Changes: -- [...truncated 469963 lines...] Gradle Test Run :streams:integrationTest > Gradle Test Executor 183 > TableTableJoinIntegrationTest > [caching enabled = true] >

[jira] [Created] (KAFKA-15697) Add local assignor and ensure it cannot be used with server side assignor

Philip Nee created KAFKA-15697: -- Summary: Add local assignor and ensure it cannot be used with server side assignor Key: KAFKA-15697 URL: https://issues.apache.org/jira/browse/KAFKA-15697 Project: Kafka

Re: [DISCUSS] KIP-992 Proposal to introduce IQv2 Query Types: TimestampedKeyQuery and TimestampedRangeQuery

Would we really get a ClassCastException? From my understanding, the store would reject the query as unsupported and thus the returned `QueryResult` object would have it's internal flag set to indicate the failure, but no exception would be thrown directly? (Of course, there might be an excep

Re: [VOTE] KIP-988 Streams StandbyUpdateListener

+1 (binding) On 10/25/23 4:06 PM, Sophie Blee-Goldman wrote: Happy to see this -- that's a +1 (binding) from me On Mon, Oct 23, 2023 at 6:33 AM Bill Bejeck wrote: This is a great addition +1(binding) -Bill On Fri, Oct 20, 2023 at 2:29 PM Almog Gavra wrote: +1 (non-binding) - great impr

Re: [DISCUSS] KIP-988 Streams Standby Task Update Listener

Thanks. SGTM. On 10/25/23 4:06 PM, Sophie Blee-Goldman wrote: That all sounds good to me! Thanks for the KIP On Wed, Oct 25, 2023 at 3:47 PM Colt McNealy wrote: Hi Sophie, Matthias, Bruno, and Eduwer— Thanks for your patience as I have been scrambling to catch up after a week of business tr

[jira] [Resolved] (KAFKA-15644) Fix CVE-2023-4586 in netty:handler

[ https://issues.apache.org/jira/browse/KAFKA-15644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-15644. Fix Version/s: 3.7.0 Resolution: Fixed > Fix CVE-2023-4586 in netty:handler > -

[jira] [Created] (KAFKA-15696) Revoke partitions on Consumer.close()

Kirk True created KAFKA-15696: - Summary: Revoke partitions on Consumer.close() Key: KAFKA-15696 URL: https://issues.apache.org/jira/browse/KAFKA-15696 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-15695) Local log start offset is not updated on the follower after rebuilding remote log auxiliary state

Nikhil Ramakrishnan created KAFKA-15695: --- Summary: Local log start offset is not updated on the follower after rebuilding remote log auxiliary state Key: KAFKA-15695 URL: https://issues.apache.org/jira/brows

[jira] [Created] (KAFKA-15694) New integration tests to have full coverage for preview

Kirk True created KAFKA-15694: - Summary: New integration tests to have full coverage for preview Key: KAFKA-15694 URL: https://issues.apache.org/jira/browse/KAFKA-15694 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-15693) Disabling scheduled rebalance delay in Connect can lead to indefinitely unassigned connectors and tasks

Chris Egerton created KAFKA-15693: - Summary: Disabling scheduled rebalance delay in Connect can lead to indefinitely unassigned connectors and tasks Key: KAFKA-15693 URL: https://issues.apache.org/jira/browse/KAFK

[jira] [Created] (KAFKA-15692) New integration tests to have full coverage

Kirk True created KAFKA-15692: - Summary: New integration tests to have full coverage Key: KAFKA-15692 URL: https://issues.apache.org/jira/browse/KAFKA-15692 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-15691) Upgrade existing and add new system tests to use new coordinator

Kirk True created KAFKA-15691: - Summary: Upgrade existing and add new system tests to use new coordinator Key: KAFKA-15691 URL: https://issues.apache.org/jira/browse/KAFKA-15691 Project: Kafka I

[jira] [Created] (KAFKA-15690) Flaky integration tests

Calvin Liu created KAFKA-15690: -- Summary: Flaky integration tests Key: KAFKA-15690 URL: https://issues.apache.org/jira/browse/KAFKA-15690 Project: Kafka Issue Type: Bug Reporter: Cal

Re: [VOTE] KIP-967: Support custom SSL configuration for Kafka Connect RestServer

I support this KIP +1 > 23 окт. 2023 г., в 20:20, Greg Harris > написал(а): > > Hey Taras, > > Thanks for the KIP! > > The design you propose follows the conventions started in KIP-519, and > should feel natural to operators familiar with the broker feature. > I also like that we're able to

[jira] [Created] (KAFKA-15689) KRaftMigrationDriver not logging the skipped event when expected state is wrong

Paolo Patierno created KAFKA-15689: -- Summary: KRaftMigrationDriver not logging the skipped event when expected state is wrong Key: KAFKA-15689 URL: https://issues.apache.org/jira/browse/KAFKA-15689 P

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

See

Re: [DISCUSS] KIP-990: Capability to SUSPEND Tasks on DeserializationException

1. Woops! I've fixed that now. Thanks for catching that. 2. I agree, I'll remove the LogAndPause handler so it's clear this is an advanced feature. I'll also add some documentation to DeserializationExceptionResponse#SUSPEND that explains the care users should approach it with. 3a. This is intere

[jira] [Created] (KAFKA-15688) Partition leader election not running when disk IO hangs

Peter Sinoros-Szabo created KAFKA-15688: --- Summary: Partition leader election not running when disk IO hangs Key: KAFKA-15688 URL: https://issues.apache.org/jira/browse/KAFKA-15688 Project: Kafka

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

See Changes: -- [...truncated 430754 lines...] Gradle Test Run :core:test > Gradle Test Executor 91 > ZooKeeperClientTest > testZNodeChangeHandlerForCreation() PASSED Gra

[jira] [Created] (KAFKA-15687) Update host address for the GoupMetadata of static members

Yu Wang created KAFKA-15687: --- Summary: Update host address for the GoupMetadata of static members Key: KAFKA-15687 URL: https://issues.apache.org/jira/browse/KAFKA-15687 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-15685) Missing compatibility for MinGW (windows)

[ https://issues.apache.org/jira/browse/KAFKA-15685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Divij Vaidya resolved KAFKA-15685. -- Resolution: Fixed > Missing compatibility for MinGW (windows) > --

[jira] [Created] (KAFKA-15686) Consumer should be able to detect network problem

Jiahongchao created KAFKA-15686: --- Summary: Consumer should be able to detect network problem Key: KAFKA-15686 URL: https://issues.apache.org/jira/browse/KAFKA-15686 Project: Kafka Issue Type: N

[jira] [Created] (KAFKA-15685) Missing compatibility for MinGW (windows)

Divij Vaidya created KAFKA-15685: Summary: Missing compatibility for MinGW (windows) Key: KAFKA-15685 URL: https://issues.apache.org/jira/browse/KAFKA-15685 Project: Kafka Issue Type: Improve

[jira] [Resolved] (KAFKA-15200) verify pre-requisite at start of release.py

[ https://issues.apache.org/jira/browse/KAFKA-15200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Divij Vaidya resolved KAFKA-15200. -- Resolution: Fixed > verify pre-requisite at start of release.py >