Re: [DISCUSS] KIP-1153: Extending support for Microsecond Precision for Kafka Connect

Hi Chris, Can you please review this one too? On Sat, Apr 5, 2025 at 7:00 AM pritam kumar wrote: > Hi Kafka Community, > Sorry due to some changes I had to change the link to the kip. > Here is the updated KIP link: > https://cwiki.apache.org/confluence/display/KAFKA/KIP-1154%

Re: [DISCUSS] KIP-1173: Connect Storage Topics Sharing Across Clusters

; > Finally, I think we may want to use a more structured format for record > keys. IIRC there's essentially no limits on what characters can be used for > group IDs (please correct me if I'm wrong), so we can't use any kind of > delimiter that won't be included in the group

Re: [DISCUSS] KIP-1173: Connect Storage Topics Sharing Across Clusters

ilures: The unavailability/corruption of one topic now > affects multiple Connect clusters instead of just one > * Complications with Exactly Once mode: transactional writes to internal > topics may cause unavailability in other clusters from hanging > transactions. > > Thanks! >

[DISCUSS] KIP-1173: Connect Storage Topics Sharing Across Clusters

Hi Kafka Community, I'd like to start a discussion on KIP-1173: Connect Storage Topics Sharing Across Clusters . The primary motivation for writing this KIP and proposing this enhancemen

[jira] [Created] (KAFKA-19211) Connect Storage Topics Sharing Across Clusters

Pritam Kumar created KAFKA-19211: Summary: Connect Storage Topics Sharing Across Clusters Key: KAFKA-19211 URL: https://issues.apache.org/jira/browse/KAFKA-19211 Project: Kafka Issue Type

Re: Re: [DISCUSS] KIP-1153: Extending support for Microsecond Precision for Kafka Connect

Thank you Sudesh, for reviewing the KIP and the valuable feedback. Thanks, Pritam On Thu, Apr 17, 2025 at 8:59 PM Sudesh Wasnik wrote: > Thanks Pritam! > No more feedback from my end. Nice addition ! > > Thanks, > Sudesh > On 17 Apr 2025 at 4:59 PM +0530, pritam kumar , &

Re: Re: [DISCUSS] KIP-1153: Extending support for Microsecond Precision for Kafka Connect

Hi Sudesh, Sorry for the earlier comment, I just checked that avro in 1.12 has timestamp-nanos support. I will update the KIP to have nanosecond support also and correspondingly I will make changes for nanosecond. Thanks Pritam. On Wed, Apr 16, 2025 at 7:13 PM pritam kumar wrote: > Also j

Re: Re: [DISCUSS] KIP-1153: Extending support for Microsecond Precision for Kafka Connect

I have made Nanosecond related changes in the KIP. Please have a look. Thanks Pritam. On Thu, Apr 17, 2025 at 4:25 PM pritam kumar wrote: > Hi Sudesh, > Sorry for the earlier comment, I just checked that avro in 1.12 has > timestamp-nanos support. I will update the KIP to have n

Re: Re: [DISCUSS] KIP-1153: Extending support for Microsecond Precision for Kafka Connect

Also just to add I did not add this in the first place as I think Avro itself does not have the Nanosecond logical type. On Wed, Apr 16, 2025 at 7:01 PM pritam kumar wrote: > Thanks Sudesh, for taking a look at this. I am already working on > extending this for nanosecond precision a

Re: Re: [DISCUSS] KIP-1153: Extending support for Microsecond Precision for Kafka Connect

he KIP to also add support for Nanosecond precision! > > Thanks > Sudesh > > On 2025/04/05 01:30:49 pritam kumar wrote: > > Hi Kafka Community, > > Sorry due to some changes I had to change the link to the kip. > > Here is the updated KIP link: > > > https

Coordinating Cross-Cluster Kafka Transactions with Exactly-Once Semantics

suggestions, or shared pain would be incredibly helpful! Thanks in advance, Pritam Kumar

Re: [DISCUSS] KIP-1153: Extending support for Microsecond Precision for Kafka Connect

Hi Kafka Community, Sorry due to some changes I had to change the link to the kip. Here is the updated KIP link: https://cwiki.apache.org/confluence/display/KAFKA/KIP-1154%3A+Extending+support+for+Microsecond+Precision+for+Kafka+Connect On Sat, Apr 5, 2025 at 12:14 AM pritam kumar wrote: >

[DISCUSS] KIP-1153: Extending support for Microsecond Precision for Kafka Connect

Hi Kafka Community, I’d like to start a discussion on KIP-1153: Extending Support for Microsecond Precision for Kafka Connect . The primary motivation behind this KIP is t

[jira] [Created] (KAFKA-19086) Extending support for Microsecond Precision for Kafka Connect

Pritam Kumar created KAFKA-19086: Summary: Extending support for Microsecond Precision for Kafka Connect Key: KAFKA-19086 URL: https://issues.apache.org/jira/browse/KAFKA-19086 Project: Kafka

[jira] [Created] (KAFKA-19070) Adding task number to the user provided client id (via consumer.override.client.id) to ensure each consumer has a unique client ID to avoid metric registration conflicts

Pritam Kumar created KAFKA-19070: Summary: Adding task number to the user provided client id (via consumer.override.client.id) to ensure each consumer has a unique client ID to avoid metric registration conflicts. Key: KAFKA

[jira] [Created] (KAFKA-17599) Update Consumer Subscription with Current Assignment Before Partition Revocation

Pritam Kumar created KAFKA-17599: Summary: Update Consumer Subscription with Current Assignment Before Partition Revocation Key: KAFKA-17599 URL: https://issues.apache.org/jira/browse/KAFKA-17599

[jira] [Created] (KAFKA-15680) Partition-Count is not getting updated Correctly in the Incremental Co-operative Rebalancing(ICR) Mode of Rebalancing

Pritam Kumar created KAFKA-15680: Summary: Partition-Count is not getting updated Correctly in the Incremental Co-operative Rebalancing(ICR) Mode of Rebalancing Key: KAFKA-15680 URL: https://issues.apache.org

[jira] [Resolved] (KAFKA-14220) "partition-count" not getting updated after revocation of partitions in case of Incremental Co-operative rebalancing.

[ https://issues.apache.org/jira/browse/KAFKA-14220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pritam Kumar resolved KAFKA-14220. -- Reviewer: (was: Chris Egerton) Resolution: Abandoned > "partition-count"

[jira] [Created] (KAFKA-14220) "partition-count" not getting updated after revocation of partitions in case of Incremental Co-operative rebalancing.

Pritam Kumar created KAFKA-14220: Summary: "partition-count" not getting updated after revocation of partitions in case of Incremental Co-operative rebalancing. Key: KAFKA-14220 URL: https://issues.