THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
final MultiVersionedKeyQuery<Integer, Integer> queryquery1 = MultiVersionedKeyQuery.withKey(1).from(Instant.parse("2023-08-03T10:37:30.00Z")); final StateQueryRequest<ValueIterator<VersionedRecord<Integer>>> requestrequest1 = inStore("my_store").withQuery(queryquery1); final StateQueryResult<ValueIterator<VersionedRecord<Integer>>> versionedKeyResultversionedKeyResult1 = kafkaStreams.query(requestrequest1); // Get the results from all partitions. final Map<Integer, QueryResult<ValueIterator<VersionedRecord<Integer>>>> partitionResultspartitionResults1 = versionedKeyResultversionedKeyResult1.getPartitionResults(); for (final Entry<Integer, QueryResult<ValueIterator<VersionedRecord<Integer>>>> entry : partitionResultspartitionResults1.entrySet()) { try (final ValueIterator<VersionedRecord<Integer>> iterator = entry.getValue().getResult()) { while (iterator.hasNext()) { final VersionedRecord<Integer> record = iterator.next(); Long timestamp = record.timestamp(); Integer value = record.value(); } } } final MultiVersionedKeyQuery<Integer, Integer> query = MultiVersionedKeyQuery.withKey(1).from(Instant.parse("2023-08-03T10:37:30.00Z")); |
Compatibility, Deprecation, and Migration Plan
...