[VOTE] KIP-662: Throw Exception when Source Topics of a Streams App are Deleted

Hi, I would like to start the vote for https://cwiki.apache.org/confluence/display/KAFKA/KIP-662%3A+Throw+Exception+when+Source+Topics+of+a+Streams+App+are+Deleted Best, Bruno

Re: [DISCUSS] KIP-662: Throw Exception when Source Topics of a Streams App are Deleted

Hi Guozhang, Thank you for pointing this out. I added the package to the KIP. Best, Bruno On 24.08.20 20:55, Guozhang Wang wrote: Hello Bruno, Thanks for the KIP, it sounds good to me as well. Just a minor comment: we would include which package the new "MissingSourceTopicException" class

[jira] [Resolved] (KAFKA-10293) fix flaky streams/streams_eos_test.py

[ https://issues.apache.org/jira/browse/KAFKA-10293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-10293. --- Resolution: Fixed > fix flaky streams/streams_eos_test.py >

Re: [DISCUSS] KIP-405: Kafka Tiered Storage

Thanks everyone for attending the meeting today. Here is the recording https://drive.google.com/file/d/14PRM7U0OopOOrJR197VlqvRX5SXNtmKj/view?usp=sharing Notes: 1. KIP is updated with follower fetch protocol and ready to reviewed 2. Satish to capture schema of internal metadata topic in

[jira] [Created] (KAFKA-10431) ProducerPerformance with payloadFile arg: add support for sequential or random outputs

Zaahir Laher created KAFKA-10431: Summary: ProducerPerformance with payloadFile arg: add support for sequential or random outputs Key: KAFKA-10431 URL: https://issues.apache.org/jira/browse/KAFKA-10431

[jira] [Created] (KAFKA-10432) LeaderEpochCache is incorrectly recovered on segment recovery for epoch 0

Lucas Bradstreet created KAFKA-10432: Summary: LeaderEpochCache is incorrectly recovered on segment recovery for epoch 0 Key: KAFKA-10432 URL: https://issues.apache.org/jira/browse/KAFKA-10432

[jira] [Created] (KAFKA-10433) Reuse the ByteBuffer in validating compressed records

Chia-Ping Tsai created KAFKA-10433: -- Summary: Reuse the ByteBuffer in validating compressed records Key: KAFKA-10433 URL: https://issues.apache.org/jira/browse/KAFKA-10433 Project: Kafka

Re: [VOTE] KIP-662: Throw Exception when Source Topics of a Streams App are Deleted

+1. Thanks Bruno! Guozhang On Tue, Aug 25, 2020 at 4:00 AM Bruno Cadonna wrote: > Hi, > > I would like to start the vote for > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-662%3A+Throw+Exception+when+Source+Topics+of+a+Streams+App+are+Deleted > > Best, > Bruno > -- -- Guozhang

Re: [DISCUSS] KIP-647: Add ability to handle late messages in streams-aggregation

Hi Matthias, Bruno, Let me elaborate on my suggestions regarding late-tick handling. > why you rejected the more general solution involving a callback The main reasons why I tend to the topic approach is API-consistency and cleanness of the user code. The problem with a callback, in my opinion,

[GitHub] [kafka-site] vvcephei merged pull request #295: MINOR: fix for text wrapping in some tables in docs

vvcephei merged pull request #295: URL: https://github.com/apache/kafka-site/pull/295 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[jira] [Created] (KAFKA-10430) Hook support

Dennis Jaheruddin created KAFKA-10430: - Summary: Hook support Key: KAFKA-10430 URL: https://issues.apache.org/jira/browse/KAFKA-10430 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-10434) Remove deprecated methods on WindowStore

Jorge Esteban Quilcate Otoya created KAFKA-10434: Summary: Remove deprecated methods on WindowStore Key: KAFKA-10434 URL: https://issues.apache.org/jira/browse/KAFKA-10434 Project:

Re: [DISCUSS] KIP-405: Kafka Tiered Storage

Hi, Harsha, Thanks for the summary. Could you add the summary and the recording link to the last section of https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals ? Jun On Tue, Aug 25, 2020 at 11:12 AM Harsha Chintalapani wrote: > Thanks everyone for attending the

[jira] [Created] (KAFKA-10435) Fetch protocol changes for KIP-595

Jason Gustafson created KAFKA-10435: --- Summary: Fetch protocol changes for KIP-595 Key: KAFKA-10435 URL: https://issues.apache.org/jira/browse/KAFKA-10435 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-10436) Implement KIP-478 Topology changes

John Roesler created KAFKA-10436: Summary: Implement KIP-478 Topology changes Key: KAFKA-10436 URL: https://issues.apache.org/jira/browse/KAFKA-10436 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-10379) Implement the KIP-478 StreamBuilder#addGlobalStore()

[ https://issues.apache.org/jira/browse/KAFKA-10379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-10379. -- Resolution: Fixed > Implement the KIP-478 StreamBuilder#addGlobalStore() >

[jira] [Created] (KAFKA-10437) Convert test-utils (and StateStore) for KIP-478

John Roesler created KAFKA-10437: Summary: Convert test-utils (and StateStore) for KIP-478 Key: KAFKA-10437 URL: https://issues.apache.org/jira/browse/KAFKA-10437 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-9344) Logged consumer config does not always match actual config values

[ https://issues.apache.org/jira/browse/KAFKA-9344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx resolved KAFKA-9344. --- Resolution: Fixed > Logged consumer config does not always match actual config values >