cadonna commented on a change in pull request #9508:
URL: https://github.com/apache/kafka/pull/9508#discussion_r568508079
##########
File path:
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStoreTest.java
##########
@@ -434,6 +435,22 @@ public void
shouldRemoveMetricsEvenIfWrappedStoreThrowsOnClose() {
verify(inner);
}
+ @Test
+ public void shouldGetRecordsWithPrefixKey() {
+ final StringSerializer stringSerializer = new StringSerializer();
+ expect(inner.prefixScan(KEY, stringSerializer))
+ .andReturn(new
KeyValueIteratorStub<>(Collections.singletonList(BYTE_KEY_VALUE_PAIR).iterator()));
+ init();
+
+ final KeyValueIterator<String, String> iterator =
metered.prefixScan(KEY, stringSerializer);
+ assertThat(iterator.next().value, equalTo(VALUE));
+ iterator.close();
+
+ final KafkaMetric metric = metric("prefix-scan-rate");
Review comment:
To get rid of the test failure, you need to change this:
```suggestion
final KafkaMetric metric = metrics.metric(new
MetricName("prefix-scan-rate", STORE_LEVEL_GROUP, "", tags));
```
Sorry, the failure of the test is my bad. I missed the issue with the
different metrics versions when I requested to change this in a previous review.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
