当前位置: 首页 > 知识库问答 >
问题:

使用库伯内特安装Kafka和动物园管理员集群

靳金鹏
2023-03-14

任何人都可以分享我的yaml文件,用于创建具有两个kafka经纪人的kafka集群和具有3个服务器的动物园管理员集群。我是库伯内特斯的新手。

共有3个答案

梁英喆
2023-03-14

我想你可以看看斯特林齐项目,https://strimzi.io/。它基于 Kubernetes 运算符模式,提供了一种使用自定义资源在库伯内特上部署和管理 Kafka 集群的简单方法。通过新的“Kafka”资源 YAML 文件来描述Kafka群集,该文件用于设置所需的一切。操作员负责处理这个问题,并为您部署动物园管理员集合Kafka集群。它还部署了两个以上的运算符来处理主题和用户(但它们是可选的)。

上官波鸿
2023-03-14

我建议你试试斯特林齐Kafka运营商。使用它,你可以定义一个Kafka集群,就像其他库伯内特斯对象一样 - 编写一个yaml文件。此外,用户,主题和Kafka连接集群也只是一个k8s对象。斯特里姆齐·Kafka操作员的一些(不是全部!)功能:

  • 使用TLS保护经纪人之间以及经纪人和动物园管理员之间的通信
  • 能够将集群暴露在k8s集群之外
  • 可部署为头盔图(它简化了很多事情)
  • 更改集群配置时滚动更新
  • 平滑扩展
  • 准备使用Prometheus和Grafana监控集群。

值得一提的是一个很棒的文档。

创建Kafka集群就像应用这样的库伯内特斯清单一样简单:

apiVersion: kafka.strimzi.io/v1beta1
kind: Kafka
metadata:
  name: my-cluster
spec:
  kafka:
    version: 2.2.0
    replicas: 3
    listeners:
      plain: {}
      tls: {}
    config:
      offsets.topic.replication.factor: 3
      transaction.state.log.replication.factor: 3
      transaction.state.log.min.isr: 2
      log.message.format.version: "2.2"
    storage:
      type: jbod
      volumes:
      - id: 0
        type: persistent-claim
        size: 100Gi
        deleteClaim: false
  zookeeper:
    replicas: 3
    storage:
      type: persistent-claim
      size: 100Gi
      deleteClaim: false
  entityOperator:
    topicOperator: {}
    userOperator: {}
唐裕
2023-03-14

看看https://github.com/Yolean/kubernetes-kafka,确保代理内存限制为2 GB或以上。

在库伯内特斯维持一个可靠的Kafka集群仍然是一个挑战,祝你好运。

 类似资料:
  • 假设我有 3 台 Kafka 服务器。服务器 1 zoopkeeper1 服务器 2 zoopkeeper2 服务器 3 zoopkeeper3 在集群配置中,zoopkeepers 会发生什么?它们是为每个服务器单独维护的,还是会在群集配置中同步其数据?

  • 我已经设置了一个带有SASL SCRAM安全性的Kafka集群,它运行良好。 根据文档,我使用了命令< code>kafka-configs.sh来创建用户名和密码,并授予该用户对主题的访问权限。 这也很棒。 但是, 命令本身不需要任何类型的身份验证,因此在我看来,任何人都可以运行该命令并在Kafka中创建自己的用户并授予自己的权限。 也许我需要在Zookeeper上启用SASL安全性?但我找不到

  • 分布式 Apache HBase 安装依赖于正在运行的 ZooKeeper 集群。所有参与节点和客户端都需要能够访问正在运行的 ZooKeeper 集合。 Apache HBase 默认为您管理 ZooKeeper“集群”。它将启动和停止 ZooKeeper 集合作为 HBase 启动/停止过程的一部分。您还可以独立于 HBase 管理 ZooKeeper 集合,只需将 HBase 指向它应该使用

  • 在Zookeeper和代理身份验证上启用SASL时,我面临以下错误。 以下配置在JAAS文件中给出,该文件作为KAFKA_OPTS传递,将其作为JVM参数:- Kafka经纪人的服务器。属性设置了以下额外字段:- Zookeeper属性如下所示:

  • 如果我部署war,我将得到以下异常: 原因:org.apache.camel.resolveEndpointFailedException:无法解析endpoint:kafka://localhost:9092?serializerClass=kafka.serializer.stringencoder&topic=checking&zookeePerhost=localhost&zookeePe

  • 我正在尝试安装Kafka Kafka和Zookeeper正在运行Apache Kafka tarball(v 0 . 0 . 9 ),在Docker映像中。 尝试使用提供的脚本消费/生产。并尝试使用自己的java应用程序进行生产。如果Kafka一切正常 以下是我在尝试生成时遇到的错误: Kafka属性测试 首先: 第二: 第三: 上一个: 这是我的“/etc/hosts” 我遵循了入门指南,如果我