Kubernetes的Spring Cloud Data Flow-无法配置多个kafka代理
deployer:
kubernetes:
environmentVariables: >
SPRING_CLOUD_STREAM_KAFKA_BINDER_BROKERS='172.16.3.192:9092,172.16.3.193:9092,172.16.3.194:9092',
SPRING_CLOUD_STREAM_KAFKA_BINDER_ZK_NODES='172.16.3.192:2181,172.16.3.193:2181,172.16.3.194:2181'
但在尝试部署SCDF流时出错：声明的环境变量无效:172.16.3.193:9092
我应该如何配置它以使其工作？提前谢了。
共有1个答案
删除YAML中的>
这是创建一个块字符串，而不是环境变量的映射。在YAML中，如何在多行上中断字符串？
此外，如果在kubernetes中使用CoreDNS，您可能应该使用kafka.default.cluster.local这样的值，而不是IP地址，类似于Zookeeper
-
我试图连接到一个Kafka集群通过SASL_SSL协议与jaas配置如下： 上面的配置与Spring-Cloud-stream官方git repo上提供的示例配置是内联的。 在库的git repo上提出的类似问题说，它在最新版本中已经修复，但似乎没有。得到以下错误： SpringBootVersion： 2.2.8和Spring-Cloud-stream-依赖版本-Horsham。SR6. 这让我
-
对集群设置有点困惑： > Zookeeper可以通过配置myid(1,2,3...)将其设置为群集例如，在zoo.cfg文件中具有zookeeper1:2888:3888、zookeeper2:2889:3889 对于Kafka，在server.properties文件中，是否必须为参数zookeeper.connect指定zookeeper服务器的完整列表，还是只要1就足够了？有什么不同吗？我见
-
我用代理ip列表在我的kafka生产者/消费者/流应用程序中配置。但我想移动到一个url条目，该条目将通过DNS查找当前称为up的代理ip来解析（DNS主动检查集群中的代理并使用IP短TTL[10s]响应查找）。这让我在未来添加代理时具有更大的灵活性，并且我可以在所有环境/阶段的应用程序中保持相同的配置。这是推荐的方法吗，还是这会消除客户端没有严格代理列表的弹性？我假设此配置仅用于最初“发现”集群
-
我已经创建了一个Flink原生Kubernetes（1.14.2）集群，这是成功的。我正在尝试更新使用Flink Native Kubernetes公开的configmap的logback配置。Flink Native Kubernetes在集群启动期间创建此configmap，在集群停止时将其删除，此行为符合官方文档。 我更新了同样成功的回退配置图，这个过程甚至更新了作业管理器和任务管理器中的实
-
问题内容： 因此，我的目标是以分布式方式建立一个由多个kafka经纪人组成的集群。但是我看不出让经纪人彼此了解的方法。 据我了解，每个代理在其配置中都需要一个单独的ID，如果我从Kubernetes启动容器，我不能保证或配置该ID吗？ 他们还需要具有相同的advertised_host吗？ 是否有我需要更改的参数才能使节点相互发现？ 在Dockerfile的末尾使用脚本进行这样的配置是否可行？和/
-
我正在尝试为Kafka Connect REST API（2.11-2.1.0）配置SSL。 问题所在 我尝试了两种配置（工人配置）： 带有前缀 < li >并且不带< code>listeners.https.前缀 两种配置都启动正常，并在尝试连接到https://localhost:9000时显示以下异常： 在日志中，我看到SslContextWorks是使用任何密钥库创建的，但使用密码： 因
-
问题内容： 我想将所有错误定向到我的Errorsevlet，而无需明确指定所有代码。有什么办法可以这样做吗？ 到达ErrorServlet后，如何获取servlet中错误的堆栈跟踪。这样一发生错误，我就可以通过电子邮件发送详细信息。 问题答案： 试试这个，所有错误都会被捕获（500个）而不是404等
-
我是码头工人和库伯内特斯的新手。使用的技术： < li >点网核心2.2 < li>Asp。NET Core WebAPI 2.2 < li >启用Kubernetes支持的Docker for windows(Edge) < li >代码 我将两个服务托管到两个docker容器容器1和容器2中。 下面是我的部署。yaml 当我运行命令时： 我获得的状态为 。 但是当我只配置了一个容器时，同样运行