[jira] [Commented] (KAFKA-14184) Kafka streams application crashes due to "UnsupportedOperationException: this should not happen: timestamp() is not supported in standby tasks."

[ https://issues.apache.org/jira/browse/KAFKA-14184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635680#comment-17635680 ] Matthias J. Sax commented on KAFKA-14184: - The stack trace is highly suspicious. Based on the

[jira] [Commented] (KAFKA-14374) Kafka streams losing messages in State Store during first launch of app

[ https://issues.apache.org/jira/browse/KAFKA-14374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635667#comment-17635667 ] Matthias J. Sax commented on KAFKA-14374: - Thanks for creating a ticket. I am not sure right now

[jira] [Resolved] (KAFKA-14360) Documentation: Streams Security page has broken links

[ https://issues.apache.org/jira/browse/KAFKA-14360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-14360. - Resolution: Fixed > Documentation: Streams Security page has broken links >

[jira] [Resolved] (KAFKA-14360) Documentation: Streams Security page has broken links

[ https://issues.apache.org/jira/browse/KAFKA-14360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-14360. - Resolution: Fixed > Documentation: Streams Security page has broken links >

[jira] [Commented] (KAFKA-14294) Kafka Streams should commit transaction when no records are processed

[ https://issues.apache.org/jira/browse/KAFKA-14294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630098#comment-17630098 ] Matthias J. Sax commented on KAFKA-14294: - Why do you think we don't commit? Based on the code,

[jira] [Commented] (KAFKA-13813) left/outer joins can wait indefinitely for emitted record with spurious record fix

[ https://issues.apache.org/jira/browse/KAFKA-13813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629223#comment-17629223 ] Matthias J. Sax commented on KAFKA-13813: - Sorry for late reply – I was on leave. {quote}In this

[jira] [Updated] (KAFKA-14090) Allow Kafka Streams to be configured to not create internal topics

[ https://issues.apache.org/jira/browse/KAFKA-14090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14090: Component/s: streams (was: clients) > Allow Kafka Streams to be

[jira] [Updated] (KAFKA-14076) Fix issues with KafkaStreams.CloseOptions

[ https://issues.apache.org/jira/browse/KAFKA-14076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14076: Affects Version/s: 3.3.0 > Fix issues with KafkaStreams.CloseOptions >

[jira] [Updated] (KAFKA-13217) Reconsider skipping the LeaveGroup on close() or add an overload that does so

[ https://issues.apache.org/jira/browse/KAFKA-13217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13217: Labels: kip newbie newbie++ (was: needs-kip newbie newbie++) > Reconsider skipping the

[jira] [Updated] (KAFKA-13217) Reconsider skipping the LeaveGroup on close() or add an overload that does so

[ https://issues.apache.org/jira/browse/KAFKA-13217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13217: Description: In Kafka Streams, when an instance is shut down via the close() API, we

[jira] [Commented] (KAFKA-13217) Reconsider skipping the LeaveGroup on close() or add an overload that does so

[ https://issues.apache.org/jira/browse/KAFKA-13217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17569283#comment-17569283 ] Matthias J. Sax commented on KAFKA-13217: - Just reviewed the PR and linked the tickets. PR LGTM,

[jira] [Commented] (KAFKA-14076) Fix issues with KafkaStreams.CloseOptions

[ https://issues.apache.org/jira/browse/KAFKA-14076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17569282#comment-17569282 ] Matthias J. Sax commented on KAFKA-14076: - Marking this as blocker for 3.3, because this fixes

[jira] [Updated] (KAFKA-14076) Fix issues with KafkaStreams.CloseOptions

[ https://issues.apache.org/jira/browse/KAFKA-14076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14076: Priority: Blocker (was: Major) > Fix issues with KafkaStreams.CloseOptions >

[jira] [Updated] (KAFKA-14076) Fix issues with KafkaStreams.CloseOptions

[ https://issues.apache.org/jira/browse/KAFKA-14076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14076: Fix Version/s: 3.3.0 > Fix issues with KafkaStreams.CloseOptions >

[jira] [Assigned] (KAFKA-14076) Fix issues with KafkaStreams.CloseOptions

[ https://issues.apache.org/jira/browse/KAFKA-14076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-14076: --- Assignee: Jim Hughes > Fix issues with KafkaStreams.CloseOptions >

[jira] [Commented] (KAFKA-12887) Do not trigger user-customized ExceptionalHandler for RTE

[ https://issues.apache.org/jira/browse/KAFKA-12887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17568659#comment-17568659 ] Matthias J. Sax commented on KAFKA-12887: - This feature broke some stuff, and we revert it:

[jira] [Updated] (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 updated KAFKA-13152: Labels: kip (was: needs-kip) > Replace "buffered.records.per.partition" with

[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: - > Replace "buffered.records.per.partition" with "input.buffer.max.bytes" >

[jira] [Updated] (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 updated KAFKA-13152: Fix Version/s: (was: 3.3.0) > Replace "buffered.records.per.partition" with

[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: - > Replace "buffered.records.per.partition" with "input.buffer.max.bytes" >

[jira] [Commented] (KAFKA-14049) Relax Non Null Requirement for KStreamGlobalKTable Left Join

[ https://issues.apache.org/jira/browse/KAFKA-14049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17563510#comment-17563510 ] Matthias J. Sax commented on KAFKA-14049: - {quote}Null Values in the Stream for a Left Join

[jira] (KAFKA-14049) Relax Non Null Requirement for KStreamGlobalKTable Left Join

[ https://issues.apache.org/jira/browse/KAFKA-14049 ] Matthias J. Sax deleted comment on KAFKA-14049: - was (Author: mjsax): Sounds like a duplicate to https://issues.apache.org/jira/browse/KAFKA-12317 ? > Relax Non Null Requirement for

[jira] [Commented] (KAFKA-14049) Relax Non Null Requirement for KStreamGlobalKTable Left Join

[ https://issues.apache.org/jira/browse/KAFKA-14049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17563509#comment-17563509 ] Matthias J. Sax commented on KAFKA-14049: - Sounds like a duplicate to

[jira] [Updated] (KAFKA-13936) Invalid consumer lag when monitoring from a kafka streams application

[ https://issues.apache.org/jira/browse/KAFKA-13936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13936: Fix Version/s: 3.3.0 > Invalid consumer lag when monitoring from a kafka streams

[jira] [Assigned] (KAFKA-13936) Invalid consumer lag when monitoring from a kafka streams application

[ https://issues.apache.org/jira/browse/KAFKA-13936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-13936: --- Assignee: Prashanth Joseph Babu > Invalid consumer lag when monitoring from a

[jira] [Resolved] (KAFKA-13936) Invalid consumer lag when monitoring from a kafka streams application

[ https://issues.apache.org/jira/browse/KAFKA-13936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-13936. - Resolution: Fixed > Invalid consumer lag when monitoring from a kafka streams

[jira] [Resolved] (KAFKA-13936) Invalid consumer lag when monitoring from a kafka streams application

[ https://issues.apache.org/jira/browse/KAFKA-13936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-13936. - Resolution: Fixed > Invalid consumer lag when monitoring from a kafka streams

[jira] [Commented] (KAFKA-10493) KTable out-of-order updates are not being ignored

[ https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17560622#comment-17560622 ] Matthias J. Sax commented on KAFKA-10493: - There is nothing official yet, but we started to work

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

[ https://issues.apache.org/jira/browse/KAFKA-13531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17555781#comment-17555781 ] Matthias J. Sax commented on KAFKA-13531: - Could be. We usually also report if we say more

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

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

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

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

[jira] [Commented] (KAFKA-13939) Memory Leak When Logging Is Disabled In InMemoryTimeOrderedKeyValueBuffer

[ https://issues.apache.org/jira/browse/KAFKA-13939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17554742#comment-17554742 ] Matthias J. Sax commented on KAFKA-13939: - Thanks for the PR. I added you to list of

[jira] [Assigned] (KAFKA-13939) Memory Leak When Logging Is Disabled In InMemoryTimeOrderedKeyValueBuffer

[ https://issues.apache.org/jira/browse/KAFKA-13939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-13939: --- Assignee: Jackson Newhouse > Memory Leak When Logging Is Disabled In

[jira] [Commented] (SUREFIRE-2076) BufferOverflowException when encoding message with null runMode

[ https://issues.apache.org/jira/browse/SUREFIRE-2076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17554376#comment-17554376 ] Matthias J. Sax commented on SUREFIRE-2076: --- Thanks for the update! – I opened a PR for our

[jira] [Commented] (KAFKA-13963) Topology Description ignores context.forward

[ https://issues.apache.org/jira/browse/KAFKA-13963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17551333#comment-17551333 ] Matthias J. Sax commented on KAFKA-13963: - {quote}Is it worth updating the java doc to mention

[jira] [Commented] (KAFKA-13963) Topology Description ignores context.forward

[ https://issues.apache.org/jira/browse/KAFKA-13963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17551271#comment-17551271 ] Matthias J. Sax commented on KAFKA-13963: - TopologyDescription only describes the structure of

[jira] [Commented] (KAFKA-13936) Invalid consumer lag when monitoring from a kafka streams application

[ https://issues.apache.org/jira/browse/KAFKA-13936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17546407#comment-17546407 ] Matthias J. Sax commented on KAFKA-13936: - The docs are in the same repository as the code:

[jira] [Commented] (KAFKA-13936) Invalid consumer lag when monitoring from a kafka streams application

[ https://issues.apache.org/jira/browse/KAFKA-13936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17545686#comment-17545686 ] Matthias J. Sax commented on KAFKA-13936: - Might be worth to document for this case :) – Would

[jira] [Updated] (KAFKA-13945) Add task-level metrics to Streams for bytes/records Produced

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

[jira] [Commented] (KAFKA-13936) Invalid consumer lag when monitoring from a kafka streams application

[ https://issues.apache.org/jira/browse/KAFKA-13936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17544647#comment-17544647 ] Matthias J. Sax commented on KAFKA-13936: - As mentioned above, offsets are by default committed

[jira] [Commented] (KAFKA-13939) Memory Leak When Logging Is Disabled In InMemoryTimeOrderedKeyValueBuffer

[ https://issues.apache.org/jira/browse/KAFKA-13939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17544645#comment-17544645 ] Matthias J. Sax commented on KAFKA-13939: - Thanks for reporting this issue – sound rather severs

[jira] [Updated] (KAFKA-13939) Memory Leak When Logging Is Disabled In InMemoryTimeOrderedKeyValueBuffer

[ https://issues.apache.org/jira/browse/KAFKA-13939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13939: Component/s: streams > Memory Leak When Logging Is Disabled In

[jira] [Updated] (KAFKA-13939) Memory Leak When Logging Is Disabled In InMemoryTimeOrderedKeyValueBuffer

[ https://issues.apache.org/jira/browse/KAFKA-13939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13939: Priority: Blocker (was: Major) > Memory Leak When Logging Is Disabled In

[jira] [Commented] (KAFKA-13936) Invalid consumer lag when monitoring from a kafka streams application

[ https://issues.apache.org/jira/browse/KAFKA-13936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542359#comment-17542359 ] Matthias J. Sax commented on KAFKA-13936: - > we see in the kafka UI  There is no "Kafka UI" –

[jira] [Commented] (KAFKA-13817) Schedule nextTimeToEmit to system time every time instead of just once

[ https://issues.apache.org/jira/browse/KAFKA-13817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17540294#comment-17540294 ] Matthias J. Sax commented on KAFKA-13817: - Thanks for the PR! I put it into my review backlog.

[jira] [Commented] (KAFKA-13913) Provide builders for KafkaProducer/KafkaConsumer and KafkaStreams

[ https://issues.apache.org/jira/browse/KAFKA-13913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17539718#comment-17539718 ] Matthias J. Sax commented on KAFKA-13913: - There was some discussion about this in the past (cf

[jira] [Updated] (KAFKA-13913) Provide builders for KafkaProducer/KafkaConsumer and KafkaStreams

[ https://issues.apache.org/jira/browse/KAFKA-13913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13913: Labels: kip (was: ) > Provide builders for KafkaProducer/KafkaConsumer and KafkaStreams

[jira] [Updated] (KAFKA-13913) Provide builders for KafkaProducer/KafkaConsumer and KafkaStreams

[ https://issues.apache.org/jira/browse/KAFKA-13913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13913: Component/s: streams > Provide builders for KafkaProducer/KafkaConsumer and KafkaStreams

[jira] [Commented] (KAFKA-6520) When a Kafka Stream can't communicate with the server, it's Status stays RUNNING

[ https://issues.apache.org/jira/browse/KAFKA-6520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17537860#comment-17537860 ] Matthias J. Sax commented on KAFKA-6520: It's still an open item – and it's complex (for details,

[jira] [Commented] (KAFKA-13817) Schedule nextTimeToEmit to system time every time instead of just once

[ https://issues.apache.org/jira/browse/KAFKA-13817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17536926#comment-17536926 ] Matthias J. Sax commented on KAFKA-13817: - > as it will eventually self-correct and continue to

[jira] [Commented] (SUREFIRE-2076) BufferOverflowException when encoding message with null runMode

[ https://issues.apache.org/jira/browse/SUREFIRE-2076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17535072#comment-17535072 ] Matthias J. Sax commented on SUREFIRE-2076: --- [~tibordigana] [~zoltan.meze] – Did you see my

[jira] [Resolved] (KAFKA-7527) Enable Dependency Injection for Kafka Streams handlers (KIP-378)

[ https://issues.apache.org/jira/browse/KAFKA-7527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7527. Resolution: Fixed > Enable Dependency Injection for Kafka Streams handlers (KIP-378) >

[jira] [Resolved] (KAFKA-7527) Enable Dependency Injection for Kafka Streams handlers (KIP-378)

[ https://issues.apache.org/jira/browse/KAFKA-7527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7527. Resolution: Fixed > Enable Dependency Injection for Kafka Streams handlers (KIP-378) >

[jira] [Commented] (KAFKA-8769) Consider computing stream time independently per key

[ https://issues.apache.org/jira/browse/KAFKA-8769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17532427#comment-17532427 ] Matthias J. Sax commented on KAFKA-8769: Just a "random" comment, based on some other discussion

[jira] [Updated] (KAFKA-13873) Add ability to Pause / Resume KafkaStreams Topologies

[ https://issues.apache.org/jira/browse/KAFKA-13873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13873: Description: In order to reduce resources used or modify data pipelines, users may want

[jira] [Updated] (KAFKA-13873) Add ability to Pause / Resume KafkaStreams Topologies

[ https://issues.apache.org/jira/browse/KAFKA-13873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13873: Component/s: streams > Add ability to Pause / Resume KafkaStreams Topologies >

[jira] [Updated] (KAFKA-13873) Add ability to Pause / Resume KafkaStreams Topologies

[ https://issues.apache.org/jira/browse/KAFKA-13873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13873: Labels: kip (was: ) > Add ability to Pause / Resume KafkaStreams Topologies >

[jira] [Updated] (KAFKA-13870) support both Suppressed untilTimeLimit and maxBytes without using emitEarlyWhenFull()

[ https://issues.apache.org/jira/browse/KAFKA-13870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13870: Labels: needs-kip (was: ) > support both Suppressed untilTimeLimit and maxBytes without

[jira] [Commented] (KAFKA-13870) support both Suppressed untilTimeLimit and maxBytes without using emitEarlyWhenFull()

[ https://issues.apache.org/jira/browse/KAFKA-13870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17531836#comment-17531836 ] Matthias J. Sax commented on KAFKA-13870: - I think you mix up two concepts: windowing is about

[jira] [Updated] (KAFKA-13813) left/outer joins can wait indefinitely for emitted record with spurious record fix

[ https://issues.apache.org/jira/browse/KAFKA-13813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13813: Summary: left/outer joins can wait indefinitely for emitted record with spurious record

[jira] [Created] (KAFKA-13866) Support more advanced time retention policies

Matthias J. Sax created KAFKA-13866: --- Summary: Support more advanced time retention policies Key: KAFKA-13866 URL: https://issues.apache.org/jira/browse/KAFKA-13866 Project: Kafka Issue

[jira] [Created] (KAFKA-13866) Support more advanced time retention policies

Matthias J. Sax created KAFKA-13866: --- Summary: Support more advanced time retention policies Key: KAFKA-13866 URL: https://issues.apache.org/jira/browse/KAFKA-13866 Project: Kafka Issue

[jira] [Commented] (SUREFIRE-2076) BufferOverflowException when encoding message with null runMode

[ https://issues.apache.org/jira/browse/SUREFIRE-2076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17529670#comment-17529670 ] Matthias J. Sax commented on SUREFIRE-2076: --- Seems we are hitting this issue trying to

[jira] [Commented] (KAFKA-13647) RocksDb metrics 'number-open-files' is not correct

[ https://issues.apache.org/jira/browse/KAFKA-13647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17528288#comment-17528288 ] Matthias J. Sax commented on KAFKA-13647: - Should we close this ticket? \cc [~guozhang]

[jira] [Comment Edited] (KAFKA-12909) Allow users to opt-into spurious left/outer stream-stream join improvement

[ https://issues.apache.org/jira/browse/KAFKA-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522502#comment-17522502 ] Matthias J. Sax edited comment on KAFKA-12909 at 4/21/22 9:13 PM: --

[jira] [Commented] (KAFKA-12909) Allow users to opt-into spurious left/outer stream-stream join improvement

[ https://issues.apache.org/jira/browse/KAFKA-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17526086#comment-17526086 ] Matthias J. Sax commented on KAFKA-12909: - Ah sorry. That was my bad... Fixed. > Allow users to

[jira] [Updated] (KAFKA-13842) Add per-aggregation step before repartitioning

[ https://issues.apache.org/jira/browse/KAFKA-13842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13842: Description: Kafka Streams follows a continuous refinement model for aggregation. For

[jira] [Created] (KAFKA-13842) Add per-aggregation step before repartitioning

Matthias J. Sax created KAFKA-13842: --- Summary: Add per-aggregation step before repartitioning Key: KAFKA-13842 URL: https://issues.apache.org/jira/browse/KAFKA-13842 Project: Kafka Issue

[jira] [Created] (KAFKA-13842) Add per-aggregation step before repartitioning

Matthias J. Sax created KAFKA-13842: --- Summary: Add per-aggregation step before repartitioning Key: KAFKA-13842 URL: https://issues.apache.org/jira/browse/KAFKA-13842 Project: Kafka Issue

[jira] [Comment Edited] (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 edited comment on KAFKA-13787 at 4/15/22 8:56 PM: --

[jira] [Comment Edited] (KAFKA-12909) Allow users to opt-into spurious left/outer stream-stream join improvement

[ https://issues.apache.org/jira/browse/KAFKA-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522502#comment-17522502 ] Matthias J. Sax edited comment on KAFKA-12909 at 4/14/22 7:12 PM: --

[jira] [Commented] (KAFKA-12909) Allow users to opt-into spurious left/outer stream-stream join improvement

[ https://issues.apache.org/jira/browse/KAFKA-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522502#comment-17522502 ] Matthias J. Sax commented on KAFKA-12909: - {quote}It makes sense but it is still kind of hard to

[jira] [Commented] (KAFKA-12909) Allow users to opt-into spurious left/outer stream-stream join improvement

[ https://issues.apache.org/jira/browse/KAFKA-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17521985#comment-17521985 ] Matthias J. Sax commented on KAFKA-12909: - This ticket is about left/outer join in particular

[jira] [Commented] (KAFKA-8318) Session Window Aggregations generate an extra tombstone

[ https://issues.apache.org/jira/browse/KAFKA-8318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17521866#comment-17521866 ] Matthias J. Sax commented on KAFKA-8318: It seem [~ipasynkov] does no work on this any longer.

[jira] [Updated] (KAFKA-13817) Schedule nextTimeToEmit to system time every time instead of just once

[ https://issues.apache.org/jira/browse/KAFKA-13817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13817: Labels: beginner newbie (was: ) > Schedule nextTimeToEmit to system time every time

[jira] [Updated] (KAFKA-13817) Schedule nextTimeToEmit to system time every time instead of just once

[ https://issues.apache.org/jira/browse/KAFKA-13817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13817: Component/s: streams > Schedule nextTimeToEmit to system time every time instead of just

[jira] [Commented] (KAFKA-13813) left/outer joins can wait indefinitely for emitted record with suprious record fix

[ https://issues.apache.org/jira/browse/KAFKA-13813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17521243#comment-17521243 ] Matthias J. Sax commented on KAFKA-13813: - The change is intentionally, as users wanted to get

[jira] [Commented] (KAFKA-13820) Add debug-level logs to explain why a store is filtered out during interactive query

[ https://issues.apache.org/jira/browse/KAFKA-13820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17521234#comment-17521234 ] Matthias J. Sax commented on KAFKA-13820: - Sounds related to

[jira] [Updated] (KAFKA-13813) left/outer joins can wait indefinitely for emitted record with suprious record fix

[ https://issues.apache.org/jira/browse/KAFKA-13813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13813: Issue Type: Improvement (was: Bug) > left/outer joins can wait indefinitely for emitted

[jira] [Updated] (KAFKA-13813) left/outer joins can wait indefinitely for emitted record with suprious record fix

[ https://issues.apache.org/jira/browse/KAFKA-13813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13813: Component/s: streams > left/outer joins can wait indefinitely for emitted record with

[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=17519199#comment-17519199 ] Matthias J. Sax commented on KAFKA-7509: Thanks for staying on top of this. The filtering code is

[jira] [Commented] (KAFKA-12909) Allow users to opt-into spurious left/outer stream-stream join improvement

[ https://issues.apache.org/jira/browse/KAFKA-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519175#comment-17519175 ] Matthias J. Sax commented on KAFKA-12909: - Not that _inner_ join result are still instant, even

[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 >

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