[jira] [Commented] (KAFKA-15768) StateQueryResult#getOnlyPartitionResult should not throw for FailedQueryResult

2023-11-28 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17790603#comment-17790603 ] John Roesler commented on KAFKA-15768: -- Hey [~hanyuzheng] , thanks for the bug report! I agree

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

2023-06-07 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13531: - Attachment:

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

2023-06-07 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17730190#comment-17730190 ] John Roesler commented on KAFKA-13531: -- Seen again while verifying the 3.5.0 release artifacts

[jira] [Updated] (KAFKA-14995) Automate asf.yaml collaborators refresh

2023-05-12 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-14995: - Labels: newbie (was: ) > Automate asf.yaml collaborators refresh >

[jira] [Created] (KAFKA-14995) Automate asf.yaml collaborators refresh

2023-05-12 Thread John Roesler (Jira)
John Roesler created KAFKA-14995: Summary: Automate asf.yaml collaborators refresh Key: KAFKA-14995 URL: https://issues.apache.org/jira/browse/KAFKA-14995 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-14364) Support evolving serde with Foreign Key Join

2022-11-07 Thread John Roesler (Jira)
John Roesler created KAFKA-14364: Summary: Support evolving serde with Foreign Key Join Key: KAFKA-14364 URL: https://issues.apache.org/jira/browse/KAFKA-14364 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-14254) Format timestamps in assignor logs as dates instead of integers

2022-09-21 Thread John Roesler (Jira)
John Roesler created KAFKA-14254: Summary: Format timestamps in assignor logs as dates instead of integers Key: KAFKA-14254 URL: https://issues.apache.org/jira/browse/KAFKA-14254 Project: Kafka

[jira] [Updated] (KAFKA-14254) Format timestamps in assignor logs as dates instead of integers

2022-09-21 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-14254: - Labels: newbie newbie++ (was: ) > Format timestamps in assignor logs as dates instead of

[jira] [Updated] (KAFKA-14253) StreamsPartitionAssignor should print the member count in assignment logs

2022-09-21 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-14253: - Labels: newbie newbie++ (was: newbie++) > StreamsPartitionAssignor should print the member

[jira] [Updated] (KAFKA-14253) StreamsPartitionAssignor should print the member count in assignment logs

2022-09-21 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-14253: - Labels: newbie++ (was: ) > StreamsPartitionAssignor should print the member count in

[jira] [Created] (KAFKA-14253) StreamsPartitionAssignor should print the member count in assignment logs

2022-09-21 Thread John Roesler (Jira)
John Roesler created KAFKA-14253: Summary: StreamsPartitionAssignor should print the member count in assignment logs Key: KAFKA-14253 URL: https://issues.apache.org/jira/browse/KAFKA-14253 Project:

[jira] [Created] (KAFKA-14202) IQv2: Expose binary store schema to store implementations

2022-09-06 Thread John Roesler (Jira)
John Roesler created KAFKA-14202: Summary: IQv2: Expose binary store schema to store implementations Key: KAFKA-14202 URL: https://issues.apache.org/jira/browse/KAFKA-14202 Project: Kafka

[jira] [Commented] (KAFKA-13978) Trigger UncaughtExceptionHandler for IllegalArgument and IllegalState exceptions

2022-08-10 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17578023#comment-17578023 ] John Roesler commented on KAFKA-13978: -- Hey [~bryves]  , I just checked trunk and 3.3, and I don't

[jira] [Commented] (KAFKA-14020) Performance regression in Producer

2022-07-12 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17566017#comment-17566017 ] John Roesler commented on KAFKA-14020: -- Hey [~alivshits] , thanks for your work on

[jira] [Commented] (KAFKA-14020) Performance regression in Producer

2022-06-25 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17558796#comment-17558796 ] John Roesler commented on KAFKA-14020: -- {color:#1d1c1d}FYI, just setting the partitioner back to

