无法从外部机器连接到kafka

2024-01-26

我从 Apache Kafka 开始,当我尝试从外部机器连接时遇到问题。

使用下面的配置,如果应用程序和 docker 在同一台机器上运行,则一切正常。

但是当我将应用程序放入机器 A 并将 docker 放入机器 B 时,应用程序无法连接。

我的 spring Kafka @Configuration 有这条线到 @Bean ConsumerFactory 和 ProducerFactory (想象一下我的机器,docker ip = 10.10.10.10)

props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "10.10.10.10:9092");

我的 docker 文件是这样的:

version: '2'
services:
zookeeper:
    image: wurstmeister/zookeeper:3.4.6
    ports:
      - 2181:2181
kafka:
    image: wurstmeister/kafka:0.10.1.1
    environment:
        KAFKA_ADVERTISED_HOST_NAME: 0.0.0.0
        KAFKA_ADVERTISED_PORT: 9092
        KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
        KAFKA_CREATE_TOPICS: "topic-jhipster:1:1,PROCESS_ORDER:1:1, PROCESS_CHANNEL:1:1"
        JMX_PORT: 9999
        KAFKA_JMX_OPTS: "-Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.authenticate=false -Dcom.sun.management.jmxremote.ssl=false -Djava.rmi.server.hostname=127.0.0.1 -Dcom.sun.management.jmxremote.rmi.port=9999"
    ports:
        - 9092:9092
        - 9999:9999
kafka-manager:
    image: sheepkiller/kafka-manager
    ports:
        - 9000:9000
    links:
        - zookeeper
    environment:
        ZK_HOSTS: zookeeper:2181

我收到这个错误:

org.springframework.kafka.core.KafkaProducerException: Failed to send;
nested exception is org.apache.kafka.common.errors.TimeoutException: 
Expiring 1 record(s) for

编辑,添加一些信息..

