[jira] [Updated] (KAFKA-10515) NPE: Foreign key join serde may not be initialized with default serde if application is distributed

2020-10-29 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10515: - Fix Version/s: 2.6.1 > NPE: Foreign key join serde may not be initialized with default serde if

[jira] [Created] (KAFKA-10662) Possible hanging test in 2.6 on JDK 11

2020-10-29 Thread John Roesler (Jira)
John Roesler created KAFKA-10662: Summary: Possible hanging test in 2.6 on JDK 11 Key: KAFKA-10662 URL: https://issues.apache.org/jira/browse/KAFKA-10662 Project: Kafka Issue Type: Bug Af

[jira] [Resolved] (KAFKA-10638) QueryableStateIntegrationTest fails due to stricter store checking

2020-10-29 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-10638. -- Resolution: Fixed > QueryableStateIntegrationTest fails due to stricter store checking > -

[jira] [Updated] (KAFKA-10638) QueryableStateIntegrationTest fails due to stricter store checking

2020-10-29 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10638: - Fix Version/s: (was: 2.7.1) (was: 2.8.0) 2.7.0 > Q

[jira] [Commented] (KAFKA-10638) QueryableStateIntegrationTest fails due to stricter store checking

2020-10-28 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17222306#comment-17222306 ] John Roesler commented on KAFKA-10638: -- Thanks, [~bbejeck] , I agree. When I filed

[jira] [Assigned] (KAFKA-10091) Improve task idling

2020-10-28 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-10091: Assignee: John Roesler (was: A. Sophie Blee-Goldman) > Improve task idling > ---

[jira] [Commented] (KAFKA-10638) QueryableStateIntegrationTest fails due to stricter store checking

2020-10-23 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17219873#comment-17219873 ] John Roesler commented on KAFKA-10638: -- Hey [~bbejeck] , I've marked this as a 2.7.

[jira] [Created] (KAFKA-10638) QueryableStateIntegrationTest fails due to stricter store checking

2020-10-23 Thread John Roesler (Jira)
John Roesler created KAFKA-10638: Summary: QueryableStateIntegrationTest fails due to stricter store checking Key: KAFKA-10638 URL: https://issues.apache.org/jira/browse/KAFKA-10638 Project: Kafka

[jira] [Updated] (KAFKA-10284) Group membership update due to static member rejoin should be persisted

2020-10-23 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10284: - Fix Version/s: 2.5.2 > Group membership update due to static member rejoin should be persisted >

[jira] [Updated] (KAFKA-10284) Group membership update due to static member rejoin should be persisted

2020-10-22 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10284: - Fix Version/s: 2.6.1 > Group membership update due to static member rejoin should be persisted >

[jira] [Resolved] (KAFKA-10284) Group membership update due to static member rejoin should be persisted

2020-10-22 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-10284. -- Resolution: Fixed > Group membership update due to static member rejoin should be persisted >

[jira] [Updated] (KAFKA-10284) Group membership update due to static member rejoin should be persisted

2020-10-22 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10284: - Fix Version/s: 2.7.0 > Group membership update due to static member rejoin should be persisted >

[jira] [Created] (KAFKA-10630) State Directory config could be improved

2020-10-22 Thread John Roesler (Jira)
John Roesler created KAFKA-10630: Summary: State Directory config could be improved Key: KAFKA-10630 URL: https://issues.apache.org/jira/browse/KAFKA-10630 Project: Kafka Issue Type: Task

[jira] [Created] (KAFKA-10629) TopologyTestDriver should not require a Properties arg

2020-10-22 Thread John Roesler (Jira)
John Roesler created KAFKA-10629: Summary: TopologyTestDriver should not require a Properties arg Key: KAFKA-10629 URL: https://issues.apache.org/jira/browse/KAFKA-10629 Project: Kafka Issue

[jira] [Updated] (KAFKA-10628) Follow-up: Remove all unnecessary dummy TopologyTestDriver configs

2020-10-22 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10628: - Component/s: streams > Follow-up: Remove all unnecessary dummy TopologyTestDriver configs >

