当前位置: 首页 > 知识库问答 >
问题:

Kafka河。allMetadata()返回DOCKER中的空列表(交互式查询)

鞠晋
2023-03-14

我有一个简单的kafka streams应用程序,它利用交互式查询并使用RESTfull进行实例通信。

该应用程序在docker之外使用多个流实例运行良好。并且流#allMetadata()返回所有正在运行的实例的正确列表。但是,一旦我在docker中运行应用程序,流#allMetadata()的结果是一个空数组[]。

注意:在docker中运行时,除了其他实例的可发现性之外,一切都正常。【我可以与不同的流实例进行交互,并可以获取它们存储的数据】

我已经看过其他有同样问题的帖子了,但是我的帖子和其他帖子似乎有点不同

  • 我在所有实例中都有相同的应用程序ID

我错过了什么?

共有1个答案

丁阳羽
2023-03-14

我发现了问题并解决了它。

该问题是由我的流媒体应用docker基础映像中缺少库[ld-linux-x86-64.so.2]引起的,该库由RocksDB的依赖项之一[librocksdbjni8077190960714261011.so]使用(去想象!)。

解决方案是只使用另一个具有上述库的基本图像,因此我将我的流应用程序的基本图像从openjdk:8-jdk-alpine更改为Anapix/alpine java:latest,现在一切正常。

注意:当我出现上述问题时,我注意到了另一个症状。我的流媒体应用程序偶尔会与Kafka经纪人失去联系。我会不时在日志上看到一条消息,内容是“无法访问代理节点…”。上述修复后,此问题消失。我不知道它们是如何相互关联的。

 类似资料:
  • 我正在尝试从我的应用打开Gmail(点击按钮)。我只在Android11中面临这个问题。这不是打开Gmail。在本例中,QueryInputActivities返回空列表。 请帮助我解决android 11的这个问题。下面是我正在使用的代码。。

  • 有人能告诉我为什么列表返回空吗?我的xpath是准确的,因为我重新检查了它,但我仍然无法迭代它,而调试for循环甚至没有执行。我不确定我哪里出了问题。

  • 在Kafka Streams Spring Boot应用程序中,配置(提供主机和端口信息)和访问交互式查询的“惯用”方式是什么? 访问KafkaStreams实例以访问状态存储的正确方法是什么? 我知道spring cloud stream中的InteractiveQueriesService,但我并不是只在spring Boot中使用spring kafka库。 谢谢你

  • 昨天我的Nexus5收到了从到版本的更新。此后,扫描设备中可用网络的动作停止接收列表,在这种情况下,结果列表的大小为0,即使在Wifi系统设置中列出了10+个Wifi网络。 这方面的代码通常是:注册并在接收器中等待事件,如下所示: 我在API的变化主题中搜索了关于这个的内容,但是我没有看到这个功能有什么突破性的变化。 有人注意到了吗?是API中的新内容还是仅有的个别情况?

  • 我有一个奇怪的怪癖,当我运行一个nativeQuery调用单个列中的所有不同值时,我没有得到任何结果。然而,当我从查询中删除“distinct”操作符时,它的工作非常好,告诉我这不是数据库连接或内容问题。 控制器方法: 显然,我可以编写一个“distinct”方法来遍历这个列表,但对我来说,查询不起作用似乎很奇怪 编辑:在备注中请求的存储库和实体类中添加 资源库接口: 创建和修改表的SQL

  • 问题内容: 我正在尝试编写一个用于与last.fm API进行交互的小脚本。 我有一点使用的经验,但是以前使用它的方式似乎无效,而是返回一个空列表。 我删除了API密钥,因为我不知道它到底应该有多私密,并举了一个示例,说明了我在该位置接收的XML。 与API交互的类: 调用的get_now_playing方法: 我收到的xml样本: 问题答案: 问题在于, 如果给定标签名称,则仅搜索元素的直接后代