我正在尝试使用来自 kafka 服务器的数据,我正在使用@Kafkalistener注释。
问题是每次重新启动应用程序时我都会收到所有消息。如何在我的应用程序中保存上次使用的偏移量并使用它来使用下一条消息?
我正在使用 jhipster 4.5.6。我正在尝试在 heroku 上运行我的应用程序,在主类中执行此代码时出现此错误:
环境 env = app.run(args).getEnvironment();
2017-06-24 17:35:32.293 ERROR 4 --- [ main] osboot.SpringApplication : 应用程序启动失败 2017-06-24T17:35:32.294416+00:00 app[web.1]: 2017-06-24T17 :35:32.294418 + 00:00 app [web.1]:org.springframework.beans.FatalBeanException:无法将属性“密码”从源复制到目标;嵌套异常是 java.lang.reflect.InitationTargetException