[jira] [Created] (KAFKA-18196) Reuse window store for stream-stream self-join

A. Sophie Blee-Goldman created KAFKA-18196: -- Summary: Reuse window store for stream-stream self-join Key: KAFKA-18196 URL: https://issues.apache.org/jira/browse/KAFKA-18196 Project: Kafka

[jira] [Created] (KAFKA-18195) Enter "incompatible" instead of leaving incompatible entires blank in Kafka Streams broker compatibility matrix

A. Sophie Blee-Goldman created KAFKA-18195: -- Summary: Enter "incompatible" instead of leaving incompatible entires blank in Kafka Streams broker compatibility matrix Key: KAFKA-18195 URL: https://issues.

Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #143

See

[jira] [Resolved] (KAFKA-18192) generator module should run under java 11

[ https://issues.apache.org/jira/browse/KAFKA-18192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-18192. Fix Version/s: 4.0.0 Resolution: Fixed > generator module should run under java 11

[jira] [Created] (KAFKA-18194) Flaky test_broker_rolling_bounce due to frequent rebootstrapping

Philip Nee created KAFKA-18194: -- Summary: Flaky test_broker_rolling_bounce due to frequent rebootstrapping Key: KAFKA-18194 URL: https://issues.apache.org/jira/browse/KAFKA-18194 Project: Kafka

[jira] [Resolved] (KAFKA-18184) Remove the unnecessary project path check from build.gradle

[ https://issues.apache.org/jira/browse/KAFKA-18184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-18184. Fix Version/s: 4.0.0 Resolution: Fixed > Remove the unnecessary project path check

Re: [DISCUSS] KIP-1109: Unifying Kafka Consumer Topic Metrics

hi Apoorv, Let's use the following example to explain my point. in 4.0 *Topic Name: topic.a.b* - *Deprecated Metric Added:* A deprecated metric with the tag topic_a_b has been added. - *New Metric Added:* A new metric with the tag topic.a.b has been introduced. Users should monitor t

Re: [DISCUSS] Apache Kafka 4.0.0 release

Hi Ismael and all, Question: While browsing the KIPs, I found we missed KIP-724 in the kafka v4.0 plan. Based on the KIP, we should drop support for message formats v0 and v1 in v4.0. Is this

[jira] [Resolved] (KAFKA-18030) Remove old upgrade-system-tests modules

[ https://issues.apache.org/jira/browse/KAFKA-18030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-18030. Fix Version/s: 4.0.0 Resolution: Fixed > Remove old upgrade-system-tests modules >

Re: [VOTE]: KIP-1071: Streams Rebalance Protocol

+1 (binding) Thank you guys for the deep discussion and for carefully considering all the details of this new protocol. Looking forward to seeing the KIP in action! -Sophie On Fri, Dec 6, 2024 at 5:52 AM Andrew Schofield < andrew_schofield_j...@outlook.com> wrote: > Hi Bruno and Lucas, > Thanks

[jira] [Resolved] (KAFKA-18067) Kafka Streams can leak Producer client under EOS

[ https://issues.apache.org/jira/browse/KAFKA-18067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-18067. Resolution: Fixed > Kafka Streams can leak Producer client under EOS > ---

Re: [DISCUSS] KIP-1109: Unifying Kafka Consumer Topic Metrics

Hi, Apoorv, I thought Chia's suggestion is to emit the metric under both the topic name with and without dot replacement. Thanks, Jun On Wed, Nov 27, 2024 at 3:06 PM Apoorv Mittal wrote: > Thanks Jun and Chia for review and feedback. > > Initially I thought this might be a breaking change for

[jira] [Created] (KAFKA-18193) Kafka Streams `CloseOptions` should not have a public constructor

Matthias J. Sax created KAFKA-18193: --- Summary: Kafka Streams `CloseOptions` should not have a public constructor Key: KAFKA-18193 URL: https://issues.apache.org/jira/browse/KAFKA-18193 Project: Kafk

[jira] [Created] (KAFKA-18192) generator module should run under java 11

Chia-Ping Tsai created KAFKA-18192: -- Summary: generator module should run under java 11 Key: KAFKA-18192 URL: https://issues.apache.org/jira/browse/KAFKA-18192 Project: Kafka Issue Type: Sub

[jira] [Resolved] (KAFKA-15284) Implement GroupProtocolResolver to dynamically determine consumer group protocol

[ https://issues.apache.org/jira/browse/KAFKA-15284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True resolved KAFKA-15284. --- Resolution: Won't Fix > Implement GroupProtocolResolver to dynamically determine consumer group > p

[jira] [Created] (KAFKA-18191) StreamJoined name is not used for processor names

A. Sophie Blee-Goldman created KAFKA-18191: -- Summary: StreamJoined name is not used for processor names Key: KAFKA-18191 URL: https://issues.apache.org/jira/browse/KAFKA-18191 Project: Kafka

RE: Re: [VOTE]: KIP-1071: Streams Rebalance Protocol

+1 (non-binding) Thank you for this excellent work! Colt McNealy *Founder and Managing Member* www.littlehorse.dev On 2024/12/06 13:51:34 Andrew Schofield wrote: > Hi Bruno and Lucas, > Thanks for proposing this excellent KIP. > > +1 (binding) > > Thanks, > Andrew > _

[jira] [Resolved] (KAFKA-18164) Empty in memory acknowledgements when a shareAcknowledge request fails

[ https://issues.apache.org/jira/browse/KAFKA-18164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield resolved KAFKA-18164. -- Resolution: Fixed > Empty in memory acknowledgements when a shareAcknowledge request f

[jira] [Resolved] (KAFKA-18165) Update nodesWithPendingRequests only when a request successfully builds

[ https://issues.apache.org/jira/browse/KAFKA-18165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield resolved KAFKA-18165. -- Resolution: Fixed > Update nodesWithPendingRequests only when a request successfully b

[jira] [Created] (KAFKA-18190) TopologyTestDriver time is not synchronized with test topics

A. Sophie Blee-Goldman created KAFKA-18190: -- Summary: TopologyTestDriver time is not synchronized with test topics Key: KAFKA-18190 URL: https://issues.apache.org/jira/browse/KAFKA-18190 Proj

[jira] [Resolved] (KAFKA-18122) Add ShareConsumeBenchWorker for running trogdor workloads.

[ https://issues.apache.org/jira/browse/KAFKA-18122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield resolved KAFKA-18122. -- Fix Version/s: 4.0.0 Resolution: Fixed > Add ShareConsumeBenchWorker for runnin

Re: [DISCUSS] Apache Kafka 4.0.0 release

Hey David and folks, I wanted to discuss the possibility of merging in KIP-996 (PreVote) in two phases in order to make the 4.0 release. Part 1 (Vote RPC includes PreVote field) by feature freeze Part 2 (new in

[jira] [Resolved] (KAFKA-18106) Brokers should be removed from the ISR if possible on unclean restart

[ https://issues.apache.org/jira/browse/KAFKA-18106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin McCabe resolved KAFKA-18106. -- Resolution: Fixed > Brokers should be removed from the ISR if possible on unclean restart > --

[jira] [Created] (KAFKA-18189) CoordinatorRequestManager log of time disconnected from coordinator is incorrect

Kirk True created KAFKA-18189: - Summary: CoordinatorRequestManager log of time disconnected from coordinator is incorrect Key: KAFKA-18189 URL: https://issues.apache.org/jira/browse/KAFKA-18189 Project: K

[jira] [Resolved] (KAFKA-16018) KafkaStreams can go into a zombie state if UncaughtExceptionHandler is specified via the deprecated method

[ https://issues.apache.org/jira/browse/KAFKA-16018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-16018. - Resolution: Won't Do Kafka 4.0 is around the corner. Closing this. > KafkaStreams can g

[jira] [Resolved] (KAFKA-14619) KRaft validate snapshot id are at batch boundries

[ https://issues.apache.org/jira/browse/KAFKA-14619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Wu resolved KAFKA-14619. -- Resolution: Fixed > KRaft validate snapshot id are at batch boundries > --

[jira] [Resolved] (KAFKA-17696) New consumer background operations unaware of metadata errors

[ https://issues.apache.org/jira/browse/KAFKA-17696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lianet Magrans resolved KAFKA-17696. Resolution: Fixed > New consumer background operations unaware of metadata errors > --

[jira] [Created] (KAFKA-18188) Admin LeaveGroup should allow removing member by member id

David Jacot created KAFKA-18188: --- Summary: Admin LeaveGroup should allow removing member by member id Key: KAFKA-18188 URL: https://issues.apache.org/jira/browse/KAFKA-18188 Project: Kafka Issu

Permissions to contribute to Apache Kafka

wiki ID: Jhen-Yung Hsu Jira ID: Jhen-Yung Hsu Thanks, Yung

Re: [VOTE] KIP-1034: Dead letter queue in Kafka Streams

Hello, I have some concerns about the naming: 1. continue() is not feasible because continue is a reserved keyword. Therefore, I suggest using the following names: * continueProcessing * failProcessing * retryProcessing 2. ProductionExceptionHandlerResponse() is already us

[jira] [Resolved] (KAFKA-18134) Reject the upgrade if the member assignment has non empty userData

[ https://issues.apache.org/jira/browse/KAFKA-18134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-18134. - Assignee: Sean Quah (was: Dongnuo Lyu) Resolution: Fixed > Reject the upgrade if the memb

Re: [VOTE] KIP-1098: Reverse Checkpointing in MirrorMaker

Gentle bump - please consider checking the KIP and voting. Daniel Dániel Urbán ezt írta (időpont: 2024. dec. 5., Cs, 12:08): > Bumping this vote - the change has a relatively small footprint, but fills > a sizable gap in MM2. > Please consider checking the KIP and chiming in. > TIA > Daniel > >