任何人都可以分享我的yaml文件,用于创建具有两个kafka经纪人的kafka集群和具有3个服务器的动物园管理员集群。我是库伯内特斯的新手。
我想你可以看看斯特林齐项目,https://strimzi.io/。它基于 Kubernetes 运算符模式,提供了一种使用自定义资源在库伯内特上部署和管理 Kafka 集群的简单方法。通过新的“Kafka”资源 YAML 文件来描述Kafka群集,该文件用于设置所需的一切。操作员负责处理这个问题,并为您部署动物园管理员集合Kafka集群。它还部署了两个以上的运算符来处理主题和用户(但它们是可选的)。
我建议你试试斯特林齐Kafka运营商。使用它,你可以定义一个Kafka集群,就像其他库伯内特斯对象一样 - 编写一个yaml文件。此外,用户,主题和Kafka连接集群也只是一个k8s对象。斯特里姆齐·Kafka操作员的一些(不是全部!)功能:
值得一提的是一个很棒的文档。
创建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: {}
看看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” 我遵循了入门指南,如果我