[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&focusedCommentId=17507674#comment-17507674 ] Leah Thomas commented on KAFKA-13739: - I think your analysis makes sense and the cha

[jira] [Created] (KAFKA-13811) Investigate sliding windows performance

Leah Thomas created KAFKA-13811: --- Summary: Investigate sliding windows performance Key: KAFKA-13811 URL: https://issues.apache.org/jira/browse/KAFKA-13811 Project: Kafka Issue Type: Task

[jira] [Resolved] (KAFKA-10366) TimeWindowedDeserializer doesn't allow users to set a custom window size

[ https://issues.apache.org/jira/browse/KAFKA-10366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leah Thomas resolved KAFKA-10366. - Fix Version/s: 2.8.0 Resolution: Fixed > TimeWindowedDeserializer doesn't allow users to

[jira] [Resolved] (KAFKA-9649) Remove/Warn on use of TimeWindowedSerde with no specified window size

[ https://issues.apache.org/jira/browse/KAFKA-9649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leah Thomas resolved KAFKA-9649. Fix Version/s: 2.8.0 Resolution: Fixed > Remove/Warn on use of TimeWindowedSerde with no spe

[jira] [Created] (KAFKA-12344) Support SlidingWindows in the Scala API

Leah Thomas created KAFKA-12344: --- Summary: Support SlidingWindows in the Scala API Key: KAFKA-12344 URL: https://issues.apache.org/jira/browse/KAFKA-12344 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-13052) Replace uses of SerDes in the docs with Serdes

Leah Thomas created KAFKA-13052: --- Summary: Replace uses of SerDes in the docs with Serdes Key: KAFKA-13052 URL: https://issues.apache.org/jira/browse/KAFKA-13052 Project: Kafka Issue Type: Task

[jira] [Created] (KAFKA-13120) Flesh out `streams_static_membership_test` to be more robust

Leah Thomas created KAFKA-13120: --- Summary: Flesh out `streams_static_membership_test` to be more robust Key: KAFKA-13120 URL: https://issues.apache.org/jira/browse/KAFKA-13120 Project: Kafka I

[jira] [Updated] (KAFKA-13120) Flesh out `streams_static_membership_test` to be more robust

[ https://issues.apache.org/jira/browse/KAFKA-13120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leah Thomas updated KAFKA-13120: Description: When fixing the `streams_static_membership_test.py` we noticed that the test is prett

[jira] [Assigned] (KAFKA-5636) Add Sliding-Window support for Aggregations

[ https://issues.apache.org/jira/browse/KAFKA-5636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leah Thomas reassigned KAFKA-5636: -- Assignee: Leah Thomas (was: Sophie Blee-Goldman) > Add Sliding-Window support for Aggregation

[jira] [Assigned] (KAFKA-4996) Fix findbugs multithreaded correctness warnings for streams

[ https://issues.apache.org/jira/browse/KAFKA-4996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leah Thomas reassigned KAFKA-4996: -- Assignee: Leah Thomas (was: Sophie Blee-Goldman) > Fix findbugs multithreaded correctness war

[jira] [Commented] (KAFKA-9509) Fix flaky test MirrorConnectorsIntegrationTest.testReplication

[ https://issues.apache.org/jira/browse/KAFKA-9509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17146612#comment-17146612 ] Leah Thomas commented on KAFKA-9509: Failed again: h3. Stacktrace java.lang.RuntimeE

[jira] [Resolved] (KAFKA-4996) Fix findbugs multithreaded correctness warnings for streams

[ https://issues.apache.org/jira/browse/KAFKA-4996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leah Thomas resolved KAFKA-4996. Resolution: Fixed > Fix findbugs multithreaded correctness warnings for streams > -

[jira] [Created] (KAFKA-10366) TimeWindowedDeserializer doesn't allow users to set a custom window size

Leah Thomas created KAFKA-10366: --- Summary: TimeWindowedDeserializer doesn't allow users to set a custom window size Key: KAFKA-10366 URL: https://issues.apache.org/jira/browse/KAFKA-10366 Project: Kafka

[jira] [Commented] (KAFKA-9649) Remove/Warn on use of TimeWindowedSerde with no specified window size

[ https://issues.apache.org/jira/browse/KAFKA-9649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17181472#comment-17181472 ] Leah Thomas commented on KAFKA-9649: Hey Sören, I started a KIP to take care of this

[jira] [Comment Edited] (KAFKA-9649) Remove/Warn on use of TimeWindowedSerde with no specified window size

[ https://issues.apache.org/jira/browse/KAFKA-9649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17181472#comment-17181472 ] Leah Thomas edited comment on KAFKA-9649 at 8/20/20, 10:24 PM:

[jira] [Updated] (KAFKA-5636) Add Sliding-Window support for Aggregations

[ https://issues.apache.org/jira/browse/KAFKA-5636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leah Thomas updated KAFKA-5636: --- Fix Version/s: 2.7.0 > Add Sliding-Window support for Aggregations >

[jira] [Resolved] (KAFKA-5636) Add Sliding-Window support for Aggregations

[ https://issues.apache.org/jira/browse/KAFKA-5636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leah Thomas resolved KAFKA-5636. Resolution: Fixed > Add Sliding-Window support for Aggregations > -

[jira] [Assigned] (KAFKA-9126) Extend `StreamJoined` to allow more store configs

[ https://issues.apache.org/jira/browse/KAFKA-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leah Thomas reassigned KAFKA-9126: -- Assignee: Leah Thomas > Extend `StreamJoined` to allow more store configs > --

[jira] [Assigned] (KAFKA-9559) Change the default "default serde" from ByteArraySerde to null

[ https://issues.apache.org/jira/browse/KAFKA-9559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leah Thomas reassigned KAFKA-9559: -- Assignee: Leah Thomas > Change the default "default serde" from ByteArraySerde to null > -

[jira] [Commented] (KAFKA-9559) Change the default "default serde" from ByteArraySerde to null

[ https://issues.apache.org/jira/browse/KAFKA-9559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17314023#comment-17314023 ] Leah Thomas commented on KAFKA-9559: [~mjsax] are you saying refactoring the code whe

[jira] [Assigned] (KAFKA-12344) Support SlidingWindows in the Scala API

[ https://issues.apache.org/jira/browse/KAFKA-12344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leah Thomas reassigned KAFKA-12344: --- Assignee: (was: Leah Thomas) > Support SlidingWindows in the Scala API > --

[jira] [Updated] (KAFKA-12344) Support SlidingWindows in the Scala API

[ https://issues.apache.org/jira/browse/KAFKA-12344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leah Thomas updated KAFKA-12344: Labels: newbie scala (was: ) > Support SlidingWindows in the Scala API >

[jira] [Commented] (KAFKA-12344) Support SlidingWindows in the Scala API

[ https://issues.apache.org/jira/browse/KAFKA-12344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17314954#comment-17314954 ] Leah Thomas commented on KAFKA-12344: - Hi [~ketulgupta], thanks for picking this up!

[jira] [Commented] (KAFKA-10417) suppress() with cogroup() throws ClassCastException

[ https://issues.apache.org/jira/browse/KAFKA-10417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17242789#comment-17242789 ] Leah Thomas commented on KAFKA-10417: - [~duvholt] are you still planning on working

[jira] [Assigned] (KAFKA-10417) suppress() with cogroup() throws ClassCastException

[ https://issues.apache.org/jira/browse/KAFKA-10417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leah Thomas reassigned KAFKA-10417: --- Assignee: Leah Thomas > suppress() with cogroup() throws ClassCastException > -

[jira] [Assigned] (KAFKA-9126) Extend `StreamJoined` to allow more store configs

[ https://issues.apache.org/jira/browse/KAFKA-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leah Thomas reassigned KAFKA-9126: -- Assignee: Leah Thomas > Extend `StreamJoined` to allow more store configs > --

[jira] [Assigned] (KAFKA-9126) Extend `StreamJoined` to allow more store configs

[ https://issues.apache.org/jira/browse/KAFKA-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leah Thomas reassigned KAFKA-9126: -- Assignee: (was: Leah Thomas) > Extend `StreamJoined` to allow more store configs > ---

[jira] [Resolved] (KAFKA-10417) suppress() with cogroup() throws ClassCastException

[ https://issues.apache.org/jira/browse/KAFKA-10417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leah Thomas resolved KAFKA-10417. - Resolution: Fixed > suppress() with cogroup() throws ClassCastException > --

[jira] [Resolved] (KAFKA-9126) Extend `StreamJoined` to allow more store configs

[ https://issues.apache.org/jira/browse/KAFKA-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leah Thomas resolved KAFKA-9126. Fix Version/s: 2.8.0 Resolution: Fixed > Extend `StreamJoined` to allow more store configs >

[jira] [Commented] (KAFKA-12190) Failure on Windows due to an UnsupportedOperationException when StateDirectory sets file permissions

[ https://issues.apache.org/jira/browse/KAFKA-12190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17264922#comment-17264922 ] Leah Thomas commented on KAFKA-12190: - Hey [~awilkinson], the 2.8 release plan is he