Skip to content

KAFKA-5876: Apply UnknownStateStoreException for Interactive Queries#9069

Closed
vitojeng wants to merge 1 commit intoapache:trunkfrom
vitojeng:5876-unknown-statestore
Closed

KAFKA-5876: Apply UnknownStateStoreException for Interactive Queries#9069
vitojeng wants to merge 1 commit intoapache:trunkfrom
vitojeng:5876-unknown-statestore

Conversation

@vitojeng
Copy link
Copy Markdown
Contributor

follow-up #8200

KAFKA-5876's PR break into multiple parts, this PR is part 2: apply UnknownStateStoreException

Committer Checklist (excluded from commit message)

  • Verify design and implementation
  • Verify test coverage and CI build status
  • Verify documentation (including upgrade notes)

@vitojeng vitojeng force-pushed the 5876-unknown-statestore branch from 422f6dc to c2dd4cc Compare July 24, 2020 00:10
streams.queryMetadataForKey("store", "key", (topic, key, value, numPartitions) -> 0);
}

@Test(expected = UnknownStateStoreException.class)
Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I am not sure if using annotation is a good choice. Would it be better to use assertThrows ?

@vitojeng vitojeng closed this Jan 4, 2021
@vitojeng vitojeng deleted the 5876-unknown-statestore branch May 11, 2021 05:49
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant