Skip to content

KAFKA-12289: Adding test cases for prefix scan in InMemoryKeyValueStore#10052

Merged
guozhangwang merged 3 commits intoapache:trunkfrom
vamossagar12:KAFKA-12289
Mar 2, 2021
Merged

KAFKA-12289: Adding test cases for prefix scan in InMemoryKeyValueStore#10052
guozhangwang merged 3 commits intoapache:trunkfrom
vamossagar12:KAFKA-12289

Conversation

@vamossagar12
Copy link
Copy Markdown
Contributor

More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.

Summary of testing strategy (including rationale)
for the feature or bug fix. Unit and/or integration
tests are expected for any behaviour change and
system tests should be considered for larger changes.

Committer Checklist (excluded from commit message)

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

@vamossagar12
Copy link
Copy Markdown
Contributor Author

@cadonna , As discussed, i have added the test cases by adding store with key as Bytes. Also, have added the warning with the example in the javadocs for prefixScan()

Copy link
Copy Markdown
Member

@cadonna cadonna left a comment

Choose a reason for hiding this comment

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

@vamossagar12 Thanks for the update!

Here my comments.

Comment thread streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyKeyValueStore.java Outdated
vamossagar12 and others added 2 commits February 25, 2021 12:23
…eyValueStore.java

Co-authored-by: Bruno Cadonna <bruno@confluent.io>
…/InMemoryKeyValueStoreTest.java

Co-authored-by: Bruno Cadonna <bruno@confluent.io>
@vamossagar12
Copy link
Copy Markdown
Contributor Author

Thanks @cadonna , i have committed your suggestions.

Copy link
Copy Markdown
Member

@cadonna cadonna left a comment

Choose a reason for hiding this comment

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

Thanks, @vamossagar12 !

LGTM!

@cadonna
Copy link
Copy Markdown
Member

cadonna commented Feb 25, 2021

Call for committer approval: @guozhangwang @ableegoldman @mjsax @vvcephei @abbccdda

@guozhangwang guozhangwang merged commit b2075a0 into apache:trunk Mar 2, 2021
@guozhangwang
Copy link
Copy Markdown
Contributor

LGTM. Thanks for the contribution @vamossagar12 !

guozhangwang pushed a commit that referenced this pull request Mar 2, 2021
…re (#10052)

Co-authored-by: Bruno Cadonna <bruno@confluent.io>

Reviewers: Bruno Cadonna <cadonna@confluent.io>, Guozhang Wang <guozhang@confluent.io>
@guozhangwang
Copy link
Copy Markdown
Contributor

Cherry-picked to 2.8 as well cc @vvcephei

ijuma added a commit to ijuma/kafka that referenced this pull request Mar 2, 2021
* apache-github/trunk: (37 commits)
  KAFKA-10357: Extract setup of changelog from Streams partition assignor (apache#10163)
  KAFKA-10251: increase timeout for consuming records (apache#10228)
  KAFKA-12394; Return `TOPIC_AUTHORIZATION_FAILED` in delete topic response if no describe permission (apache#10223)
  MINOR: Disable transactional/idempotent system tests for Raft quorums (apache#10224)
  KAFKA-10766: Unit test cases for RocksDBRangeIterator (apache#9717)
  KAFKA-12289: Adding test cases for prefix scan in InMemoryKeyValueStore (apache#10052)
  KAFKA-12268: Implement task idling semantics via currentLag API (apache#10137)
  MINOR: Time and log producer state recovery phases (apache#10241)
  MINOR: correct the error message of validating uint32 (apache#10193)
  MINOR: Format the revoking active log output in `StreamsPartitionAssignor` (apache#10242)
  KAFKA-12323 Follow-up: Refactor the unit test a bit (apache#10205)
  MINOR: Remove stack trace of the lock exception in a debug log4j (apache#10231)
  MINOR: Word count should account for extra whitespaces between words (apache#10229)
  MINOR; Small refactor in `GroupMetadata` (apache#10236)
  KAFKA-10340: Proactively close producer when cancelling source tasks (apache#10016)
  KAFKA-12329; kafka-reassign-partitions command should give a better error message when a topic does not exist (apache#10141)
  KAFKA-12254: Ensure MM2 creates topics with source topic configs (apache#10217)
  MINOR: fix kafka-metadata-shell.sh (apache#10226)
  KAFKA-12374: Add missing config sasl.mechanism.controller.protocol (apache#10199)
  KAFKA-10101: Fix edge cases in Log.recoverLog and LogManager.loadLogs (apache#8812)
  ...
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.

4 participants