如何激活和配置ElasticSearch Kafka Connect接收器?-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文

如何激活和配置ElasticSearch Kafka Connect接收器?

k8s小能手 2018-12-27 16:19:01 846

我正在尝试使用helm在Kubernetes集群中设置Kafka。

我已经使用Confluent头盔图来完成安装Kafka。

然后我试着看看如何配置弹性Kafka连接接收器。有一点特别让我感到震惊:confluent load elasticsearch-sink命令。如何在容器启动时重复完成它?此外,要配置弹性,我必须设置属性文件。我是否正确使用ConfigMap?我很困惑,因为我必须改变由helm产生的YAML配置,这似乎不可重复......

消息中间件 Kubernetes Kafka 容器
分享到
取消 提交回答
全部回答(1)
  • k8s小能手
    2019-07-17 23:23:56

    该confluent命令是为了将其用于localhost开发/入门envionments 只。因此,它不了解Kubernetes(例如,您需要一个Ingress控制器来公开Connect REST API)。
    我不认为这是正确的。至少不在Kafka Connect的运营商框架之外(如果存在)。

    Connect 通过JSON REST API配置。

    因此,也无法在启动时加载配置。它需要手动POST,然后该配置将保留在CONNECT_CONFIG_STORAGE_TOPICKafka中。

    在内部,confluent load字面上是一个curl -XPOST -H 'Content-Type: application/json' -d${file} localhost:8083/connectors

    0 0
+ 订阅

云原生时代,是开发者最好的时代

推荐文章
相似问题