[jira] [Commented] (KAFKA-7509) Kafka Connect logs unnecessary warnings about unused configurations

[ https://issues.apache.org/jira/browse/KAFKA-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516979#comment-17516979 ] Matthias J. Sax commented on KAFKA-7509: Thanks for following up. – I briefly took a look. My

[jira] [Commented] (KAFKA-13787) Failed to delete state store directory for it is not empty

[ https://issues.apache.org/jira/browse/KAFKA-13787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516068#comment-17516068 ] Matthias J. Sax commented on KAFKA-13787: - `StateDirectory` should have all relevant code. Not

[jira] [Commented] (KAFKA-13787) Failed to delete state store directory for it is not empty

[ https://issues.apache.org/jira/browse/KAFKA-13787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515648#comment-17515648 ] Matthias J. Sax commented on KAFKA-13787: - What file system are you using? > Failed to delete

[jira] [Updated] (KAFKA-13785) Support emit final result for windowed aggregation

[ https://issues.apache.org/jira/browse/KAFKA-13785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13785: Labels: kip (was: ) > Support emit final result for windowed aggregation >

[jira] [Updated] (KAFKA-13785) Support emit final result for windowed aggregation

[ https://issues.apache.org/jira/browse/KAFKA-13785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13785: Component/s: streams > Support emit final result for windowed aggregation >

[jira] [Comment Edited] (KAFKA-4609) KTable/KTable join followed by groupBy and aggregate/count can result in duplicated results

[ https://issues.apache.org/jira/browse/KAFKA-4609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16959455#comment-16959455 ] Matthias J. Sax edited comment on KAFKA-4609 at 3/25/22, 5:31 PM: -- As

[jira] [Commented] (KAFKA-13542) Utilize the new Consumer#enforceRebalance(reason) API in Streams

[ https://issues.apache.org/jira/browse/KAFKA-13542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17512018#comment-17512018 ] Matthias J. Sax commented on KAFKA-13542: - SGTM. > Utilize the new

[jira] [Commented] (KAFKA-13542) Utilize the new Consumer#enforceRebalance(reason) API in Streams

[ https://issues.apache.org/jira/browse/KAFKA-13542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511537#comment-17511537 ] Matthias J. Sax commented on KAFKA-13542: - Curious: did we figure out why the patch resulted in

[jira] [Commented] (KAFKA-7509) Kafka Connect logs unnecessary warnings about unused configurations

[ https://issues.apache.org/jira/browse/KAFKA-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17510997#comment-17510997 ] Matthias J. Sax commented on KAFKA-7509: Thanks for the detailed explanation. I don't know

[jira] [Commented] (KAFKA-13739) Sliding window without grace not working

[ https://issues.apache.org/jira/browse/KAFKA-13739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17510043#comment-17510043 ] Matthias J. Sax commented on KAFKA-13739: - Thank you! – Let us know if you need any help. >

[jira] [Commented] (KAFKA-7509) Kafka Connect logs unnecessary warnings about unused configurations

[ https://issues.apache.org/jira/browse/KAFKA-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509095#comment-17509095 ] Matthias J. Sax commented on KAFKA-7509: {quote} # Breaking backwards compatibility for a lot of

[jira] [Commented] (KAFKA-7509) Kafka Connect logs unnecessary warnings about unused configurations

[ https://issues.apache.org/jira/browse/KAFKA-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17507833#comment-17507833 ] Matthias J. Sax commented on KAFKA-7509: Personally, I think the best way would be to tackle this

[jira] [Updated] (KAFKA-13739) Sliding window without grace not working

[ https://issues.apache.org/jira/browse/KAFKA-13739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13739: Labels: beginner newbie (was: ) > Sliding window without grace not working >

[jira] [Commented] (KAFKA-13739) Sliding window without grace not working

[ https://issues.apache.org/jira/browse/KAFKA-13739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17507825#comment-17507825 ] Matthias J. Sax commented on KAFKA-13739: - Thanks for chiming in [~lct45] \ {quote}_if_ we want

[jira] [Updated] (KAFKA-13739) Sliding window without grace not working

[ https://issues.apache.org/jira/browse/KAFKA-13739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13739: Priority: Minor (was: Major) > Sliding window without grace not working >

[jira] [Commented] (KAFKA-13739) Sliding window without grace not working

[ https://issues.apache.org/jira/browse/KAFKA-13739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17507261#comment-17507261 ] Matthias J. Sax commented on KAFKA-13739: - Thanks for reporting this. Good catch. I think you

[jira] [Updated] (KAFKA-13699) ProcessorContext does not expose Stream Time

[ https://issues.apache.org/jira/browse/KAFKA-13699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13699: Affects Version/s: 3.0.0 (was: 2.7.0) > ProcessorContext does

[jira] [Assigned] (KAFKA-13699) ProcessorContext does not expose Stream Time

[ https://issues.apache.org/jira/browse/KAFKA-13699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-13699: --- Assignee: Matthias J. Sax > ProcessorContext does not expose Stream Time >

[jira] [Assigned] (KAFKA-13721) Left-join still emit spurious results in stream-stream joins in some cases

[ https://issues.apache.org/jira/browse/KAFKA-13721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-13721: --- Assignee: Matthias J. Sax > Left-join still emit spurious results in stream-stream

[jira] [Updated] (KAFKA-13722) Update internal interfaces that use ProcessorContext to use StateStoreContext instead

[ https://issues.apache.org/jira/browse/KAFKA-13722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13722: Component/s: streams > Update internal interfaces that use ProcessorContext to use

[jira] [Assigned] (KAFKA-8065) Forwarding modified timestamps does not reset timestamp correctly

[ https://issues.apache.org/jira/browse/KAFKA-8065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8065: -- Assignee: Matthias J. Sax > Forwarding modified timestamps does not reset timestamp

[jira] [Commented] (KAFKA-13683) Transactional Producer - Transaction with key xyz went wrong with exception: Timeout expired after 60000milliseconds while awaiting InitProducerId

[ https://issues.apache.org/jira/browse/KAFKA-13683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503218#comment-17503218 ] Matthias J. Sax commented on KAFKA-13683: - {quote}We are using kakfa streams 3.0. {quote} Should

[jira] [Commented] (KAFKA-13699) ProcessorContext does not expose Stream Time

[ https://issues.apache.org/jira/browse/KAFKA-13699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503214#comment-17503214 ] Matthias J. Sax commented on KAFKA-13699: - Seems the only question is, if we need to update the

[jira] [Updated] (KAFKA-13699) ProcessorContext does not expose Stream Time

[ https://issues.apache.org/jira/browse/KAFKA-13699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13699: Labels: newbie (was: ) > ProcessorContext does not expose Stream Time >

[jira] [Commented] (KAFKA-6035) Avoid creating changelog topics for state stores that are directly piped to a sink topic

[ https://issues.apache.org/jira/browse/KAFKA-6035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503213#comment-17503213 ] Matthias J. Sax commented on KAFKA-6035: Even if this ticket is finished, if you call

[jira] [Commented] (KAFKA-13678) 2nd punctuation using STREAM_TIME does not respect scheduled interval

[ https://issues.apache.org/jira/browse/KAFKA-13678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499753#comment-17499753 ] Matthias J. Sax commented on KAFKA-13678: - We have a different use case in mind: punctuation are

[jira] [Commented] (KAFKA-13699) ProcessorContext does not expose Stream Time

[ https://issues.apache.org/jira/browse/KAFKA-13699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499691#comment-17499691 ] Matthias J. Sax commented on KAFKA-13699: - That's my understanding, too. Seems we missed to add

[jira] [Commented] (KAFKA-13678) 2nd punctuation using STREAM_TIME does not respect scheduled interval

[ https://issues.apache.org/jira/browse/KAFKA-13678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497935#comment-17497935 ] Matthias J. Sax commented on KAFKA-13678: - We believe it's important for the data re-processing

[jira] [Commented] (KAFKA-4212) Add a key-value store that is a TTL persistent cache

[ https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497934#comment-17497934 ] Matthias J. Sax commented on KAFKA-4212: A windowed-store is basically just a `` kv-store and it

[jira] [Commented] (KAFKA-10635) Streams application fails with OutOfOrderSequenceException after rolling restarts of brokers

[ https://issues.apache.org/jira/browse/KAFKA-10635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497214#comment-17497214 ] Matthias J. Sax commented on KAFKA-10635: - Is this fixed via

[jira] [Commented] (KAFKA-12446) Define KGroupedTable#aggregate subtractor + adder order of execution

[ https://issues.apache.org/jira/browse/KAFKA-12446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497210#comment-17497210 ] Matthias J. Sax commented on KAFKA-12446: - Just discovering the ticket. – I don't think it makes

[jira] [Resolved] (KAFKA-12640) AbstractCoordinator ignores backoff timeout when joining the consumer group

[ https://issues.apache.org/jira/browse/KAFKA-12640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-12640. - Resolution: Duplicate > AbstractCoordinator ignores backoff timeout when joining the

[jira] [Commented] (KAFKA-13501) Avoid state restore via rebalance if standbys are enabled

[ https://issues.apache.org/jira/browse/KAFKA-13501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497201#comment-17497201 ] Matthias J. Sax commented on KAFKA-13501: - There is also

[jira] [Commented] (KAFKA-13501) Avoid state restore via rebalance if standbys are enabled

[ https://issues.apache.org/jira/browse/KAFKA-13501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497196#comment-17497196 ] Matthias J. Sax commented on KAFKA-13501: - I just discovered

[jira] [Updated] (KAFKA-13685) Seems to get empty event time in some messages.

[ https://issues.apache.org/jira/browse/KAFKA-13685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13685: Component/s: streams (was: consumer) (was:

[jira] [Updated] (KAFKA-13678) 2nd punctuation using STREAM_TIME does not respect scheduled interval

[ https://issues.apache.org/jira/browse/KAFKA-13678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13678: Issue Type: Improvement (was: Bug) > 2nd punctuation using STREAM_TIME does not respect

[jira] [Commented] (KAFKA-13678) 2nd punctuation using STREAM_TIME does not respect scheduled interval

[ https://issues.apache.org/jira/browse/KAFKA-13678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497056#comment-17497056 ] Matthias J. Sax commented on KAFKA-13678: - What [~guozhang] says is right – we align stream-time

[jira] [Updated] (KAFKA-13677) version 3.0.0 Processor implementation uses parameter record (restricted identifier)

[ https://issues.apache.org/jira/browse/KAFKA-13677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13677: Component/s: streams (was: clients) > version 3.0.0 Processor

[jira] [Comment Edited] (KAFKA-13655) Cannot edit clients page

[ https://issues.apache.org/jira/browse/KAFKA-13655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17492280#comment-17492280 ] Matthias J. Sax edited comment on KAFKA-13655 at 2/15/22, 12:23 AM:

[jira] [Commented] (KAFKA-13655) Cannot edit clients page

[ https://issues.apache.org/jira/browse/KAFKA-13655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17492280#comment-17492280 ] Matthias J. Sax commented on KAFKA-13655: - Missed you message from a week ago – sorry about

[jira] [Commented] (KAFKA-6647) KafkaStreams.cleanUp creates .lock file in directory its trying to clean (Windows OS)

[ https://issues.apache.org/jira/browse/KAFKA-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17491093#comment-17491093 ] Matthias J. Sax commented on KAFKA-6647: Not sure if I can follow the details – it might be best

[jira] [Assigned] (KAFKA-13229) KIP-761: implement a total blocked time metric in Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-13229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-13229: --- Assignee: Rohan Desai > KIP-761: implement a total blocked time metric in Kafka

[jira] [Commented] (KAFKA-13641) Kafka Streams Scala: Add `Option` to `ValueJoiner` parameters

[ https://issues.apache.org/jira/browse/KAFKA-13641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489966#comment-17489966 ] Matthias J. Sax commented on KAFKA-13641: - {quote}Hope I didn't come across as rude or imply

[jira] [Commented] (KAFKA-13289) Bulk processing correctly ordered input data through a join with kafka-streams results in `Skipping record for expired segment`

[ https://issues.apache.org/jira/browse/KAFKA-13289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489962#comment-17489962 ] Matthias J. Sax commented on KAFKA-13289: - Great news! Thanks for sharing. Happy you got your

[jira] [Comment Edited] (KAFKA-13655) Cannot edit clients page

[ https://issues.apache.org/jira/browse/KAFKA-13655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489958#comment-17489958 ] Matthias J. Sax edited comment on KAFKA-13655 at 2/10/22, 5:05 AM: ---

[jira] [Resolved] (KAFKA-13655) Cannot edit clients page

[ https://issues.apache.org/jira/browse/KAFKA-13655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-13655. - Resolution: Not A Bug > Cannot edit clients page > > >

[jira] [Commented] (KAFKA-13655) Cannot edit clients page

[ https://issues.apache.org/jira/browse/KAFKA-13655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489958#comment-17489958 ] Matthias J. Sax commented on KAFKA-13655: - Did you create an account (note the Jira and wiki are

[jira] [Resolved] (KAFKA-13400) offset() is not supported in standby tasks.

[ https://issues.apache.org/jira/browse/KAFKA-13400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-13400. - Resolution: Not A Bug Based on the information provided, the conclusion seems to be

[jira] [Updated] (KAFKA-13492) IQ Parity: queries for key/value store range and scan

[ https://issues.apache.org/jira/browse/KAFKA-13492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13492: Fix Version/s: 3.2.0 > IQ Parity: queries for key/value store range and scan >

[jira] [Updated] (KAFKA-8410) Strengthen the types of Processors, at least in the DSL, maybe in the PAPI as well

[ https://issues.apache.org/jira/browse/KAFKA-8410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8410: --- Description: KIP-478:

[jira] [Updated] (KAFKA-8410) Strengthen the types of Processors, at least in the DSL, maybe in the PAPI as well

[ https://issues.apache.org/jira/browse/KAFKA-8410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8410: --- Labels: kip tech-debt (was: tech-debt) > Strengthen the types of Processors, at least in

[jira] [Resolved] (KAFKA-8410) Strengthen the types of Processors, at least in the DSL, maybe in the PAPI as well

[ https://issues.apache.org/jira/browse/KAFKA-8410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8410. Resolution: Fixed This feature (KIP–478:

[jira] [Updated] (KAFKA-8410) Strengthen the types of Processors, at least in the DSL, maybe in the PAPI as well

[ https://issues.apache.org/jira/browse/KAFKA-8410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8410: --- Fix Version/s: 2.7.0 > Strengthen the types of Processors, at least in the DSL, maybe in the

[jira] [Commented] (KAFKA-13641) Kafka Streams Scala: Add `Option` to `ValueJoiner` parameters

[ https://issues.apache.org/jira/browse/KAFKA-13641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17487750#comment-17487750 ] Matthias J. Sax commented on KAFKA-13641: - {quote}Is the plan to have type driven semantics?

[jira] [Commented] (KAFKA-13641) Kafka Streams Scala: Add `Option` to `ValueJoiner` parameters

[ https://issues.apache.org/jira/browse/KAFKA-13641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17487433#comment-17487433 ] Matthias J. Sax commented on KAFKA-13641: - I don't have a good intuition atm what a good way

[jira] [Commented] (KAFKA-13641) Kafka Streams Scala: Add `Option` to `ValueJoiner` parameters

[ https://issues.apache.org/jira/browse/KAFKA-13641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17486584#comment-17486584 ] Matthias J. Sax commented on KAFKA-13641: - The Java API faces the same issue – it's hard from a

[jira] [Updated] (KAFKA-13641) Kafka Streams Scala: Add `Option` to `ValueJoiner` parameters

[ https://issues.apache.org/jira/browse/KAFKA-13641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13641: Language: scala needs-kip (was: scala) > Kafka Streams Scala: Add `Option` to

[jira] [Commented] (KAFKA-13638) Slow KTable update when forwarding multiple values from transformer

[ https://issues.apache.org/jira/browse/KAFKA-13638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17486177#comment-17486177 ] Matthias J. Sax commented on KAFKA-13638: - Seems this does not explain much yet, as 5.18.4 did

[jira] [Commented] (KAFKA-13633) Merging multiple KStreams in one operation

[ https://issues.apache.org/jira/browse/KAFKA-13633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17486002#comment-17486002 ] Matthias J. Sax commented on KAFKA-13633: - Thanks! Will try to review the KIP soon. > Merging

[jira] [Updated] (KAFKA-13633) Merging multiple KStreams in one operation

[ https://issues.apache.org/jira/browse/KAFKA-13633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13633: Labels: kip (was: ) > Merging multiple KStreams in one operation >

[jira] [Commented] (KAFKA-13638) Slow KTable update when forwarding multiple values from transformer

[ https://issues.apache.org/jira/browse/KAFKA-13638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17486001#comment-17486001 ] Matthias J. Sax commented on KAFKA-13638: - We did update the RocksDB version in 3.0.0 release:

[jira] [Reopened] (KAFKA-13152) Replace "buffered.records.per.partition" with "input.buffer.max.bytes"

[ https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-13152: - The PR broke backward compatibility. Needed to revert the commit. Sorry about that. Lets

[jira] [Updated] (KAFKA-13633) Merging multiple KStreams in one operation

[ https://issues.apache.org/jira/browse/KAFKA-13633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13633: Labels: needs-kip (was: ) > Merging multiple KStreams in one operation >

[jira] [Commented] (KAFKA-13633) Merging multiple KStreams in one operation

[ https://issues.apache.org/jira/browse/KAFKA-13633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17485067#comment-17485067 ] Matthias J. Sax commented on KAFKA-13633: - Seems you close the PR... Btw: this ticket implies a

[jira] [Updated] (KAFKA-10309) KafkaProducer's sendOffsetsToTransaction should not block infinitively

[ https://issues.apache.org/jira/browse/KAFKA-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10309: Fix Version/s: 2.7.0 > KafkaProducer's sendOffsetsToTransaction should not block

[jira] [Created] (KAFKA-13602) Allow to broadcast a result record

Matthias J. Sax created KAFKA-13602: --- Summary: Allow to broadcast a result record Key: KAFKA-13602 URL: https://issues.apache.org/jira/browse/KAFKA-13602 Project: Kafka Issue Type: New

[jira] [Updated] (KAFKA-13602) Allow to broadcast a result record

[ https://issues.apache.org/jira/browse/KAFKA-13602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13602: Labels: needs-kip newbie++ (was: needs-kip) > Allow to broadcast a result record >

[jira] [Updated] (KAFKA-13549) Add "delete interval" config

[ https://issues.apache.org/jira/browse/KAFKA-13549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13549: Description: KIP-811:

[jira] [Commented] (KAFKA-13289) Bulk processing correctly ordered input data through a join with kafka-streams results in `Skipping record for expired segment`

[ https://issues.apache.org/jira/browse/KAFKA-13289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17474910#comment-17474910 ] Matthias J. Sax commented on KAFKA-13289: - {quote}However it seems the dropping of messages is

[jira] [Assigned] (KAFKA-10173) BufferUnderflowException during Kafka Streams Upgrade

[ https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-10173: --- Assignee: John Roesler (was: Matthias J. Sax) > BufferUnderflowException during

[jira] [Assigned] (KAFKA-10173) BufferUnderflowException during Kafka Streams Upgrade

[ https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-10173: --- Assignee: Matthias J. Sax (was: John Roesler) > BufferUnderflowException during

[jira] [Commented] (KAFKA-13289) Bulk processing correctly ordered input data through a join with kafka-streams results in `Skipping record for expired segment`

[ https://issues.apache.org/jira/browse/KAFKA-13289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17473149#comment-17473149 ] Matthias J. Sax commented on KAFKA-13289: - {quote}The app uses a 0ms join window with a 0ms

[jira] [Resolved] (KAFKA-13476) Streams crashes when non Base64 Offset Metadata is found

[ https://issues.apache.org/jira/browse/KAFKA-13476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-13476. - Fix Version/s: 3.2.0 Resolution: Fixed > Streams crashes when non Base64 Offset

[jira] [Commented] (KAFKA-13289) Bulk processing correctly ordered input data through a join with kafka-streams results in `Skipping record for expired segment`

[ https://issues.apache.org/jira/browse/KAFKA-13289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469010#comment-17469010 ] Matthias J. Sax commented on KAFKA-13289: - You can reproduce with the code in the github repo

[jira] [Commented] (KAFKA-13289) Bulk processing correctly ordered input data through a join with kafka-streams results in `Skipping record for expired segment`

[ https://issues.apache.org/jira/browse/KAFKA-13289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17468879#comment-17468879 ] Matthias J. Sax commented on KAFKA-13289: - {quote}However in the cases mentioned here, there is

[jira] [Commented] (KAFKA-13561) Consider deprecating `StreamsBuilder#build(props)` function

[ https://issues.apache.org/jira/browse/KAFKA-13561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463439#comment-17463439 ] Matthias J. Sax commented on KAFKA-13561: - Thanks for the details. > Consider deprecating

[jira] [Updated] (KAFKA-13561) Consider deprecating `StreamsBuilder#build(props)` function

[ https://issues.apache.org/jira/browse/KAFKA-13561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13561: Labels: needs-kip (was: ) > Consider deprecating `StreamsBuilder#build(props)` function

[jira] [Updated] (KAFKA-13561) Consider deprecating `StreamsBuilder#build(props)` function

[ https://issues.apache.org/jira/browse/KAFKA-13561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13561: Component/s: streams > Consider deprecating `StreamsBuilder#build(props)` function >

[jira] [Commented] (KAFKA-13561) Consider deprecating `StreamsBuilder#build(props)` function

[ https://issues.apache.org/jira/browse/KAFKA-13561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463436#comment-17463436 ] Matthias J. Sax commented on KAFKA-13561: - My personal idea was actually to deprecate

[jira] [Updated] (KAFKA-13549) Add "delete interval" config

[ https://issues.apache.org/jira/browse/KAFKA-13549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13549: Labels: kip (was: needs-kip) > Add "delete interval" config >

[jira] [Assigned] (KAFKA-13549) Add "delete interval" config

[ https://issues.apache.org/jira/browse/KAFKA-13549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-13549: --- Assignee: Nicholas Telford > Add "delete interval" config >

[jira] [Updated] (KAFKA-13549) Add "delete interval" config

[ https://issues.apache.org/jira/browse/KAFKA-13549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13549: Description: KIP-811:

[jira] [Commented] (KAFKA-13549) Add "delete interval" config

[ https://issues.apache.org/jira/browse/KAFKA-13549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17461738#comment-17461738 ] Matthias J. Sax commented on KAFKA-13549: - You could also just do the KIP. Should not be too

[jira] [Created] (KAFKA-13555) Consider number if input topic partitions for task assignment

Matthias J. Sax created KAFKA-13555: --- Summary: Consider number if input topic partitions for task assignment Key: KAFKA-13555 URL: https://issues.apache.org/jira/browse/KAFKA-13555 Project: Kafka

[jira] [Commented] (KAFKA-13476) Streams crashes when non Base64 Offset Metadata is found

[ https://issues.apache.org/jira/browse/KAFKA-13476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17461160#comment-17461160 ] Matthias J. Sax commented on KAFKA-13476: - {quote}Tracing data was added to metadata because

[jira] [Created] (KAFKA-13549) Add "delete interval" config

Matthias J. Sax created KAFKA-13549: --- Summary: Add "delete interval" config Key: KAFKA-13549 URL: https://issues.apache.org/jira/browse/KAFKA-13549 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-13500) Consider adding a dedicated standby consumer

[ https://issues.apache.org/jira/browse/KAFKA-13500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17457487#comment-17457487 ] Matthias J. Sax commented on KAFKA-13500: - Right... My bad. > Consider adding a dedicated

[jira] [Comment Edited] (KAFKA-8115) Flaky Test CoordinatorTest#testTaskRequestWithOldStartMsGetsUpdated

[ https://issues.apache.org/jira/browse/KAFKA-8115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456993#comment-17456993 ] Matthias J. Sax edited comment on KAFKA-8115 at 12/10/21, 9:14 AM: --- One

[jira] [Commented] (KAFKA-8115) Flaky Test CoordinatorTest#testTaskRequestWithOldStartMsGetsUpdated

[ https://issues.apache.org/jira/browse/KAFKA-8115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456993#comment-17456993 ] Matthias J. Sax commented on KAFKA-8115: One more on 3.1. > Flaky Test

[jira] [Commented] (KAFKA-13530) Flaky test ReplicaManagerTest

[ https://issues.apache.org/jira/browse/KAFKA-13530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456992#comment-17456992 ] Matthias J. Sax commented on KAFKA-13530: - Again. > Flaky test ReplicaManagerTest >

[jira] [Commented] (KAFKA-8115) Flaky Test CoordinatorTest#testTaskRequestWithOldStartMsGetsUpdated

[ https://issues.apache.org/jira/browse/KAFKA-8115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456991#comment-17456991 ] Matthias J. Sax commented on KAFKA-8115: Failed again. > Flaky Test

[jira] [Commented] (KAFKA-13530) Flaky test ReplicaManagerTest

[ https://issues.apache.org/jira/browse/KAFKA-13530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456990#comment-17456990 ] Matthias J. Sax commented on KAFKA-13530: - +1 > Flaky test ReplicaManagerTest >

[jira] [Commented] (KAFKA-12377) Flaky Test SaslAuthenticatorTest#testSslClientAuthRequiredForSaslSslListener

[ https://issues.apache.org/jira/browse/KAFKA-12377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456989#comment-17456989 ] Matthias J. Sax commented on KAFKA-12377: - One more. > Flaky Test

[jira] [Created] (KAFKA-13532) Flaky test KafkaStreamsTest.testInitializesAndDestroysMetricsReporters

Matthias J. Sax created KAFKA-13532: --- Summary: Flaky test KafkaStreamsTest.testInitializesAndDestroysMetricsReporters Key: KAFKA-13532 URL: https://issues.apache.org/jira/browse/KAFKA-13532

[jira] [Commented] (KAFKA-12377) Flaky Test SaslAuthenticatorTest#testSslClientAuthRequiredForSaslSslListener

[ https://issues.apache.org/jira/browse/KAFKA-12377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456986#comment-17456986 ] Matthias J. Sax commented on KAFKA-12377: - One more on 3.1 branch. > Flaky Test

[jira] [Created] (KAFKA-13531) Flaky test NamedTopologyIntegrationTest

Matthias J. Sax created KAFKA-13531: --- Summary: Flaky test NamedTopologyIntegrationTest Key: KAFKA-13531 URL: https://issues.apache.org/jira/browse/KAFKA-13531 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-12933) Flaky test ReassignPartitionsIntegrationTest.testReassignmentWithAlterIsrDisabled

[ https://issues.apache.org/jira/browse/KAFKA-12933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-12933. - Resolution: Fixed > Flaky test >

[jira] [Commented] (KAFKA-13530) Flaky test ReplicaManagerTest

[ https://issues.apache.org/jira/browse/KAFKA-13530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456981#comment-17456981 ] Matthias J. Sax commented on KAFKA-13530: - And again. > Flaky test ReplicaManagerTest >

[jira] [Commented] (KAFKA-13514) Flakey test StickyAssignorTest

[ https://issues.apache.org/jira/browse/KAFKA-13514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456982#comment-17456982 ] Matthias J. Sax commented on KAFKA-13514: - And one more. > Flakey test StickyAssignorTest >

[jira] [Commented] (KAFKA-13530) Flaky test ReplicaManagerTest

[ https://issues.apache.org/jira/browse/KAFKA-13530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456978#comment-17456978 ] Matthias J. Sax commented on KAFKA-13530: - And one more. > Flaky test ReplicaManagerTest >

<    3   4   5   6   7   8   9   10   11   12   >