Kafka表（Ktable）中是否有基于值检索键的功能？或者是否有任何基于键和值检索数据的方法

Question

我正在做一个关于kafka流和KTable的poc。我想知道是否有任何方法在kafka中存储数据（键-值对或键-对象对），或者通过流、KTable、状态存储，这样我就可以检索基于键和值的数据库。我创建了一个基于topic的kstream，在该kstream上推送了一些消息，并使用wordcountalgo在kstream上创建的ktable中填充了值。类似这样的事情：

StoreBuilder customerStateStore = Stores.keyValueStoreBuilder(Stores.persistentKeyValueStore("customer-store"),Serdes.String(), customerSerde)
                .withLoggingEnabled(new HashMap<>());
streamsBuilder.stream("customer", Consumed.with(Serdes.String(), customerSerde)).to("customer-to-ktable-topic",Produced.with(Serdes.String(), customerSerde));
KTable<String, Customer> customerKTable = streamsBuilder.table("customer-to-ktable-topic", Consumed.with(Serdes.String(), customerSerde),Materialized.as(customerStateStore.name()));

我无法获取基于值的记录。

https://kafka.apache.org/10/javadoc/org/apache/kafka/streams/kstream/ktable.html在kafka文档中只有get（字符串键）函数可用。然而，我正在探索是否可以通过其他方式实现这一点？

Answer 1

您的CustomerStateStore是一个键值存储，如您所述，您只能基于键进行查询。

一个建议是在IN流上工作，以便将值（或值的一部分）用作存储中的键。您可以使用map()方法来完成此操作。这样做的目的可能是：

Original IN msg: key1 - value1

Would generate 2 entries in the store:
    key1 - value1
    value1 - key1 (or whatever depending on your usecase)

这样做，您将能够查询value1上的存储，因为它是一个键。（如果在in主题中，不同键的值相同，请小心。）

但是你必须小心你的输入主题的分区：一个给定的值可能会出现在你的主题的几个分区中，然后出现在你的KS应用程序的不同实例中。