...
Code Block | ||||||
---|---|---|---|---|---|---|
| ||||||
final VersionedKeyQuery<Integer, Integer> query = VersionedKeyQuery.withKey(1).asOf(Instant.parse("2023-08-03T10:37:30.00Z"); final StateQueryRequest<ValueIterator<VersionedRecord<Integer>>> request = inStore("my_store").withQuery(query); final StateQueryResult<ValueAndTimestamp<Integer>> result = kafkaStreams.query(request); |
...