[jira] [Created] (KAFKA-12994) Migrate all Tests to New API and Remove Suppression for Deprecation Warnings related to KIP-633

Israel Ekpo created KAFKA-12994: --- Summary: Migrate all Tests to New API and Remove Suppression for Deprecation Warnings related to KIP-633 Key: KAFKA-12994 URL: https://issues.apache.org/jira/browse/KAFKA-12994

[jira] [Created] (KAFKA-12993) Formatting of Streams 'Memory Management' docs is messed up

A. Sophie Blee-Goldman created KAFKA-12993: -- Summary: Formatting of Streams 'Memory Management' docs is messed up Key: KAFKA-12993 URL: https://issues.apache.org/jira/browse/KAFKA-12993 Proj

[jira] [Created] (KAFKA-12992) Make kraft configuration properties public

Jose Armando Garcia Sancio created KAFKA-12992: -- Summary: Make kraft configuration properties public Key: KAFKA-12992 URL: https://issues.apache.org/jira/browse/KAFKA-12992 Project: Kafka

Re: [DISCUSS] KIP-655: Windowed "Distinct" Operation for KStream

Ivan, I read through the discussion and your new proposal. I have a couple of questions. 1. As we have cancelRepartition, wouldn't selectKey be sufficient. You still have idExtractor. Maybe I misunderstood the discussion. 2. isPersistent should be replaced by Materialized. It looked like you agre

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

See

[DISCUSS] KIP-759: Unneeded repartition canceling

Hello, I'd like to start a discussion for KIP-759: https://cwiki.apache.org/confluence/display/KAFKA/KIP-759%3A+Unneeded+repartition+canceling This is an offshoot of the discussion of KIP-655 for a `distinct` operator, which turned out to be a separate proposal. The proposal is quite trivia

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 2.8 #39

See

Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #251

See

[jira] [Resolved] (KAFKA-12967) DescribeQuorum API should be forwarded from brokers

[ https://issues.apache.org/jira/browse/KAFKA-12967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-12967. - Resolution: Fixed > DescribeQuorum API should be forwarded from brokers > --

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 2.8 #38

See

Re: [VOTE] KIP-690: Add additional configuration to control MirrorMaker 2 internal topics naming convention

+1 (binding) Thanks for the KIP! On Tue, May 4, 2021 at 3:23 PM Igor Soarez wrote: > > Another +1 here, also non-binding. > > Thank you Omnia! > > -- > Igor > > > On Fri, Apr 30, 2021, at 3:15 PM, Ryanne Dolan wrote: > > +1 (non-binding), thanks! > > > > On Thu, Jan 21, 2021, 4:31 AM Omnia Ibrahi

Re: [DISCUSS] KIP-690 Add additional configuration to control MirrorMaker 2 internal topics naming convention

Hi Omnia, I think the current proposal makes sense. Thanks for driving this feature. On Mon, Jun 21, 2021 at 11:51 PM Ryanne Dolan wrote: > > Omnia, I agree with you that allowing users to specify the whole topic name > via configuration is likely to create problems. MM2 must distinguish betwee

Re: [VOTE] KIP-699: Update FindCoordinator to resolve multiple Coordinators at a time

Hi, Quick update: To handle reverting to the old behaviour with older brokers, I've introduced a new exception, NoBatchedFindCoordinatorsException. I've updated the KIP accordingly. For more details, see the discussion in the pull request: https://github.com/apache/kafka/pull/10743 Thanks On Tue

[jira] [Resolved] (KAFKA-12336) custom stream naming does not work while calling stream[K, V](topicPattern: Pattern) API with named Consumed parameter

[ https://issues.apache.org/jira/browse/KAFKA-12336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-12336. - Resolution: Fixed > custom stream naming does not work while calling stream[K, V](topicPattern:

[jira] [Resolved] (KAFKA-12991) Fix unsafe access to `AbstractCoordinator.state`

[ https://issues.apache.org/jira/browse/KAFKA-12991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-12991. - Fix Version/s: 2.8.1 3.0.0 Reviewer: A. Sophie Blee-Goldman Re

[jira] [Created] (KAFKA-12991) Fix unsafe access to `AbstractCoordinator.state`

David Jacot created KAFKA-12991: --- Summary: Fix unsafe access to `AbstractCoordinator.state` Key: KAFKA-12991 URL: https://issues.apache.org/jira/browse/KAFKA-12991 Project: Kafka Issue Type: Bu

Re: [DISCUSS] KIP-655: Windowed "Distinct" Operation for KStream

Hello all, I have rewritten the KIP-655 summarizing what was agreed upon during this discussion (now the proposal is much simpler and less invasive). I have also created KIP-759 (cancelRepartition operation) and started a discussion for it. Regards, Ivan. 04.06.2021 8:15, Matthias J. Sa

[jira] [Created] (KAFKA-12990) Infinite Loop in producing event to kafka

Piotr Rybarczyk created KAFKA-12990: --- Summary: Infinite Loop in producing event to kafka Key: KAFKA-12990 URL: https://issues.apache.org/jira/browse/KAFKA-12990 Project: Kafka Issue Type: B

[jira] [Created] (KAFKA-12989) `MockClient` should respect the request matcher passed to `prepareUnsupportedVersionResponse`

David Jacot created KAFKA-12989: --- Summary: `MockClient` should respect the request matcher passed to `prepareUnsupportedVersionResponse` Key: KAFKA-12989 URL: https://issues.apache.org/jira/browse/KAFKA-12989

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 2.8 #37

See

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

See Changes: -- [...truncated 542412 lines...] [2021-06-24T09:58:23.458Z] TopicCommandIntegrationTest > testDeleteWhenTopicDoesntExist() STARTED [2021-06-24T09:58:24.725Z]

[jira] [Resolved] (KAFKA-12898) Owned partitions in the subscription must be sorted

[ https://issues.apache.org/jira/browse/KAFKA-12898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-12898. - Fix Version/s: 2.8.1 Reviewer: A. Sophie Blee-Goldman Resolution: Fixed > Owned

[jira] [Created] (KAFKA-12988) RLMM add/updateRemoteLogSegmentMetadata and putRemotePartitionDeleteMetadata to be changed with asynchronous APIs.

Satish Duggana created KAFKA-12988: -- Summary: RLMM add/updateRemoteLogSegmentMetadata and putRemotePartitionDeleteMetadata to be changed with asynchronous APIs. Key: KAFKA-12988 URL: https://issues.apache.org/jir