[jira] [Created] (KAFKA-14241) Implement the snapshot cleanup policy

Jose Armando Garcia Sancio created KAFKA-14241: -- Summary: Implement the snapshot cleanup policy Key: KAFKA-14241 URL: https://issues.apache.org/jira/browse/KAFKA-14241 Project: Kafka

Re: KafkaConsumer refactor proposal

On Fri, Sep 16, 2022 at 3:01 PM Guozhang Wang wrote: > Hi Philip, > > On Fri, Sep 16, 2022 at 1:20 PM Philip Nee wrote: > > > Hi Guozhang, > > > > Thank you for the reviews, and I agree with your suggestions: If we find > > any behavior changes, we will issue a KIP. Is it possible to first >

Re: KafkaConsumer refactor proposal

Hi Philip, On Fri, Sep 16, 2022 at 1:20 PM Philip Nee wrote: > Hi Guozhang, > > Thank you for the reviews, and I agree with your suggestions: If we find > any behavior changes, we will issue a KIP. Is it possible to first publish > the new implementation in a separate class so that we don't

Re: KafkaConsumer refactor proposal

Hi Guozhang, Thank you for the reviews, and I agree with your suggestions: If we find any behavior changes, we will issue a KIP. Is it possible to first publish the new implementation in a separate class so that we don't disrupt the existing implementation? Then we can issue a KIP to address the

[jira] [Created] (KAFKA-14240) Ensure kraft metadata log dir is initialized with valid snapshot state

Jason Gustafson created KAFKA-14240: --- Summary: Ensure kraft metadata log dir is initialized with valid snapshot state Key: KAFKA-14240 URL: https://issues.apache.org/jira/browse/KAFKA-14240

Re: KafkaConsumer refactor proposal

Thank you, Kirk! Your feedback is very much appreciated; I'd like to try to address them in the email and the document. Here are my responses: 1. I removed that point because I think we should still try to maintain the current behavior to avoid regressions 2. I think I misworded it. I think

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.2 #85

See Changes: -- [...truncated 456323 lines...] [2022-09-16T18:21:25.252Z] [2022-09-16T18:21:25.252Z] org.apache.kafka.streams.integration.ResetPartitionTimeIntegrationTest >

[DISCUSS] KIP-869: Improve Streams State Restoration Visibility

Hello everyone, I'd like to start a discussion for the following KIP, aiming to improve Kafka Stream's restoration visibility via new metrics and callback methods: https://cwiki.apache.org/confluence/display/KAFKA/KIP-869%3A+Improve+Streams+State+Restoration+Visibility Thanks! -- Guozhang

[jira] [Created] (KAFKA-14239) Merge StateRestorationIntegrationTest into RestoreIntegrationTest

Guozhang Wang created KAFKA-14239: - Summary: Merge StateRestorationIntegrationTest into RestoreIntegrationTest Key: KAFKA-14239 URL: https://issues.apache.org/jira/browse/KAFKA-14239 Project: Kafka

Re: Request for contributor permissions

Hello Akshay, Thanks for your interest! You should have the permissions now. Guozhang On Fri, Sep 16, 2022 at 7:40 AM Akshay Bhadange wrote: > Hello sir/madam , > > I am really interested in this project and want to contribute.so please > provide me the contributor permission.my jira id is >

[jira] [Created] (KAFKA-14238) KRaft replicas can delete segments not included in a snapshot

Jose Armando Garcia Sancio created KAFKA-14238: -- Summary: KRaft replicas can delete segments not included in a snapshot Key: KAFKA-14238 URL: https://issues.apache.org/jira/browse/KAFKA-14238

[jira] [Created] (KAFKA-14237) Kafka TLS Doesn't Present Intermediary Certificates when using PEM

Ryan R created KAFKA-14237: -- Summary: Kafka TLS Doesn't Present Intermediary Certificates when using PEM Key: KAFKA-14237 URL: https://issues.apache.org/jira/browse/KAFKA-14237 Project: Kafka

Request for contributor permissions

Hello sir/madam , I am really interested in this project and want to contribute.so please provide me the contributor permission.my jira id is (akshaybhadange21).thanks for your help

Re: Re: [DISCUSS] KIP-710: Full support for distributed mode in dedicated MirrorMaker 2.0 clusters

Hi Chris, I went through the KIP and updated it based on our discussion. I think your suggestions simplified (and shortened) the KIP significantly. Thanks, Daniel Dániel Urbán ezt írta (időpont: 2022. szept. 16., P, 15:15): > Hi Chris, > > 1. For the REST-server-per-flow setup, it made sense

Re: Re: [DISCUSS] KIP-710: Full support for distributed mode in dedicated MirrorMaker 2.0 clusters

Hi Chris, 1. For the REST-server-per-flow setup, it made sense to introduce some simplified configuration. With a single REST server, it doesn't make sense anymore, I'm removing it from the KIP. 2. I think that changing the worker ID generation still makes sense, otherwise there is no way to

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

See Changes: -- [...truncated 421715 lines...] [2022-09-16T12:42:29.734Z] StreamsAssignmentScaleTest > testFallbackPriorTaskAssignorManyThreadsPerClient STARTED

Re: [VOTE] KIP-862: Self-join optimization for stream-stream joins

Hi Vicky, Thanks for the KIP! I think the KIP looks good! You described how the self-join is optimized when the names of the state stores are automatically generated by Streams. I think for completeness you should also mention what happens when users explicitly name the state stores of the

[jira] [Created] (KAFKA-14236) ListGroups request produces too much Denied logs in authorizer

Alexandre GRIFFAUT created KAFKA-14236: -- Summary: ListGroups request produces too much Denied logs in authorizer Key: KAFKA-14236 URL: https://issues.apache.org/jira/browse/KAFKA-14236 Project:

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

See Changes: -- [...truncated 424103 lines...] [2022-09-16T09:52:32.698Z] StreamsAssignmentScaleTest > testStickyTaskAssignorManyStandbys STARTED