[jira] [Created] (KAFKA-14020) Performance regression in Producer

2022-06-24 Thread John Roesler (Jira)
John Roesler created KAFKA-14020: Summary: Performance regression in Producer Key: KAFKA-14020 URL: https://issues.apache.org/jira/browse/KAFKA-14020 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-13654) Extend KStream process with new Processor API

2022-04-19 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-13654. -- Fix Version/s: 3.3.0 Resolution: Fixed > Extend KStream process with new Processor API

[jira] [Assigned] (KAFKA-13654) Extend KStream process with new Processor API

2022-04-19 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-13654: Assignee: Jorge Esteban Quilcate Otoya > Extend KStream process with new Processor API >

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

2022-04-11 Thread John Roesler (Jira)
John Roesler created KAFKA-13820: Summary: Add debug-level logs to explain why a store is filtered out during interactive query Key: KAFKA-13820 URL: https://issues.apache.org/jira/browse/KAFKA-13820

[jira] [Updated] (KAFKA-13819) Add application.server to Streams assignor logs when set

2022-04-11 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13819: - Component/s: streams > Add application.server to Streams assignor logs when set >

[jira] [Updated] (KAFKA-13818) Add generation to consumer assignor logs

2022-04-11 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13818: - Component/s: consumer > Add generation to consumer assignor logs >

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

2022-04-11 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13820: - Component/s: streams > Add debug-level logs to explain why a store is filtered out during >

[jira] [Created] (KAFKA-13819) Add application.server to Streams assignor logs when set

2022-04-11 Thread John Roesler (Jira)
John Roesler created KAFKA-13819: Summary: Add application.server to Streams assignor logs when set Key: KAFKA-13819 URL: https://issues.apache.org/jira/browse/KAFKA-13819 Project: Kafka

[jira] [Created] (KAFKA-13818) Add generation to consumer assignor logs

2022-04-11 Thread John Roesler (Jira)
John Roesler created KAFKA-13818: Summary: Add generation to consumer assignor logs Key: KAFKA-13818 URL: https://issues.apache.org/jira/browse/KAFKA-13818 Project: Kafka Issue Type:

[jira] [Assigned] (KAFKA-13818) Add generation to consumer assignor logs

2022-04-11 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-13818: Assignee: John Roesler > Add generation to consumer assignor logs >

[jira] [Resolved] (KAFKA-13479) Interactive Query v2

2022-04-06 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-13479. -- Fix Version/s: 3.2.0 Resolution: Fixed > Interactive Query v2 > >

[jira] [Closed] (KAFKA-13479) Interactive Query v2

2022-04-06 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler closed KAFKA-13479. > Interactive Query v2 > > > Key: KAFKA-13479 >

[jira] [Updated] (KAFKA-13622) Revisit the complexity of position tracking in state stores

2022-04-06 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13622: - Parent: (was: KAFKA-13479) Issue Type: Improvement (was: Sub-task) > Revisit the

[jira] [Updated] (KAFKA-13548) IQv2: revisit WindowKeyQuery and WindowRangeQuery

2022-04-06 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13548: - Parent: (was: KAFKA-13479) Issue Type: Improvement (was: Sub-task) > IQv2: revisit

[jira] [Updated] (KAFKA-13622) Revisit the complexity of position tracking in state stores

2022-04-06 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13622: - Labels: IQv2 (was: ) > Revisit the complexity of position tracking in state stores >

[jira] [Updated] (KAFKA-13622) Revisit the complexity of position tracking in state stores

2022-04-06 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13622: - Component/s: streams > Revisit the complexity of position tracking in state stores >

[jira] [Updated] (KAFKA-13548) IQv2: revisit WindowKeyQuery and WindowRangeQuery

2022-04-06 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13548: - Component/s: streams > IQv2: revisit WindowKeyQuery and WindowRangeQuery >

[jira] [Updated] (KAFKA-13541) Make IQv2 query/store interface type safe

