在AK上部署Spring-Cloud-Data-Flow时，如何指定使用外部托管的Kafka集群

Question

我尝试了基于helm的SCDF部署(https://docs.spring.io/spring-cloud-dataflow-server-kubernetes/docs/current-snapshot/reference/htmlsingle/#_helm_installation)，这可以使用基于RabbitMQ或基于Kafka的消息传递系统-这两个选项都可以部署在helm图表中。但是，我的项目已经有了运行在Confluent cloud上的自己的Kafka实例，我希望用它来代替“内部”实例。然后，我还尝试了SCDF的Kubectl部署(https://docs.spring.io/spring-cloud-dataflow-server-kubernetes/docs/current-snapshot/reference/htmlsingle/#_deploying_with_code_kubectl_code)，并看到我需要再次运行两个消息传递组件中的一个。我想知道配置SCDF以使用我自己的Kafka实例的最佳方法--有人能透露任何一个吗？

Answer 1

上面的文档引用非常旧，因此，您可能需要更新到最新的文档引用。

关于SCDF的最新消息，您也需要参考这里，还有一个SCDF微站点您也可以参考。

为了回答您的具体问题，由于Apache Kafka被用作流应用程序中的绑定器，您有两个选项来设置外部Kafka集群配置：

null

data:
  application.yaml: |-
    spring:
      cloud:
        skipper:
          server:
            platform:
              kubernetes:
                accounts:
                  default:
                    environmentVariables: 'SPRING_CLOUD_STREAM_KAFKA_BINDER_BROKERS=${KAFKA_SERVICE_HOST}:${KAFKA_SERVICE_PORT},SPRING_CLOUD_STREAM_KAFKA_BINDER_ZK_NODES=${KAFKA_ZK_SERVICE_HOST}:${KAFKA_ZK_SERVICE_PORT}'

null