[jira] [Updated] (KAFKA-10628) Follow-up: Remove all unnecessary dummy TopologyTestDriver configs

2020-10-22 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10628: - Labels: newbie (was: ) > Follow-up: Remove all unnecessary dummy TopologyTestDriver configs > -

[jira] [Updated] (KAFKA-10628) Follow-up: Remove all unnecessary dummy TopologyTestDriver configs

2020-10-22 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10628: - Component/s: streams-test-utils > Follow-up: Remove all unnecessary dummy TopologyTestDriver con

[jira] [Created] (KAFKA-10628) Follow-up: Remove all unnecessary dummy TopologyTestDriver configs

2020-10-22 Thread John Roesler (Jira)
John Roesler created KAFKA-10628: Summary: Follow-up: Remove all unnecessary dummy TopologyTestDriver configs Key: KAFKA-10628 URL: https://issues.apache.org/jira/browse/KAFKA-10628 Project: Kafka

[jira] [Commented] (KAFKA-10515) NPE: Foreign key join serde may not be initialized with default serde if application is distributed

2020-10-21 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17218346#comment-17218346 ] John Roesler commented on KAFKA-10515: -- Removed the 2.6 and 2.5 fix versions until

[jira] [Updated] (KAFKA-10515) NPE: Foreign key join serde may not be initialized with default serde if application is distributed

2020-10-21 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10515: - Fix Version/s: (was: 2.6.1) (was: 2.5.2) > NPE: Foreign key join serd

[jira] [Resolved] (KAFKA-10605) KIP-478: deprecate the replaced Processor API members

2020-10-19 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-10605. -- Resolution: Fixed > KIP-478: deprecate the replaced Processor API members > --

[jira] [Resolved] (KAFKA-10455) Probing rebalances are not guaranteed to be triggered by non-leader members

2020-10-19 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-10455. -- Resolution: Fixed > Probing rebalances are not guaranteed to be triggered by non-leader member

[jira] [Commented] (KAFKA-10336) Rolling upgrade with Suppression may throw exceptions

2020-10-15 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17215130#comment-17215130 ] John Roesler commented on KAFKA-10336: -- Hi [~bbejeck] , sorry for the delay. I do

[jira] [Updated] (KAFKA-10336) Rolling upgrade with Suppression may throw exceptions

2020-10-15 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10336: - Priority: Critical (was: Blocker) > Rolling upgrade with Suppression may throw exceptions > ---

[jira] [Updated] (KAFKA-10336) Rolling upgrade with Suppression may throw exceptions

2020-10-15 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10336: - Fix Version/s: (was: 2.7.0) 2.8.0 > Rolling upgrade with Suppression may

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

2020-10-13 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17213535#comment-17213535 ] John Roesler commented on KAFKA-10417: -- Hi [~duvholt] , Thanks for sharing that. I

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

2020-10-13 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10417: - Fix Version/s: (was: 2.7.1) (was: 2.8.0) 2.7.0 > s

[jira] [Resolved] (KAFKA-10215) MockProcessorContext doesn't work with SessionStores

2020-10-13 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-10215. -- Resolution: Fixed Fixed in the new processor API. > MockProcessorContext doesn't work with Se

[jira] [Updated] (KAFKA-10546) KIP-478: Deprecate the old PAPI interfaces

2020-10-13 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10546: - Summary: KIP-478: Deprecate the old PAPI interfaces (was: KIP-478: Deprecate old PAPI) > KIP-4

[jira] [Updated] (KAFKA-10605) KIP-478: deprecate the replaced Processor API members

2020-10-13 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10605: - Component/s: streams > KIP-478: deprecate the replaced Processor API members > -

[jira] [Created] (KAFKA-10605) KIP-478: deprecate the replaced Processor API members

2020-10-13 Thread John Roesler (Jira)
John Roesler created KAFKA-10605: Summary: KIP-478: deprecate the replaced Processor API members Key: KAFKA-10605 URL: https://issues.apache.org/jira/browse/KAFKA-10605 Project: Kafka Issue T