2022-04-06 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13541: - Parent: (was: KAFKA-13479) Issue Type: Improvement (was: Sub-task) > Make IQv2

[jira] [Updated] (KAFKA-13548) IQv2: revisit WindowKeyQuery and WindowRangeQuery

2022-04-06 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13548: - Labels: IQv2 (was: ) > IQv2: revisit WindowKeyQuery and WindowRangeQuery >

[jira] [Commented] (KAFKA-13479) Interactive Query v2

2022-04-06 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17518567#comment-17518567 ] John Roesler commented on KAFKA-13479: -- Sorry about that, [~cadonna] . I'll do it now. All the

[jira] [Updated] (KAFKA-13541) Make IQv2 query/store interface type safe

2022-04-06 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13541: - Component/s: streams > Make IQv2 query/store interface type safe >

[jira] [Updated] (KAFKA-13541) Make IQv2 query/store interface type safe

2022-04-06 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13541: - Labels: IQv2 (was: ) > Make IQv2 query/store interface type safe >

[jira] [Updated] (KAFKA-13526) IQv2: Consider more generic logic for mapping between binary and typed queries

2022-04-06 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13526: - Labels: IQv2 (was: ) > IQv2: Consider more generic logic for mapping between binary and typed

[jira] [Updated] (KAFKA-13526) IQv2: Consider more generic logic for mapping between binary and typed queries

2022-04-06 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13526: - Parent: (was: KAFKA-13479) Issue Type: Improvement (was: Sub-task) > IQv2:

[jira] [Updated] (KAFKA-13526) IQv2: Consider more generic logic for mapping between binary and typed queries

2022-04-06 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13526: - Component/s: streams > IQv2: Consider more generic logic for mapping between binary and typed

[jira] [Updated] (KAFKA-13523) Implement IQv2 support in global stores

2022-04-06 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13523: - Priority: Major (was: Blocker) > Implement IQv2 support in global stores >

[jira] [Updated] (KAFKA-13523) Implement IQv2 support in global stores

2022-04-06 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13523: - Affects Version/s: (was: 3.2.0) > Implement IQv2 support in global stores >

[jira] [Updated] (KAFKA-13523) Implement IQv2 support in global stores

2022-04-06 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13523: - Component/s: streams > Implement IQv2 support in global stores >

[jira] [Updated] (KAFKA-13523) Implement IQv2 support in global stores

2022-04-06 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13523: - Parent: (was: KAFKA-13479) Issue Type: Improvement (was: Sub-task) > Implement

[jira] [Updated] (KAFKA-13523) Implement IQv2 support in global stores

2022-04-06 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13523: - Labels: IQv2 (was: ) > Implement IQv2 support in global stores >

[jira] [Resolved] (KAFKA-13554) Rename RangeQuery to KeyRangeQuery

2022-03-24 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-13554. -- Resolution: Won't Fix > Rename RangeQuery to KeyRangeQuery >

[jira] [Closed] (KAFKA-13554) Rename RangeQuery to KeyRangeQuery

2022-03-24 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler closed KAFKA-13554. > Rename RangeQuery to KeyRangeQuery > -- > > Key:

[jira] [Commented] (KAFKA-13554) Rename RangeQuery to KeyRangeQuery

2022-03-24 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17512096#comment-17512096 ] John Roesler commented on KAFKA-13554: -- I thought that I filed this because it had been insisted

[jira] [Updated] (KAFKA-13554) Rename RangeQuery to KeyRangeQuery

2022-03-24 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13554: - Affects Version/s: (was: 3.2.0) > Rename RangeQuery to KeyRangeQuery >

[jira] [Updated] (KAFKA-13554) Rename RangeQuery to KeyRangeQuery

2022-03-24 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13554: - Priority: Minor (was: Blocker) > Rename RangeQuery to KeyRangeQuery >

