java - java中的Kafka消息传递和GUI数据交换

Question

我有一个应用程序需要使用 Kafka 作为消息传递系统。我还有一个接受用户输入的 GUI。该应用程序设置为在接收到来自该主题的消息时启动繁重的处理。大部分数据来自消息，但我需要以用户输入信息的形式获取信息以设置默认值。我必须使用 Java 8，这是一个 Java 核心应用程序。我有一个继承的 Java Swing UI，并且不打算从头开始构建新的 UI。我还想在完成后在 GUI 中显示繁重的运算结果。

我正在使用 Kafka 流 API 来获取消息，使用 flatMapValue 来结束处理并将结果返回到另一个主题。

如何从文本字段中获取信息以传递给我的运算块？如何将结果返回到要显示的 GUI？

标签： javaswingapache-kafkaconcurrency

Answer 1

我解决了我的问题。它比我尝试做的要简单得多。我能够使用动作侦听器从 GUI 传递数据，并使用静态变量和 invokeLater 在 GUI 中获取内容。