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

如何在谷歌云上部署Kafka

公孙嘉禧
2023-03-14

我在谷歌云上部署了Kafka,我把监听器改为

我可以拿到经纪人的话题。然而,当我试图生成消息给Kafka经纪人时

sudo./bin/kafka-console-producer.sh--broker-list[外部IP地址]:9092--topic test

出现以下错误:

向主题测试发送消息时出现错误,键:null,值:5字节,错误:(org.apache.kafka.clients.producer.internals.errorloggingcallback)org.apache.kafka.common.errors.timeoutexception:为测试过期1条记录-0:1506 ms自批创建加上逗留时间后已过

共有1个答案

江德润
2023-03-14

您需要将adveredsed.listeners设置为外部IP,以便客户端能够正确地连接到外部IP。否则,它们将尝试连接到内部IP(因为adveredsed.listeners将默认为listeners,除非显式设置)

参考:https://kafka.apache.org/documentation/#brokerconfigs

 类似资料:
  • 我尝试使用my console在谷歌云平台上部署云功能。我使用的命令是, 但我得到了这个错误, 错误:(gcloud.functions.deploy)操作错误:代码=3,消息=Build failed:无法解析存储源:googleapi:错误404:未找到,未找到 我试着在谷歌上搜索,但似乎以前没有人遇到过这个错误消息。我也尝试过改变项目,部署效果很好。 如果有人知道是什么导致了这个错误,以及我

  • 当我运行gcloud函数deploy gcp_test——trigger resource xxx-test-123——trigger event google时。存储对象我发现语法错误。 错误:(gcloud.functions.deploy)操作错误:code=3,message=Function load错误:文件索引中的代码。无法加载js。你的代码中有语法错误吗?详细堆栈跟踪:/user\

  • 我正在尝试将Java Spring Boot应用程序部署到谷歌云,我遇到了一些问题。我尝试了两种方法: https://cloud.google.com/appengine/docs/flexible/java/quickstart https://www.baeldung.com/spring-boot-google-app-engine 这是我在使用第一种部署方法(gcloud app dep

  • 从今天开始,我无法使用gCloud cli部署云功能。 下面是我部署云功能的gloud命令: 我有个错误: 部署功能(可能需要一段时间-最多2分钟)...失败。 错误:(gcloud.functions.deploy)操作错误:代码=3,消息=生成失败:生成已超时 我曾经在一个小时前编写过相同的脚本,但现在,团队中没有人能够部署云功能,并得到相同的错误。 在stackDrive日志中,我只看到以下

  • 如何在谷歌云平台上连接mlab?我正在犯错误。 servlet java.lang.NoClassDefFoundError的未捕获异常:java.lang.Management.ManagementFactory是一个受限类。更多细节请参见Google App Engine开发人员指南。在com.google.apphosting.runtime.security.shared.stub.jav

  • 介绍如何在谷歌云平台获取在云联壹云平台需要使用的配置参数。 如何获取谷歌云服务帐号密钥信息? 纳管指定项目 打开“GCP Console中的IAM和管理-IAM页面”页面并登录。 单击顶部“选择项目”,选择需要授权的项目。 在左侧导航栏中选择“服务账号”,进入指定项目的服务账号页面。 单击 “创建服务账号” 按钮,进入创建服务账号页面。 配置服务账号名称、服务账号ID、服务账号说明等,单击 “创建