[jira] [Updated] (KAFKA-13622) Revisit the complexity of position tracking in state stores

2022-03-24 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13622: - Priority: Minor (was: Blocker) > Revisit the complexity of position tracking in state stores >

[jira] [Updated] (KAFKA-13622) Revisit the complexity of position tracking in state stores

2022-03-24 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13622: - Affects Version/s: (was: 3.2.0) > Revisit the complexity of position tracking in state

[jira] [Updated] (KAFKA-13541) Make IQv2 query/store interface type safe

2022-03-24 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13541: - Affects Version/s: (was: 3.2.0) > Make IQv2 query/store interface type safe >

[jira] [Assigned] (KAFKA-13554) Rename RangeQuery to KeyRangeQuery

2022-03-24 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-13554: Assignee: John Roesler (was: Vicky Papavasileiou) > Rename RangeQuery to KeyRangeQuery

[jira] [Updated] (KAFKA-13541) Make IQv2 query/store interface type safe

2022-03-24 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13541: - Priority: Minor (was: Blocker) > Make IQv2 query/store interface type safe >

[jira] [Updated] (KAFKA-13526) IQv2: Consider more generic logic for mapping between binary and typed queries

2022-03-24 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13526: - Priority: Minor (was: Blocker) > IQv2: Consider more generic logic for mapping between binary

[jira] [Updated] (KAFKA-13526) IQv2: Consider more generic logic for mapping between binary and typed queries

2022-03-24 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13526: - Affects Version/s: (was: 3.2.0) > IQv2: Consider more generic logic for mapping between

[jira] [Updated] (KAFKA-13548) IQv2: revisit WindowKeyQuery and WindowRangeQuery

2022-03-24 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13548: - Priority: Minor (was: Blocker) > IQv2: revisit WindowKeyQuery and WindowRangeQuery >

[jira] [Updated] (KAFKA-13548) IQv2: revisit WindowKeyQuery and WindowRangeQuery

2022-03-24 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13548: - Affects Version/s: (was: 3.2.0) > IQv2: revisit WindowKeyQuery and WindowRangeQuery >

[jira] [Updated] (KAFKA-13479) Interactive Query v2

2022-03-24 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13479: - Fix Version/s: (was: 3.2.0) > Interactive Query v2 > > >

[jira] [Resolved] (KAFKA-13714) Flaky test IQv2StoreIntegrationTest

2022-03-23 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-13714. -- Fix Version/s: 3.2.0 Assignee: John Roesler Resolution: Fixed > Flaky test

[jira] [Commented] (KAFKA-13714) Flaky test IQv2StoreIntegrationTest

2022-03-20 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509543#comment-17509543 ] John Roesler commented on KAFKA-13714: -- Oh, before I forget, here's how I'm getting repros:

[jira] [Commented] (KAFKA-13714) Flaky test IQv2StoreIntegrationTest

2022-03-20 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509541#comment-17509541 ] John Roesler commented on KAFKA-13714: -- Added some more logs, and I think I'm onto something

[jira] [Commented] (KAFKA-13714) Flaky test IQv2StoreIntegrationTest

2022-03-20 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509379#comment-17509379 ] John Roesler commented on KAFKA-13714: -- Another: {code:java} verifyStore[cache=true, log=true,

[jira] [Commented] (KAFKA-13714) Flaky test IQv2StoreIntegrationTest

2022-03-19 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509366#comment-17509366 ] John Roesler commented on KAFKA-13714: -- Continuing debugging: h3. verifyStore[cache=true, log=true,

[jira] [Comment Edited] (KAFKA-13714) Flaky test IQv2StoreIntegrationTest

2022-03-17 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17508386#comment-17508386 ] John Roesler edited comment on KAFKA-13714 at 3/17/22, 7:32 PM: Another

[jira] [Commented] (KAFKA-13714) Flaky test IQv2StoreIntegrationTest

