我的kafka流应用程序有两个示例，在一个主题中使用两个分区。单个分区的数据是只在一个应用程序中还是在两个应用程序中？如果一个应用程序示例宕机，我就会有问题。交互式查询将如何解决这个问题？我需要使用globalktable吗？
yftpprvb1#
每个kafka流应用程序示例将Map到一个或多个分区，具体取决于输入主题有多少个分区。如果为具有2个分区的输入主题运行2个示例，则每个分区将使用一个分区。如果一个示例宕机，kafka流将重新平衡第一个示例上的工作负载，它将从两个分区中消耗。您可以在此处详细介绍体系结构：https://docs.confluent.io/current/streams/architecture.html
1条答案
按热度按时间yftpprvb1#
每个kafka流应用程序示例将Map到一个或多个分区，具体取决于输入主题有多少个分区。
如果为具有2个分区的输入主题运行2个示例，则每个分区将使用一个分区。如果一个示例宕机，kafka流将重新平衡第一个示例上的工作负载，它将从两个分区中消耗。
您可以在此处详细介绍体系结构：https://docs.confluent.io/current/streams/architecture.html