我认为我缺少有关动物园管理员的任何配置..因为如果我只在我的机器A上启动动物园管理员..而机器B中的卡夫卡..可以工作..我只是不知道如何:(


尝试设置监听器,

eg: listeners = PLAINTEXT://your.host.name:9092

假设您可以在 kafka 端口上的机器之间进行 telnet。

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

无法从外部机器连接到kafka 的相关文章

随机推荐

  • 在 Perl 中计算字符串中单词数的最快方法是什么?

    我有一些函数在各种文本上运行了超过一百万次 这意味着这些函数的微小改进总体上会带来巨大的收益 目前 我注意到所有涉及字数统计的功能的运行时间都比其他功能要长得多 所以我想尝试以不同的方式进行字数统计 基本上 我的函数所做的就是获取许多具有与
  • 阻止用户输入字母? C++

    你好 我是 C 新手 但我有一个小问题 那就是我必须阻止用户在数字部分输入字母 我做了一次尝试 虽然有效 但很狡猾 因为它将允许用户继续 然后告诉他们出了问题并重新启动应用程序 我如何验证它以显示错误消息 告诉他们这不是数字并让他们重新输入
  • 如何根据对象索引合并两个列表 - 保留属性?

    我想合并两个列表 保留每个对象的索引 mylist lt list 1 NULL 2 otherlist lt list NULL 3 NULL 4 5 6 Desired list 1 3 2 4 5 6 my try suppressW
  • System.IO.IOException:使用 Directory.EnumerateDirectories 时句柄无效

    我有一个窗口服务可以将东西导入到我的系统中 有时我会收到 System IO IOException 句柄无效 有谁知道为什么会出现这种异常 下面你可以看到触发异常的代码 foreach string directoryPath in Di
  • 使用 OSMnx 提取约束多边形

    我正在使用 OSMnx 包来解决以下任务 地图上有一个由纬度和经度定义的点 X 我们需要检测包含该点 X 并受到相邻道路约束的多边形 所以基本上点 X 位于多边形内部 相邻道路将是该多边形的边界 到目前为止 我只设法在地图上绘制图形的可视化
  • 从函数返回后更改 ggplot 对象的点大小

    假设我有一个返回 ggplot 对象的函数 getplot function x rnorm 16 y rnorm 16 dat data frame x y myplot ggplot dat aes x y geom point myp
  • 所有公共结构都会产生对隐式删除的默认构造函数的调用

    我明白什么call to implicitly deleted default constructor意思是但我不明白为什么我会在这里得到它 struct TransformData enum type t kDelay 0 kScale
  • 编写一个可以采用 Int 或 Double 值的 scala 函数

    我编写了一个函数来接受以下类型的值 1 数组 1 0 2 0 3 0 这是一个元组 其中 Int 是第一个值 下一个是双精度数组 我还希望它也接受整数数组 我写的函数如下 def getCountsAndAverages T Paramet
  • C# 使用 NumberLong 将 mongodb bson 转换为 json

    我有一个动态 mongoDB bson 文档 我尝试将其反序列化为 C Dictionary 对象 bson 文档包含 LongNumber 类型 我遇到了麻烦 var json entity BsonValue ToJson JsonCo
  • 如何使用生成器形成多个管道?

    我正在使用 python 并且正在尝试找到一种将多个生成器优雅地链接在一起的方法 问题的一个例子是 例如 有一个根生成器 它提供某种数据 每个值都像级联一样传递给它的 子级 而级联反过来可能会修改它们接收的对象 我可以走这条路 for x
  • jQuery:表单序列化、隐藏字段和不显示字段

    我在用 this serialize 提交表格时 它工作得很好 除了当我 由于某种原因 有两个具有相同名称的字段 一个可见 一个不可见 而且我不是在谈论type visible but display none 但是当然serialize不
  • 没有 Google Fonts 2 的 Bootstrap CSS (Bootswatch)

    我正在开发一个网页 并使用 Bootswatch 进行样式设置 有时我必须离线工作并在本地托管 不幸的是 Bootswatch 无法离线使用 因为它使用了 Bootstrap css 版本 并且开头带有额外的字体 import url ht
  • VBA 词。超链接的HighlightColorIndex 返回 9999999

    我正在 Word 中编写一个宏 以删除突出显示的所有超链接的突出显示wdGray25 对所有超链接的搜索是通过以下方式完成的 For Each oLink In ActiveDocument Hyperlinks If oLink Rang
  • 在IntelliJ IDEA中添加AAR而不使用gradle

    如何将aar module添加到IDEA中的项目中 没有gradle 使用ant 对于 Android Studio 这几乎是一样的 我找到的唯一解决方案是将 aar 内容提取到文件夹中以与导入模块过程一起使用 File gt Projec
  • 构建应用程序时出现“找不到资源”错误

    我想将我的 Eclipse 项目迁移到 Android Studio 我曾经使用 minSdkVersion 8 构建项目 但我想添加需要 minSdkVersion 10 的新功能 我正在运行 Android Studio 1 1 0 导
  • Angular:ng-init 不在负载上运行

    我已经看到了一些有关 ng init 问题的堆栈溢出示例 尽管我似乎找不到使用控制器引用它的示例 我通过在 html 文件中包含以下内容来调用控制器中的函数 div class tab container 在控制器中 scope init
  • R:控制直方图箱的数量

    我正在使用 hist 函数来分析我生成的一些数据 对于分析测定 我想精确控制直方图箱的数量 我知道 中断参数 并且我可以看到 在许多情况下 垃圾箱的数量与中断的数量有直接关系 即 no bins no breaks 1 由于 R 的算法 情
  • 花栗鼠碰撞检测

    我对花栗鼠完全陌生 而且我刚刚使用它几天 所以我猜这是非常明显的事情 但是我找不到任何相关文档 Chipmunk 中是否有任何回调或方法可以告诉您 2 个给定的形状发生了碰撞 如果不是 最好的方法是简单地在精灵上使用 cgrect cont
  • iOS 6 自定义 URL 方案启动图像错误

    我已经在我的应用程序中实现了自定义 URL 方案 另外 我使用以下命令对启动图像有不同的名称UI启动图像文件键入 info plist 文件说 如果您的应用程序支持一个或多个自定义 URL 方案 它还可以 为每个 URL 方案提供自定义启动
  • 无法从外部机器连接到kafka

    我从 Apache Kafka 开始 当我尝试从外部机器连接时遇到问题 使用下面的配置 如果应用程序和 docker 在同一台机器上运行 则一切正常 但是当我将应用程序放入机器 A 并将 docker 放入机器 B 时 应用程序无法连接 我