2022-03-17 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17508386#comment-17508386 ] John Roesler commented on KAFKA-13714: -- Another local repro:   {code:java}

[jira] [Created] (KAFKA-13714) Flaky test IQv2StoreIntegrationTest

2022-03-07 Thread John Roesler (Jira)
John Roesler created KAFKA-13714: Summary: Flaky test IQv2StoreIntegrationTest Key: KAFKA-13714 URL: https://issues.apache.org/jira/browse/KAFKA-13714 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-13600) Rebalances while streams is in degraded state can cause stores to be reassigned and restore from scratch

2022-02-03 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17486714#comment-17486714 ] John Roesler commented on KAFKA-13600: -- Hi [~tim.patterson] , thanks for the report and the patch!

[jira] [Assigned] (KAFKA-13600) Rebalances while streams is in degraded state can cause stores to be reassigned and restore from scratch

2022-02-03 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-13600: Assignee: (was: John Roesler) > Rebalances while streams is in degraded state can

[jira] [Assigned] (KAFKA-13600) Rebalances while streams is in degraded state can cause stores to be reassigned and restore from scratch

2022-02-03 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-13600: Assignee: John Roesler > Rebalances while streams is in degraded state can cause stores

[jira] [Updated] (KAFKA-13600) Rebalances while streams is in degraded state can cause stores to be reassigned and restore from scratch

2022-02-03 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13600: - Affects Version/s: 3.1.0 > Rebalances while streams is in degraded state can cause stores to be

[jira] [Updated] (KAFKA-13523) Implement IQv2 support in global stores

2022-01-26 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13523: - Affects Version/s: 3.2.0 > Implement IQv2 support in global stores >

[jira] [Updated] (KAFKA-13526) IQv2: Consider more generic logic for mapping between binary and typed queries

2022-01-26 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13526: - Priority: Blocker (was: Major) > IQv2: Consider more generic logic for mapping between binary

[jira] [Updated] (KAFKA-13548) IQv2: revisit WindowKeyQuery and WindowRangeQuery

2022-01-26 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13548: - Priority: Blocker (was: Major) > IQv2: revisit WindowKeyQuery and WindowRangeQuery >

[jira] [Updated] (KAFKA-13622) Revisit the complexity of position tracking in state stores

2022-01-26 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13622: - Affects Version/s: 3.2.0 > Revisit the complexity of position tracking in state stores >

[jira] [Updated] (KAFKA-13541) Make IQv2 query/store interface type safe

2022-01-26 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13541: - Affects Version/s: 3.2.0 > Make IQv2 query/store interface type safe >

[jira] [Updated] (KAFKA-13541) Make IQv2 query/store interface type safe

2022-01-26 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13541: - Priority: Blocker (was: Major) > Make IQv2 query/store interface type safe >

[jira] [Updated] (KAFKA-13523) Implement IQv2 support in global stores

2022-01-26 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13523: - Priority: Blocker (was: Major) > Implement IQv2 support in global stores >

[jira] [Updated] (KAFKA-13548) IQv2: revisit WindowKeyQuery and WindowRangeQuery

2022-01-26 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13548: - Affects Version/s: 3.2.0 > IQv2: revisit WindowKeyQuery and WindowRangeQuery >

[jira] [Updated] (KAFKA-13526) IQv2: Consider more generic logic for mapping between binary and typed queries

2022-01-26 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13526: - Affects Version/s: 3.2.0 > IQv2: Consider more generic logic for mapping between binary and

[jira] [Updated] (KAFKA-13554) Rename RangeQuery to KeyRangeQuery

2022-01-26 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13554: - Affects Version/s: 3.2.0 > Rename RangeQuery to KeyRangeQuery >

[jira] [Updated] (KAFKA-13554) Rename RangeQuery to KeyRangeQuery

2022-01-26 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13554: - Priority: Blocker (was: Major) > Rename RangeQuery to KeyRangeQuery >

