apache-kafka - 如何从 KTable 中获取排序后的 KeyValueStore？

Question

我想从 KStream 中具体化一个 KTable，并且希望 KeyValueStore 按 Key 排序。

我尝试查找 KTable API 规范 ( https://kafka.apache.org/20/javadoc/org/apache/kafka/streams/kstream/KTable.html )，但不存在“排序”方法。我还查阅了这篇文章 ( https://dzone.com/articles/how-to-order-streamed-dataframes )，建议通过处理器 API 实现排序。但是，我正在检查是否可以通过其他方式实现这一点？

Answer 1

KafkaStream 允许您物化可查询状态存储。然后，您可以通过调用方法 kafkaStream#store() 获得对存储的只读访问权限。

如果您定义持久存储，KafkaStreams 将使用 RocksDB 来存储您的数据。返回的 KeyValueIterator 实例将使用 RocksDB 迭代器，它允许您以排序的方式迭代键值 Rocks Iterator-Implementation .

示例:

    KafkaStreams streams = new KafkaStreams(topology, props);
    ReadOnlyKeyValueStore<Object, Object> store = streams.store("storeName", QueryableStoreTypes.keyValueStore());
    KeyValueIterator<Object, Object> iterator = store.all();