我只是从kafka和kafka流媒体应用程序开始。我写了一个kafka流应用程序,该应用程序从一个主题中消耗,处理此消息并将其发送到另一个主题。
据我所知,我发现运行此Kafka流应用程序的唯一方法是:
- 从IDE运行Java类。
- 生成
*.jar
文件并从提示中运行。
我想知道是否有任何方法可以自动运行KAFKA Server启动上的Kafka流媒体应用程序。例如:将*.jar
文件复制到我的Kafka安装的某些文件夹,并在启动KAFKA服务器时自动运行此流应用程序。
您的Kafka Broker(Server)和您的Kafka Streams应用程序彼此独立。您可以在服务器上管理流程,无论是Initd还是Systemd,还是基于容器的解决方案,例如Docker或Kubernetes。
根据我的经验,如果您的流应用程序在经纪人或Zookeeper之前就开始了,那么它可能很想等待它们上网。因此,您可能需要在这种情况下配置流程以重新启动。