[jira] [Updated] (KAFKA-13622) Revisit the complexity of position tracking in state stores

2022-01-26 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13622: - Priority: Blocker (was: Major) > Revisit the complexity of position tracking in state stores >

[jira] [Created] (KAFKA-13622) Revisit the complexity of position tracking in state stores

2022-01-26 Thread John Roesler (Jira)
John Roesler created KAFKA-13622: Summary: Revisit the complexity of position tracking in state stores Key: KAFKA-13622 URL: https://issues.apache.org/jira/browse/KAFKA-13622 Project: Kafka

[jira] [Resolved] (KAFKA-13608) Implement Position restoration for all in-memory state stores

2022-01-26 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-13608. -- Resolution: Duplicate > Implement Position restoration for all in-memory state stores >

[jira] [Commented] (KAFKA-13608) Implement Position restoration for all in-memory state stores

2022-01-26 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17482866#comment-17482866 ] John Roesler commented on KAFKA-13608: -- Ah, I didn't realize there was a ticket for this. I just

[jira] [Resolved] (KAFKA-13524) IQv2: Implement KeyQuery from the RecordCache

2022-01-26 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-13524. -- Resolution: Fixed > IQv2: Implement KeyQuery from the RecordCache >

[jira] [Assigned] (KAFKA-13524) IQv2: Implement KeyQuery from the RecordCache

2022-01-26 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-13524: Assignee: Vicky Papavasileiou > IQv2: Implement KeyQuery from the RecordCache >

[jira] [Updated] (KAFKA-13605) Checkpoint position in state stores

2022-01-26 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13605: - Parent: KAFKA-13479 Issue Type: Sub-task (was: Improvement) > Checkpoint position in

[jira] [Updated] (KAFKA-13524) IQv2: Implement KeyQuery from the RecordCache

2021-12-28 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13524: - Description: The Record Cache in Kafka Streams is more properly termed a write buffer, since

[jira] [Updated] (KAFKA-13524) IQv2: Add option for KeyQuery from the RecordCache

2021-12-28 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13524: - Summary: IQv2: Add option for KeyQuery from the RecordCache (was: IQv2: Add option for

[jira] [Updated] (KAFKA-13524) IQv2: Add option for KeyQuery from caches

2021-12-28 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13524: - Summary: IQv2: Add option for KeyQuery from caches (was: IQv2: Add option to query KV Stores

[jira] [Updated] (KAFKA-13524) IQv2: Implement KeyQuery from the RecordCache

2021-12-28 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13524: - Summary: IQv2: Implement KeyQuery from the RecordCache (was: IQv2: Add option for KeyQuery

[jira] [Updated] (KAFKA-13524) IQv2: Add option for KeyQuery from caches

2021-12-28 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13524: - Description: I did a quick POC of this:

[jira] [Updated] (KAFKA-13524) IQv2: Add option to query KV Stores from caches

2021-12-27 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13524: - Description: I did a quick POC of this:

[jira] [Updated] (KAFKA-13524) IQv2: Add option to query KV Stores from caches

2021-12-27 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13524: - Summary: IQv2: Add option to query KV Stores from caches (was: IQv2: Add option to query from

[jira] [Updated] (KAFKA-13553) Add PAPI stores to IQv2StoreIntegrationTest

2021-12-27 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13553: - Summary: Add PAPI stores to IQv2StoreIntegrationTest (was: Add DSL stores to

[jira] [Assigned] (KAFKA-13553) Add PAPI stores to IQv2StoreIntegrationTest

2021-12-27 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-13553: Assignee: John Roesler > Add PAPI stores to IQv2StoreIntegrationTest >

[jira] [Assigned] (KAFKA-13554) Rename RangeQuery to KeyRangeQuery

2021-12-27 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-13554: Assignee: Vicky Papavasileiou > Rename RangeQuery to KeyRangeQuery >

  1   2   3   4   5   6   7   8   9   10   >