我的目标是使用容器部署 Kafka 连接连接器(s3 接收器),因此了解有关工作人员可能会或可能不会直接相互通信的详细信息非常重要。
从我读到的内容来看,我无法确定工作人员之间是否会进行直接通信(例如一名工作人员使用 REST 与另一名工作人员交谈,或其他)。
我一开始认为,当我使用 REST 更新配置时,配置更改是使用 connect_config 内部主题和/或使用 Kafka 消费者协调器传播的。
但从我读到的:
rest.advertised.host.name
If this is set, this is the hostname that will be given out to other workers to connect to.
Run Code Online (Sandbox Code Playgroud)
有关工人如何以及为什么(如果这样做)彼此沟通的任何详细信息?
我决定尝试一下 Nomad,并且正在为公司的副项目建立一个小型环境。
尽管 Nomad/Consul 的文档很好而且很详细,但它们并没有达到向世界公开一个小型 Web 服务的简单任务。
按照官方教程使用 Traefik 作为负载均衡器,如何使这些公开的服务可访问?
该教程有一个脚注,指出可以通过端口 8080 从集群外部访问服务。
但在拥有 3 个服务器和 3 个客户端的集群中,我应该将 DNS 指向哪里?具有指向 3 个客户端的故障转移功能的 DNS 是否足够?我还需要为客户端提供负载均衡器吗?
两级调度程序(如 Apache Mesos)与单级调度程序(如 Kubernetes)的优缺点是什么?它们如何在小型和大型集群上执行通常在构建、测试、部署无状态、有状态和大数据应用程序中发生的各种工作负载?
需要帮助我有这个
service {
name = "nginx"
tags = [ "nginx", "web", "urlprefix-/nginx" ]
port = "http"
check {
type = "tcp"
interval = "10s"
timeout = "2s"
}
}
Run Code Online (Sandbox Code Playgroud)
如果返回 200 响应(如 localhost:8080/test/index.html),我如何为特定 URI 添加运行状况
我正在尝试找到转换的最佳方法
map[string]string
键入字符串。我尝试使用marshall转换为json以保留格式,然后转换回字符串,但这未成功。更具体地说,我正在尝试将包含键和值的映射转换为字符串以容纳https://www.nomadproject.io/docs/job-specification/template.html#environment-variables https://github.com/hashicorp /nomad/blob/master/nomad/structs/structs.go#L3647
例如,最后一个字符串应该像
LOG_LEVEL="x"
API_KEY="y"
Run Code Online (Sandbox Code Playgroud)
地图
m := map[string]string{
"LOG_LEVEL": "x",
"API_KEY": "y",
}
Run Code Online (Sandbox Code Playgroud) 我是通过每30秒运行一次的游牧民来运行一项cron(定期)工作,这项工作除了公正之外什么也没做
echo "some string"
因此立即结束
当我做
nomad status
我也得到了所有已经完成的工作 - 已完成执行的工作,这对我来说毫无用处.有没有办法去除死亡的工作?
PS:一个明显的解决方案是解决死亡工作,游牧民提供的任何解决方案?
nomad ×6
consul ×2
apache-kafka ×1
docker ×1
go ×1
json ×1
kubernetes ×1
mesosphere ×1
nginx ×1
traefik ×1