SpringKafkaTemplate在openshift上找不到引导服务器

w7t8yxp5  于 2021-07-24  发布在  Java
关注(0)|答案(0)|浏览(238)

我正在将springsink微服务从本地机器移动到openshift平台。在我的微服务中,我创建了一个kafkatemplate,如下所示:
@自动连线
kafkatemplate<string,string>kafkatemplate;
使用此方法发送kafka消息在本地计算机上运行得非常好,但当我移动到openshift时,出现以下错误:
无法建立到节点-1(localhost/127.0.0.1:9092)的连接。代理可能不可用。
我发现这有点令人困惑,因为当我的微服务启动时,我可以在日志中看到Kafka服务器的地址,而且其他Kafka函数似乎工作正常(我可以从我的处理器微服务正在写入的Kafka主题中读出)。我能够解决这个问题的方法是手动创建一个producerfactory并将producerconfig.bootstrap\u servers\u config设置为我在日志中找到的引导服务器地址。
所以我想我有几个问题:第一,kafkatemplate是只连接到本地运行,还是有办法连接到服务启动后分配的引导服务器?如果没有,是否有一种方法可以获得我在日志中看到的引导服务器?很明显,我的服务在某一点上可以访问它,所以是否有某种方法可以动态地将bootstrap\u servers\u config设置为日志中打印的值?
或者有没有更好的方法从SpringSink微服务中写出Kafka主题?
任何帮助都将不胜感激!

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题