从应用程序外部查询 Kafka KTable答案

【问题标题】：Query the Kafka KTable from out side the Application从应用程序外部查询 Kafka KTable
【发布时间】：2018-04-16 08:43:32
【问题描述】：

我的情况是在 Kafka 集群中运行 5 个流应用程序，并且所有应用程序每个都有一个最终输出的 Kafka 主题。现在我需要编写一些 REST 服务来访问应用程序之外的最终 KTables。我可以运行这个application，但它需要创建一个流应用程序来访问最终输出主题。有没有办法在外部休息应用程序中访问这些状态存储？

【问题讨论】：

您所说的“是否有任何可能的方式来访问流应用程序本身？”是什么意思？ ?
@ArturBiesiadowski 我已经改变了问题。我正在考虑创建一些可以访问此应用程序状态存储并从中查询的休息服务
我是否正确理解您想直接从 kafka 代理访问 KTable 之类的东西，而无需先将所有数据流式传输到本地内存？
@ArturBiesiadowski 是的...我正在尝试编写该服务

标签： java rest apache-kafka apache-kafka-streams

【解决方案1】：

目前没有直接的方法来访问外部应用程序中的状态存储。

状态存储建立在更改日志主题之上，因此您可以在外部应用程序中使用更改日志主题以压缩方式获得状态存储的味道。

另一个可能的选择是实现您自己的自定义外部存储。

【讨论】：