Re: [DISCUSS] KIP-1158: Improve Connect SourceTask commit()

Hello Chris ! Thanks for the quick review ! Good point, task.commit() (existing and proposed) should fail the task on exception. Currently, if a connector implements task.commit()

[jira] [Created] (KAFKA-19122) updateClusterMetadata receives duplicate PartitionInfo

Chia-Ping Tsai created KAFKA-19122: -- Summary: updateClusterMetadata receives duplicate PartitionInfo Key: KAFKA-19122 URL: https://issues.apache.org/jira/browse/KAFKA-19122 Project: Kafka Is

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.9 #183

See

[jira] [Resolved] (KAFKA-19114) Backport KAFKA-18991 to 4.0 and 3.9

[ https://issues.apache.org/jira/browse/KAFKA-19114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] José Armando García Sancio resolved KAFKA-19114. Resolution: Fixed > Backport KAFKA-18991 to 4.0 and 3.9 >

RE: Re: [DISCUSS] KIP-1146: Anchored wall-clock punctuation

Thank you for your inputs! #1, I agree and I have changed the `startTime` parameter to be of type `Instant`. #2, I have added a section for the unintuitive cases and semantics that you and Sophie have mentioned. In short, I’m proposing to skip forward to the next trigger time. #3, It was a ty

[jira] [Reopened] (KAFKA-18287) Add support for kafka-streams-groups.sh --list

[ https://issues.apache.org/jira/browse/KAFKA-18287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reopened KAFKA-18287: --- > Add support for kafka-streams-groups.sh --list > -

[jira] [Created] (KAFKA-19118) Enable KIP-1071 in existing streams integration tests

Lucas Brutschy created KAFKA-19118: -- Summary: Enable KIP-1071 in existing streams integration tests Key: KAFKA-19118 URL: https://issues.apache.org/jira/browse/KAFKA-19118 Project: Kafka Iss

[jira] [Resolved] (KAFKA-18287) Add support for kafka-streams-groups.sh --list

[ https://issues.apache.org/jira/browse/KAFKA-18287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-18287. --- Resolution: Fixed > Add support for kafka-streams-groups.sh --list > ---

[jira] [Created] (KAFKA-19116) Deletion of share group offsets does not reset the position as expected

Andrew Schofield created KAFKA-19116: Summary: Deletion of share group offsets does not reset the position as expected Key: KAFKA-19116 URL: https://issues.apache.org/jira/browse/KAFKA-19116 Proje

[jira] [Created] (KAFKA-19120) Consider whether we could subscribe using topic ids instead of names

David Jacot created KAFKA-19120: --- Summary: Consider whether we could subscribe using topic ids instead of names Key: KAFKA-19120 URL: https://issues.apache.org/jira/browse/KAFKA-19120 Project: Kafka

Re: [DISCUSS] KIP-1131: Controller-side monitoring for broker shutdown and startup

Thanks for the improvement Kevin. I got a chance to look at the KIP. 1. kafka.controller:type=KafkaController,name=BrokerRegistrationState.kafka-X Can we use tags or attributes instead of different names? For example, how about kafka.controller:type=KafkaController,name=BrokerRegistrationState,

Re: [DISCUSS] Apache Kafka 3.9.1 release

Hi all, As discussed, today is the code freeze date for v3.9.1. I should start to prepare for the RC build this Friday. Please let me know if you have any concerns. Thanks. Luke On Tue, Apr 1, 2025 at 5:43 PM Edoardo Comar wrote: > Hi I'd like this fix to make it in 3.9.1 > https://github.com

Re: [DISCUSS] KIP-1157: Enforce KafkaPrincipalSerde Implementation for KafkaPrincipalBuilder

Hi, Thank you for your comment. I have updated the KIP to address your feedback. Please review it at your convenience. Thanks, Wang 黃竣陽 於 2025年4月8日 週二 下午10:00寫道： > Hi Johnny, > > Thanks for this KIP. > > ken_0: > > Doesn't this change break backward compatibility? If a user has only > imple

[jira] [Resolved] (KAFKA-18984) failed to reset interval.ms by using kafka-client-metrics.sh

[ https://issues.apache.org/jira/browse/KAFKA-18984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-18984. --- Resolution: Fixed > failed to reset interval.ms by using kafka-client-metrics.sh > -

[jira] [Created] (KAFKA-19117) Client Throttling Log messages should be of log level - WARN

Ravi Kalasapur created KAFKA-19117: -- Summary: Client Throttling Log messages should be of log level - WARN Key: KAFKA-19117 URL: https://issues.apache.org/jira/browse/KAFKA-19117 Project: Kafka

Re: [DISCUSS] KIP-1101: Trigger rebalance on rack topology changes

Hi PoAn, LB01: please add the removal of StreamsGroupPartitionMetadataKey / StreamsGroupPartitionMetadataValue to the KIP. Since these were not yet included in 4.0, we can just remove them as long as this KIP hits 4.1. I can help with the integration into the `streamsGroupHeartbeat`, as it will be

[jira] [Resolved] (KAFKA-19090) Move DelayedFuture and DelayedFuturePurgatory to server module

[ https://issues.apache.org/jira/browse/KAFKA-19090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-19090. Fix Version/s: 4.1.0 Resolution: Fixed > Move DelayedFuture and DelayedFuturePurgat

[jira] [Resolved] (KAFKA-8628) Auto-generated Kafka RPC code should be able to use zero-copy ByteBuffers

[ https://issues.apache.org/jira/browse/KAFKA-8628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-8628. --- Resolution: Duplicate > Auto-generated Kafka RPC code should be able to use zero-copy ByteBuf

[jira] [Created] (KAFKA-19115) Utilize initiazed topics info to verify delete share group offsets

Sushant Mahajan created KAFKA-19115: --- Summary: Utilize initiazed topics info to verify delete share group offsets Key: KAFKA-19115 URL: https://issues.apache.org/jira/browse/KAFKA-19115 Project: Kaf