Re: [DISCUSS] KIP-910: Update Source offsets for Source Connectors without producing records

Hey Yash, Thanks for your comments. 1) Hmm the question is how do you qualify a partition as stale or old? Let's say a connector has implemented updateOffsets and for a certain partition for which no records are received then it will update it's offsets. So technically that offset can't be termed

Re: [DISCUSS] KIP-953: partition method to be overloaded to accept headers as well.

Hi Sagar, Thanks for your comments. 1) Server-side partitioning doesn’t necessarily mean that there’s only one way to do it. It just means that the partitioning logic runs on the broker and any configuration of partitioning applies to the broker’s partitioner. If we ever see a KIP for this, that’

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

See

[jira] [Created] (KAFKA-15266) Log configs ignore static configs set non primary synonyms

Aman Harish Gandhi created KAFKA-15266: -- Summary: Log configs ignore static configs set non primary synonyms Key: KAFKA-15266 URL: https://issues.apache.org/jira/browse/KAFKA-15266 Project: Kafka

Re: [VOTE] KIP-951: Leader discovery optimisations for the client

Thanks Jose. On Thu, Jul 27, 2023 at 5:46 PM José Armando García Sancio wrote: > The KIP LGTM. Thanks for the design. I am looking forward to the > implementation. > > +1 (binding). > > Thanks! > -- > -José > -- Regards, Mayank Shekhar Narula

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

See

[jira] [Resolved] (KAFKA-15246) CoordinatorContext should be protected by a lock

[ https://issues.apache.org/jira/browse/KAFKA-15246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-15246. - Fix Version/s: 3.6.0 Reviewer: Justine Olshan Resolution: Fixed > CoordinatorCon

[jira] [Created] (KAFKA-15267) Cluster-wide disablement of Tiered Storage

Christo Lolov created KAFKA-15267: - Summary: Cluster-wide disablement of Tiered Storage Key: KAFKA-15267 URL: https://issues.apache.org/jira/browse/KAFKA-15267 Project: Kafka Issue Type: Sub-

[jira] [Resolved] (KAFKA-14501) Implement Heartbeat API

[ https://issues.apache.org/jira/browse/KAFKA-14501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-14501. - Fix Version/s: 3.6.0 Reviewer: David Jacot Resolution: Fixed > Implement Heartbe

Re: [VOTE] KIP-959 Add BooleanConverter to Kafka Connect

Hi everyone, Thanks everyone who has reviewed and voted for this KIP. So far it has received 3 non-binding votes (Andrew Schofield, Yash Mayya, Kamal Chandraprakash) and 2 binding votes (Chris Egerton, Greg Harris)- still shy of one binding vote to pass. Can we get help from a committer to pu

[jira] [Created] (KAFKA-15268) Consider replacing Subscription Metadata by a hash

David Jacot created KAFKA-15268: --- Summary: Consider replacing Subscription Metadata by a hash Key: KAFKA-15268 URL: https://issues.apache.org/jira/browse/KAFKA-15268 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-15269) Clean up the RaftClient interface

José Armando García Sancio created KAFKA-15269: -- Summary: Clean up the RaftClient interface Key: KAFKA-15269 URL: https://issues.apache.org/jira/browse/KAFKA-15269 Project: Kafka

[jira] [Created] (KAFKA-15270) Integration tests for AsyncConsumer simple consume case

Lianet Magrans created KAFKA-15270: -- Summary: Integration tests for AsyncConsumer simple consume case Key: KAFKA-15270 URL: https://issues.apache.org/jira/browse/KAFKA-15270 Project: Kafka I

[jira] [Created] (KAFKA-15271) TimelineHashMap.entrySet yield unexpected results with nested TimelineHashMap

David Jacot created KAFKA-15271: --- Summary: TimelineHashMap.entrySet yield unexpected results with nested TimelineHashMap Key: KAFKA-15271 URL: https://issues.apache.org/jira/browse/KAFKA-15271 Project:

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

See

[jira] [Resolved] (KAFKA-14702) Extend server side assignor to support rack aware replica placement

[ https://issues.apache.org/jira/browse/KAFKA-14702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-14702. - Fix Version/s: 3.6.0 Resolution: Fixed > Extend server side assignor to support rack awar

Re: [DISCUSS] KIP-954: expand default DSL store configuration to custom types

Thanks Guozhang & Sophie: A2. Will clarify in the KIP A3. Will change back to the deprecated version! A5. Seems like I'm outnumbered... DslStoreSuppliers it is. Will update the KIP today. - Almog On Thu, Jul 27, 2023 at 12:42 PM Guozhang Wang wrote: > Yes, that sounds right to me. Thanks Soph

[jira] [Resolved] (KAFKA-15263) KRaftMigrationDriver can run the migration twice

[ https://issues.apache.org/jira/browse/KAFKA-15263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur resolved KAFKA-15263. -- Resolution: Fixed > KRaftMigrationDriver can run the migration twice > ---

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

Hi all, We are considering replacing the Sarama Go client with confluent-kafka-go which is supported and seems promising. Regarding reliability and performance, does anybody want to share the experience? Whether or not it is the experience in pr

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

See Changes: -- [...truncated 396219 lines...] [Pipeline] } Gradle Test Run :streams:integrationTest > Gradle Test Executor 179 > TableTableJoinIntegrationTest > [caching

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

See Changes: -- [...truncated 281693 lines...] Gradle Test Run :streams:integrationTest > Gradle Test Executor 178 > VersionedKeyValueStoreIntegrationTest > shouldRestore STAR

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

See Changes: -- [...truncated 295220 lines...] Gradle Test Run :streams:integrationTest > Gradle Test Executor 182 > TableTableJoinIntegrationTest > [caching enabled = fal

Re: [DISCUSS] KIP-954: expand default DSL store configuration to custom types

OK! I think I got everything, but I'll give the KIP another read with fresh eyes later. Just a reminder that the voting is open, so go out and exercise your civic duty! ;) - Almog On Fri, Jul 28, 2023 at 10:38 AM Almog Gavra wrote: > Thanks Guozhang & Sophie: > > A2. Will clarify in the KIP > A