SSL身份认证的Benthos Kafka消费者

来到golang学习网的大家，相信都是编程学习爱好者，希望在这里学习Golang相关编程知识。下面本篇文章就来带大家聊聊《SSL身份认证的Benthos Kafka消费者》，介绍一下，希望对大家的知识积累有所帮助，助力实战开发！

我正在使用 benthos (https://www.benthos.dev/) 来消费来自 kafka 主题的消息。

使用本地 kafka 测试我的 benthos 配置工作正常，但是当我使用生产 kafka 部署和 ssl 身份验证测试相同的配置时，benthos 配置不会消耗任何消息。

配置可以连接kafka，最后看到的日志如下。

"@timestamp":"2021-12-10t00:22:44z","@service":"benthos","component":"benthos.input","level":"debug","message":"starting consumer group"}

当我使用没有 ssl 的本地 kafka 运行相同的 benthos 配置时，我可以在上一个日志之后看到一个日志。

{"@timestamp":"2021-12-09t23:49:50z","@service":"benthos","component":"benthos.input","level":"debug","message":"consuming messages from topic 'topicname' partition '0'"}

我怀疑，当使用激活了 ssl 的生产 kafka 时，缺少最后一条痕迹一定是出现问题的线索，但我无法找出问题所在。有人可以帮忙吗？

这是我正在使用的 benthos 配置。

input:
  kafka:
    addresses:
      - kafka-server:443
    topics:
      - kafka-topic
    tls:
      enabled: true
      root_cas_file: ssl/ca.crt
      client_certs:
        - cert_file: ssl/cert.pem
          key_file: sl/key.pem
    consumer_group: consumer-group
    start_from_oldest: false
    checkpoint_limit: 1
    commit_period: 1s
    max_processing_period: 600ms
    group:
      session_timeout: 50s
      heartbeat_interval: 8s
      rebalance_timeout: 60s

br， 埃斯特万·科拉多

正确答案

好吧，我使用的底栖配置没问题。问题出在 kafka 服务器端的一些 ACL 配置。

文中关于的知识介绍，希望对你的学习有所帮助！若是受益匪浅，那就动动鼠标收藏这篇《SSL身份认证的Benthos Kafka消费者》文章吧，也可关注golang学习网公众号了解相关技术文章。