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 >

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 =

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

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 >

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

[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 >

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

[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

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

See

[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:

[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

[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-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:

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

[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

[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:

[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 >

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

See

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

[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

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

See

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,

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

Re: Apache Kafka 3.6.0 release

Hi All, Whoever has KIP entries in the 3.6.0 release plan. Please update it with the latest status by tomorrow(end of the day 29th Jul UTC ). Thanks Satish. On Fri, 28 Jul 2023 at 12:01, Satish Duggana wrote: > > Thanks Ismael and Divij for the suggestions. > > One way was to follow the earlier

Re: Apache Kafka 3.6.0 release

Thanks Ismael and Divij for the suggestions. One way was to follow the earlier guidelines that we set for any early access release. It looks Ismael already mentioned the example of KRaft. KIP-405 mentions upgrade/downgrade and limitations sections. We can clarify that in the release notes for