- xml - AJAX/Jquery XML 解析
- 具有多重继承的 XML 模式
- .net - 枚举序列化 Json 与 XML
- XML 简单类型、简单内容、复杂类型、复杂内容
我正在开发一个应用程序,该应用程序从 sqs 队列中读取一条消息,对该数据执行一些操作,然后获取结果并将其发布到 kafka 主题。为了在本地进行测试,我想在我的 docker 构建中设置一个 kafka 图像。我目前能够使用 docker-compose 在本地启动 aws-cli、localstack 和我的应用程序的容器。另外,我也可以毫无问题地启动 kafka 和 zookeper。我无法让我的应用程序与 kafka 通信。
我试过使用两个单独的撰写文件,也尝试过网络。最后,我引用了:https://rmoff.net/2018/08/02/kafka-listeners-explained/。
这是我的 docker-compose 文件:
version: '3.7'
services:
localstack:
image: localstack/localstack:latest
container_name: localstack
env_file: .env
ports:
# Localstack endpoints for various API. Format is localhost:container
- '4563-4584:4563-4584'
- '8080:8080'
environment:
- SERVICES=sns:4575,sqs:4576
- DATA_DIR=/tmp/localstack/data
volumes:
# store data locally in 'localstack' folder
- './localstack:/tmp/localstack'
networks:
- my_network
aws:
image: mesosphere/aws-cli
container_name: aws-cli
# copy local JSON_DATA folder contents into aws-cli container's app folder
#volumes:
# - ./JSON_DATA:/app
env_file: .env
# bash entrypoint needed for multiple commands
entrypoint: /bin/sh -c
command: >
" sleep 10;
aws --endpoint-url=http://localstack:4576 sqs create-queue --queue-name input_queue;
aws --endpoint-url=http://localstack:4575 sns create-topic --name input_topic;
aws --endpoint-url=http://localstack:4575 sns subscribe --topic-arn arn:aws:sns:us-east-2:123456789012:example_topic --protocol sqs --notification-endpoint http://localhost:4576/queue/input_queue; "
networks:
- my_network
depends_on:
- localstack
my_app:
build: .
image: my_app
container_name: my_app
env_file: .env
ports:
- '9000:9000'
networks:
- my_network
depends_on:
- localstack
- aws
zookeeper:
image: confluentinc/cp-zookeeper:5.0.0
container_name: zookeeper
ports:
- 2181:2181
environment:
ZOOKEEPER_CLIENT_PORT: 2181
networks:
- my_network
kafka:
image: confluentinc/cp-kafka:5.0.0
ports:
- 9092:9092
depends_on:
- zookeeper
environment:
# For more details see See https://rmoff.net/2018/08/02/kafka-listeners-explained/
KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
KAFKA_ADVERTISED_LISTENERS: INSIDE://localhost:9092
KAFKA_LISTENERS: INSIDE://localhost:9092
KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: INSIDE:PLAINTEXT
KAFKA_INTER_BROKER_LISTENER_NAME: INSIDE
KAFKA_CREATE_TOPICS: "output_topic:2:2"
networks:
- my_network
networks:
my_network:
我希望发布到该主题时不会出现任何错误。相反,我得到:
kafka: client has run out of available brokers to talk to (Is your cluster reachable?)
任何想法我可能做错了什么?感谢您的帮助。
最佳答案
通过将监听器设置为仅本地主机,您已经使代理只能在 Kafka 容器本身(或从您的主机到容器)内解析。
如果您希望另一个 Docker 服务能够访问该容器,您必须添加 <some protocol>://kafka:<some port>
给广告听众,并制作listeners
因为不是本地主机
协议(protocol)也添加到 KAFKA_LISTENER_SECURITY_PROTOCOL_MAP
中
FWIW,该博客应该涵盖所有这些基础。
关于go - 如何修复 `kafka: client has run out of available brokers to talk to (Is your cluster reachable?)` 错误,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/57103197/
Google Talk如何工作?当我连接到我的 friend 进行谈话时,什么充当 中级 一个转移我的声音?那是它背后的谷歌服务器(充当中间人?还是提供点对点协议(protocol)? 最佳答案 他们
我有两个(Java)进程在不同的 JVM 上重复运行。第一个经常发现一些“信息”并需要将其存储在某个地方。第二个进程定期读取此信息来处理它。这些间隔或多或少是随机的,因此进程 1 可能会找到三条信息,
我想创建一些服务,该服务将作为简单进程运行,并为其他应用程序提供向他发送 xml 流的可能性。 我的意思是创建具有无限循环的简单进程 (exe) - 任何应用程序都能够将 XML(文件/流)发送到该进
我想知道(官方)GTalk 客户端如何设法显示接收到的所有 消息——即使它最初是由另一个客户端使用的。例如:我在笔记本电脑上登录 gmail.com 上的 GTalk,同时在我的 Android 设备
Google GTalk 客户端(web、android、windows)具有从服务器获取对话历史的强大能力,即使对话是在另一个 jabber 客户端完成的。 什么 jabber (XMPP) 功能
我知道一旦调用函数,this 的上下文就会更改为对象,但如何在无需创建方法的情况下模拟该上下文? var object = { x: 1, y: object.x, //
Google Talk 如何播放当前歌曲?我可以使用 .net 执行此操作吗? 编辑:看起来每个玩家都有自己的 SDK 供使用 温安普 :这是一个关于要使用的类的好帖子:http://forums.w
关闭。这个问题需要更多focused .它目前不接受答案。 想改进这个问题吗? 更新问题,使其只关注一个问题 editing this post . 关闭 8 年前。 Improve this qu
当我们为android或ios应用程序安装代理时,我们通常会添加一些库并更改一些配置设置。仅添加一个库如何使该应用程序记录事件并将其推送到 monkey talk IDE。 通常我们在项目中添加库的时
我是一名大学生。我正在上我的第二个 comp sci 类(class),我们还没有太多简单地在其中制作类和函数,所以我还没有真正能够充分利用我在互联网上找到的复杂行话。 我正在制作蟑螂出没模拟游戏,我
我正在开发一个 Android 应用程序,其中显示了 Google Talk 联系人及其状态 - 这工作正常。 我不确定应该调用哪个 Intent 来使用默认的 Talk 应用打开聊天窗口。 我如何知
我一直在努力弄清楚 TED Talk homepage 到底是怎么回事作品。撇开所有的动画垃圾不谈,我发现盒子的组织方式真的很迷人。 乍一看,它看起来像 jQuery masonry plugin ,
我想知道如何通过特殊客户端为 Google Talk 创建聊天机器人。 我知道它使用 XMPP 发送消息,但我完全不知道如何使用它。据我了解,如果我要创建自己的客户端页面,我应该能够制作一个机器人,当
几天来,我一直在尝试通过 SmartBand Talk (SWR30) 发送 Google 文字转语音音频。我对 AndroidManifest.xml 拥有正确的权限 PERMISSION_CONT
我设置了一个在预览控制台中运行的 GoogleHome 操作 我会写“用行动说话” 我得到我的答案 如何用法语测试 GoogleHome 上的该操作?任何解决方法? 我尝试在移动应用程序中使用别名来触
我正在尝试使用PHP连接到Google Talk XMPP服务器。我成功建立了连接并使用X-OAUTH2登录。然后Google要求我建立TLS连接。但是,当尝试将连接升级到TLS时,出现异常:stre
我是扩展程序编程的新手,但发现在 Chrome 中制作扩展要容易得多,但现在我正在尝试将我的测试扩展移植到 FF,我有几个问题如何做与我在 Chrome 中所做的相同的事情。 .现在在FF。 例如:在
FB 公开了此 EdgeRank 指标(显示在每个页面上) - 现在如何访问它来收集统计数据? 最佳答案 几周前我向 Facebook 团队询问了此事;看来当时它被忽视了,他们会调查它。我今天刚刚检查
我正在尝试使用 Monkey Talk 进行自动化测试。我安装成功了。我在 Eclipse Juno 上运行示例应用程序,然后创建一个新的 Monkey 脚本并记录操作。 问题是 Monkey IDE
有谁知道 Google Talk 浏览器插件是否可供网络应用程序开发人员使用?我说的是用 HTML/JavaScript 来操作它。 Google Talk 开发网站似乎只为想要开发独立客户端/服务器
我是一名优秀的程序员,十分优秀!