自动部署Kafka流应用程序



我只是从kafka和kafka流媒体应用程序开始。我写了一个kafka流应用程序,该应用程序从一个主题中消耗,处理此消息并将其发送到另一个主题。

据我所知,我发现运行此Kafka流应用程序的唯一方法是:

  • 从IDE运行Java类。
  • 生成*.jar文件并从提示中运行。

我想知道是否有任何方法可以自动运行KAFKA Server启动上的Kafka流媒体应用程序。例如:将*.jar文件复制到我的Kafka安装的某些文件夹,并在启动KAFKA服务器时自动运行此流应用程序。

您的Kafka Broker(Server)和您的Kafka Streams应用程序彼此独立。您可以在服务器上管理流程,无论是Initd还是Systemd,还是基于容器的解决方案,例如Docker或Kubernetes。

根据我的经验,如果您的流应用程序在经纪人或Zookeeper之前就开始了,那么它可能很想等待它们上网。因此,您可能需要在这种情况下配置流程以重新启动。

相关内容

  • 没有找到相关文章

最新更新