我有一个非常简单的qukus微服务,它使用小型响应消息(kafka)。有时我的kafka代理会崩溃,我得到以下日志:
2020-09-24 04:04:27,067 WARN [org.apa.kaf.cli.NetworkClient] (kafka-producer-network-thread | producer-1) [Producer clientId=producer-1] Bootstrap broker xxxxxxx.xxxx.xxx:2202 (id: -1 rack: null) disconnected 2020-09-24 04:04:27,083 WARN [org.apa.kaf.cli.NetworkClient] (kafka-producer-network-thread | producer-3) [Producer clientId=producer-3] Connection to node -1 (xxxxx.xxxx.xxxx.fr/XX.XX.XX.XXX:2202) could not be established. Broker may not be available.
重新启动代理后,我必须手动重新启动我的微服务。是否有可能增加微服务的功能,以便在不进行任何手动操作的情况下重新汇总新传入的消息?
谢谢你!
如果您使用的是KafkaProducer和消费者API,它们会在代理再次启动后自动重新连接。请确保在您的应用程序中您不会抛出异常并杀死线程。如果您保持线程活动,那么它将重新连接。捕获消费者线程的所有异常,以确保它不会因运行时异常而退出。
问题内容: 我注意到,在一些服务器上重新启动/关闭后,SQL Agent不会自动启动(SQL Server启动正常)。该服务设置为在Windows中自动启动。当我们手动启动SQL代理时,它会正常启动。 问题答案: 在以下路径中添加Windows级用户: 单击开始-运行 -Secpol.msc 转到: 本地策略-用户权限分配 确保您在其下运行SQL Agent Service的用户帐户具有以下分配:
我在集群的ubuntu节点上设置了一个kafka 0.11.0.0实例。直到几周前,一切都正常工作,今天我尝试启动它,在启动后出现以下错误: 我的服务器。特性: 我编辑了广告。侦听器,因为存在将请求重定向到代理的代理。无论如何,直到几周前一切都很好。。。 我开始Kafka的步骤: 有什么建议吗?谢谢你们
我有一个带有控制器的Spring portlet,其结构如下。 这是我之前问题的变体,我没有得到任何答案。 我们有时会重启服务器。我们希望避免外部人员再次手动执行调度。由于它目前是一个portlet,因此有必要呈现视图,以便执行此代码。有没有办法在liferay服务器启动后立即自动执行此调度代码?
我已将spring-boot应用程序部署到IIS/嵌入式tomcat,作为一个azure应用程序服务。当应用程序服务启动时,应用程序日志显示同一实例大约每10分钟发生一次重新启动(新的pid)。90分钟后,它将最终成功部署。我从嵌入的tomcat日志和org.springframework日志中看不到任何问题,但有时它可能在2分钟内开始。 我还可以在哪里查找启动错误,有没有办法增加应用服务启动时间
我正在使用单节点独立zookeeper运行一个带有zookeeper发现SPI机制的单节点Apache Ignite服务器。 我正在尝试使用下面的发现SPI配置从客户端应用程序连接Ignite服务器,如下所示 请提供在zookeeper重新启动后客户端自动重新连接的配置。
服务器重启后无法启动Apache HTTPD。我们 /etc/httpd/conf/拥有功能。用户/组。因此,我们使用脚本来启动httpd.conf每次服务器重启时,我们都无法启动HTTPD。我们发现 /var/run/httpd在重启后被更改为apache/root。因此,脚本无法启动功能下的HTTPD。用户/组。 请帮帮我!!!