[jira] [Resolved] (KAFKA-10562) KIP-478: Delegate the store wrappers to the new init method

2020-10-13 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-10562. -- Resolution: Fixed > KIP-478: Delegate the store wrappers to the new init method >

[jira] [Updated] (KAFKA-10562) KIP-478: Delegate the store wrappers to the new init method

2020-10-13 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10562: - Fix Version/s: 2.7.0 > KIP-478: Delegate the store wrappers to the new init method > ---

[jira] [Resolved] (KAFKA-10437) KIP-478: Implement test-utils changes

2020-10-13 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-10437. -- Resolution: Fixed > KIP-478: Implement test-utils changes > --

[jira] [Resolved] (KAFKA-10536) KIP-478: Implement KStream changes

2020-10-12 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-10536. -- Resolution: Fixed > KIP-478: Implement KStream changes > -- >

[jira] [Commented] (KAFKA-10536) KIP-478: Implement KStream changes

2020-10-12 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17212807#comment-17212807 ] John Roesler commented on KAFKA-10536: -- Decided to make this future work instead:

[jira] [Updated] (KAFKA-10603) Re-design KStream.process() and K*.transform*() operations

2020-10-12 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10603: - Description: After the implementation of KIP-478, we have the ability to reconsider all these A

[jira] [Updated] (KAFKA-10603) Re-design KStream.process() and K*.transform*() operations

2020-10-12 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10603: - Labels: needs-kip (was: ) > Re-design KStream.process() and K*.transform*() operations > --

[jira] [Updated] (KAFKA-10603) Re-design KStream.process() and K*.transform*() operations

2020-10-12 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10603: - Summary: Re-design KStream.process() and K*.transform*() operations (was: Re-design ) > Re-des

[jira] [Created] (KAFKA-10603) Re-design

2020-10-12 Thread John Roesler (Jira)
John Roesler created KAFKA-10603: Summary: Re-design Key: KAFKA-10603 URL: https://issues.apache.org/jira/browse/KAFKA-10603 Project: Kafka Issue Type: New Feature Reporter: John

[jira] [Resolved] (KAFKA-10598) KafkaStreams reports inappropriate error message for IQ

2020-10-12 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-10598. -- Resolution: Fixed > KafkaStreams reports inappropriate error message for IQ >

[jira] [Created] (KAFKA-10598) KafkaStreams reports inappropriate error message for IQ

2020-10-10 Thread John Roesler (Jira)
John Roesler created KAFKA-10598: Summary: KafkaStreams reports inappropriate error message for IQ Key: KAFKA-10598 URL: https://issues.apache.org/jira/browse/KAFKA-10598 Project: Kafka Issue

[jira] [Commented] (KAFKA-10215) MockProcessorContext doesn't work with SessionStores

2020-10-09 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211525#comment-17211525 ] John Roesler commented on KAFKA-10215: -- Note, this will be fixed for the new PAPI M

[jira] [Updated] (KAFKA-10215) MockProcessorContext doesn't work with SessionStores

2020-10-09 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10215: - Fix Version/s: 2.7.0 > MockProcessorContext doesn't work with SessionStores > --

[jira] [Assigned] (KAFKA-10215) MockProcessorContext doesn't work with SessionStores

2020-10-09 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-10215: Assignee: John Roesler > MockProcessorContext doesn't work with SessionStores > -

[jira] [Updated] (KAFKA-10200) MockProcessorContext doesn't work with WindowStores

2020-10-09 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10200: - Fix Version/s: 2.7.0 > MockProcessorContext doesn't work with WindowStores > ---

[jira] [Commented] (KAFKA-10200) MockProcessorContext doesn't work with WindowStores

2020-10-09 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211515#comment-17211515 ] John Roesler commented on KAFKA-10200: -- Thanks, Sophie, yes, this is done. > Mock

[jira] [Commented] (KAFKA-10515) NPE: Foreign key join serde may not be initialized with default serde if application is distributed

