我正在使用 kafka 处理器 api，并从 3 个分区的主题（我有 3 个代理）创建一个状态存储，我有 1 个流实例。我想知道我什么时候能拿到当地的州立商店，我能拿到所有的钥匙吗？为什么某些键有效但某些无效？正常吗？ 谢谢
【问题讨论】：
标签： apache-kafka kafka-consumer-api apache-kafka-streams
应用程序实例的数量对于这种情况无关紧要。因为输入主题有 3 个分区，所以使用 3 个分片创建状态存储。处理发生在 3 个并行任务中。每个任务都会实例化您的拓扑副本，处理一个输入主题分区，并使用一个分片。
比较：https://kafka.apache.org/21/documentation/streams/architecture
如果您想访问不同的分片，您可以使用“交互式查询”功能对所有分片进行键/值查找（以及查询的键范围）。
此外，还有全局状态存储的概念，它将所有分区中的数据加载到单个存储中（不是分片）。但是，与“常规”存储相比，它提供了不同的语义，因为存储更新与其他处理没有时间同步。
【讨论】：
application.id 的new KafkaStreams()）。请注意，每个实例的线程数也很重要。您不能拥有比输入主题分区（所有实例的所有线程的总和）更多的线程，因为一个主题分区只能由单个线程处理。所有其他线程将处于空闲状态，不处理任何数据。