2020-10-09 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211170#comment-17211170 ] John Roesler commented on KAFKA-10515: -- Thanks for the patch [~thorsten.hake] ! I'l

[jira] [Updated] (KAFKA-10515) NPE: Foreign key join serde may not be initialized with default serde if application is distributed

2020-10-09 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10515: - Priority: Critical (was: Blocker) > NPE: Foreign key join serde may not be initialized with def

[jira] [Updated] (KAFKA-10437) KIP-478: Implement test-utils changes

2020-10-06 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10437: - Description: In addition to implementing the KIP, search for and resolve these todos: {color:#0

[jira] [Updated] (KAFKA-10437) KIP-478: Implement test-utils changes

2020-10-06 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10437: - Description: In addition to implementing the KIP, search for and resolve these todos: {color:#0

[jira] [Resolved] (KAFKA-10530) kafka-streams-application-reset misses some internal topics

2020-10-05 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-10530. -- Resolution: Duplicate Closing now, since this seems like a duplicate report, and visual code

[jira] [Updated] (KAFKA-10562) KIP-478: Delegate the store wrappers to the new init method

2020-10-05 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10562: - Summary: KIP-478: Delegate the store wrappers to the new init method (was: Delegate the store w

[jira] [Updated] (KAFKA-10546) KIP-478: Deprecate old PAPI

2020-10-05 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10546: - Component/s: streams > KIP-478: Deprecate old PAPI > --- > >

[jira] [Updated] (KAFKA-10544) Convert KTable aggregations to new PAPI

2020-10-05 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10544: - Component/s: streams > Convert KTable aggregations to new PAPI > ---

[jira] [Updated] (KAFKA-10562) Delegate the store wrappers to the new init method

2020-10-05 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10562: - Component/s: streams > Delegate the store wrappers to the new init method >

[jira] [Updated] (KAFKA-10539) Convert KStreamImpl joins to new PAPI

2020-10-05 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10539: - Component/s: streams > Convert KStreamImpl joins to new PAPI > -

[jira] [Updated] (KAFKA-10538) Convert KStreamImpl maps to new PAPI

2020-10-05 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10538: - Component/s: streams > Convert KStreamImpl maps to new PAPI > --

[jira] [Updated] (KAFKA-10540) Convert KStream aggregations to new PAPI

2020-10-05 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10540: - Component/s: streams > Convert KStream aggregations to new PAPI > --

[jira] [Updated] (KAFKA-10542) Convert KTable maps to new PAPI

2020-10-05 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10542: - Component/s: streams > Convert KTable maps to new PAPI > --- > >

[jira] [Updated] (KAFKA-10543) Convert KTable joins to new PAPI

2020-10-05 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10543: - Component/s: streams > Convert KTable joins to new PAPI > > >

[jira] [Updated] (KAFKA-10541) Convert KTable filters to new PAPI

2020-10-05 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10541: - Component/s: streams > Convert KTable filters to new PAPI > -- >

[jira] [Updated] (KAFKA-10537) Convert KStreamImpl filters to new PAPI

2020-10-05 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10537: - Component/s: streams > Convert KStreamImpl filters to new PAPI > ---

[jira] [Updated] (KAFKA-10536) KIP-478: Implement KStream changes

2020-10-05 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10536: - Fix Version/s: 2.7.0 > KIP-478: Implement KStream changes > -- >

[jira] [Updated] (KAFKA-10536) KIP-478: Implement KStream changes

2020-10-05 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10536: - Component/s: streams > KIP-478: Implement KStream changes > -- >

[jira] [Updated] (KAFKA-10535) KIP-478: Implement StateStoreContext and Record

2020-10-05 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10535: - Fix Version/s: 2.7.0 > KIP-478: Implement StateStoreContext and Record > ---

[jira] [Resolved] (KAFKA-10535) KIP-478: Implement StateStoreContext and Record

2020-10-05 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-10535. -- Resolution: Fixed > KIP-478: Implement StateStoreContext and Record >

[jira] [Updated] (KAFKA-10437) KIP-478: Implement test-utils changes

2020-10-05 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10437: - Fix Version/s: 2.7.0 > KIP-478: Implement test-utils changes > -

[jira] [Updated] (KAFKA-10535) KIP-478: Implement StateStoreContext and Record

2020-10-05 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10535: - Component/s: streams > KIP-478: Implement StateStoreContext and Record > ---

[jira] [Updated] (KAFKA-10437) KIP-478: Implement test-utils changes

2020-10-05 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10437: - Component/s: streams > KIP-478: Implement test-utils changes > -

[jira] [Updated] (KAFKA-10437) KIP-478: Implement test-utils changes

2020-10-05 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10437: - Component/s: (was: streams-test-utils) > KIP-478: Implement test-utils changes > ---

[jira] [Updated] (KAFKA-10437) KIP-478: Implement test-utils changes

2020-10-05 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10437: - Component/s: streams-test-utils > KIP-478: Implement test-utils changes > --

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

2020-10-05 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10436: - Component/s: streams > Implement KIP-478 Topology changes > -- >

[jira] [Created] (KAFKA-10562) Delegate the store wrappers to the new init method

2020-10-01 Thread John Roesler (Jira)
John Roesler created KAFKA-10562: Summary: Delegate the store wrappers to the new init method Key: KAFKA-10562 URL: https://issues.apache.org/jira/browse/KAFKA-10562 Project: Kafka Issue Type

[jira] [Assigned] (KAFKA-10284) Group membership update due to static member rejoin should be persisted

2020-09-30 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-10284: Assignee: feyman (was: Boyang Chen) > Group membership update due to static member rejoi

[jira] [Updated] (KAFKA-10437) KIP-478: Implement test-utils changes

2020-09-29 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10437: - Summary: KIP-478: Implement test-utils changes (was: Convert test-utils (and StateStore) for KI

[jira] [Assigned] (KAFKA-10543) Convert KTable joins to new PAPI

2020-09-29 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-10543: Assignee: John Roesler > Convert KTable joins to new PAPI > -

[jira] [Created] (KAFKA-10546) KIP-478: Deprecate old PAPI

2020-09-29 Thread John Roesler (Jira)
John Roesler created KAFKA-10546: Summary: KIP-478: Deprecate old PAPI Key: KAFKA-10546 URL: https://issues.apache.org/jira/browse/KAFKA-10546 Project: Kafka Issue Type: Sub-task

[jira] [Assigned] (KAFKA-10540) Convert KStream aggregations to new PAPI

2020-09-29 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-10540: Assignee: John Roesler > Convert KStream aggregations to new PAPI > -

[jira] [Assigned] (KAFKA-10544) Convert KTable aggregations to new PAPI

2020-09-29 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-10544: Assignee: John Roesler > Convert KTable aggregations to new PAPI > --

[jira] [Assigned] (KAFKA-10542) Convert KTable maps to new PAPI

2020-09-29 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-10542: Assignee: John Roesler > Convert KTable maps to new PAPI > --

[jira] [Created] (KAFKA-10544) Convert KTable aggregations to new PAPI

2020-09-29 Thread John Roesler (Jira)
John Roesler created KAFKA-10544: Summary: Convert KTable aggregations to new PAPI Key: KAFKA-10544 URL: https://issues.apache.org/jira/browse/KAFKA-10544 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-10542) Convert KTable maps to new PAPI

2020-09-29 Thread John Roesler (Jira)
John Roesler created KAFKA-10542: Summary: Convert KTable maps to new PAPI Key: KAFKA-10542 URL: https://issues.apache.org/jira/browse/KAFKA-10542 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-10543) Convert KTable joins to new PAPI

2020-09-29 Thread John Roesler (Jira)
John Roesler created KAFKA-10543: Summary: Convert KTable joins to new PAPI Key: KAFKA-10543 URL: https://issues.apache.org/jira/browse/KAFKA-10543 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-10541) Convert KTable filters to new PAPI

2020-09-29 Thread John Roesler (Jira)
John Roesler created KAFKA-10541: Summary: Convert KTable filters to new PAPI Key: KAFKA-10541 URL: https://issues.apache.org/jira/browse/KAFKA-10541 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-10540) Convert KStream aggregations to new PAPI

2020-09-29 Thread John Roesler (Jira)
John Roesler created KAFKA-10540: Summary: Convert KStream aggregations to new PAPI Key: KAFKA-10540 URL: https://issues.apache.org/jira/browse/KAFKA-10540 Project: Kafka Issue Type: Sub-task

[jira] [Assigned] (KAFKA-10539) Convert KStreamImpl joins to new PAPI

2020-09-29 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-10539: Assignee: John Roesler > Convert KStreamImpl joins to new PAPI >

[jira] [Created] (KAFKA-10539) Convert KStreamImpl joins to new PAPI

2020-09-29 Thread John Roesler (Jira)
John Roesler created KAFKA-10539: Summary: Convert KStreamImpl joins to new PAPI Key: KAFKA-10539 URL: https://issues.apache.org/jira/browse/KAFKA-10539 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-10538) Convert KStreamImpl maps to new PAPI

2020-09-29 Thread John Roesler (Jira)
John Roesler created KAFKA-10538: Summary: Convert KStreamImpl maps to new PAPI Key: KAFKA-10538 URL: https://issues.apache.org/jira/browse/KAFKA-10538 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-10537) Convert KStreamImpl filters to new PAPI

2020-09-29 Thread John Roesler (Jira)
John Roesler created KAFKA-10537: Summary: Convert KStreamImpl filters to new PAPI Key: KAFKA-10537 URL: https://issues.apache.org/jira/browse/KAFKA-10537 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-10536) KIP-478: Implement KStream changes

2020-09-29 Thread John Roesler (Jira)
John Roesler created KAFKA-10536: Summary: KIP-478: Implement KStream changes Key: KAFKA-10536 URL: https://issues.apache.org/jira/browse/KAFKA-10536 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-10535) KIP-478: Implement StateStoreContext and Record

2020-09-29 Thread John Roesler (Jira)
John Roesler created KAFKA-10535: Summary: KIP-478: Implement StateStoreContext and Record Key: KAFKA-10535 URL: https://issues.apache.org/jira/browse/KAFKA-10535 Project: Kafka Issue Type: S

[jira] [Updated] (KAFKA-9584) Removing headers causes ConcurrentModificationException

2020-09-29 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9584: Fix Version/s: 2.4.2 > Removing headers causes ConcurrentModificationException > --

[jira] [Commented] (KAFKA-10530) kafka-streams-application-reset misses some internal topics

2020-09-28 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203616#comment-17203616 ] John Roesler commented on KAFKA-10530: -- Thanks for the report [~oweiler] , and sorr

[jira] [Updated] (KAFKA-9584) Removing headers causes ConcurrentModificationException

2020-09-28 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9584: Fix Version/s: 2.6.1 2.5.2 2.7.0 > Removing headers causes Co

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

2020-09-28 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203430#comment-17203430 ] John Roesler commented on KAFKA-10493: -- I've marked this for 3.0 so that we could c

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

2020-09-28 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10493: - Fix Version/s: 3.0.0 > Ktable out-of-order updates are not being ignored > -

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

2020-09-28 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10493: - Priority: Critical (was: Major) > Ktable out-of-order updates are not being ignored > -

[jira] [Commented] (KAFKA-10515) NPE: Foreign key join serde may not be initialized with default serde if application is distributed

2020-09-24 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17201603#comment-17201603 ] John Roesler commented on KAFKA-10515: -- Thanks for this report, [~thorsten.hake] !

[jira] [Updated] (KAFKA-10515) NPE: Foreign key join serde may not be initialized with default serde if application is distributed

2020-09-24 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10515: - Fix Version/s: 2.6.1 2.5.2 2.7.0 > NPE: Foreign key join s

<    1   2   3   4   5   6   7   8   9   10   >