Strimzi

在 OKD 和 Kubernetes 上运行 Apache Kafka 集群
授权协议 Apache
开发语言 Java
所属分类 服务器软件、 集群/负载均衡
软件类型 开源软件
地区 国产
投 递 者 岳阳文
操作系统 跨平台
开源组织
适用人群 未知
 软件概览

Strimzi提供了一种在各种部署配置中在OpenShiftKubernetes上运行Apache Kafka集群的方法。

在使用Strimzi项目时,使用Kubernetes和OKD(适用于Red Hat OpenShift)启动和运行Apache Kafka集群可以非常简单!

Strimzi基于Apache Kafka 2.1.0,包含三个主要组件:

集群运营者

负责在OpenShift或Kubernetes集群中部署和管理Apache Kafka集群。

主题运营者

负责管理在OpenShift或Kubernetes集群中运行的Kafka集群中的Kafka主题。

用户操作员

负责管理在OpenShift或Kubernetes集群中运行的Kafka集群中的Kafka用户。

  • 基于K8s、Strimzi的Kafka Connect实战 0. 源码地址 https://github.com/wiselyman/kafka-in-battle 1. Operator Framework Operator Framework是一个用来管理k8s原生应用(Operator)的开源工具。 Operator Framework支持的Operator分享地址:https://oper

  • github 地址 下载文件方便后续使用 wget https://github.com/strimzi/strimzi-kafka-operator/releases/download/0.33.2/strimzi-0.33.2.tar.gz tar -xzf strimzi-0.33.2.tar.gz 安装 strimzi-cluster-operator kubectl create n

 相关资料
  • 我的团队开发了一个kubernetes集群。我们已经使用< code>kubectl命令行对其进行了手动测试。这些测试用例涉及到,例如: < li >豆荚 < li >服务、负载平衡器等。 < li >部署 < li >水平窗格缩放 < li >回滚部署 < li >入口控制器 Helm-kubernetes的包装经理 < li >持久性卷和持久性卷声明。 < li>DNS 上述手动测试用例的链接

  • 我已经安装了火花图表在我的k8s集群掌舵,我有3个豆荚运行1个主和2个执行,但仍然能够提交火花作业...在“提交应用程序”一节https://github.com/bitnami/charts/tree/master/bitnami/spark中提到我们可以使用。/bin/spark-submit--class org.apache.spark.examples.sparkpi--master s

  • 我有kubernetes集群和pod,它们是集群IP类型。如果要运行集成测试ip:10.102.222.181或endpoint:10.244.0.157:80,10.249.5.243:80,则哪个ip是正确的ip

  • 在k8s集群中。如何配置zeppelin在现有spark集群中运行spark作业,而不是旋转一个新的Pod? 我有一个k8s集群正在运行,我想在其中运行与齐柏林飞艇的火花。 Spark使用官方的Bitnami/Spark helm chart(v3.0.0)进行部署。我有一个主舱和两个工人舱运转良好,一切都很好。 短伪DockerFile: 我稍微修改了。(Image,imagePullSecre

  • 我正在kubernetes上试用最新版本的Flink1.5的flink工作。 我的问题是如何在上面的flink集群上运行一个示例应用程序。flink示例项目提供了如何使用flink应用程序构建docker映像并将该应用程序提交给flink的信息。我遵循了这个例子,只是把flink的版本改成了最新版本。我发现应用程序(example-app)提交成功,并且在kubernetes的pod中显示,但是f

  • 如何强制调度器以循环方式在节点上运行pod,以便如果任何节点宕机,那么至少有一个节点将NGINX pod处于运行模式。 这到底有没有可能?如果可能,我们如何实现这一场景?

  • 我正在尝试使用 Strimzi 部署 Kafka,问题是,它将 Kafka 代理暴露为负载均衡器并为其分配外部 IP。我希望 Kafka 代理在内部可用,并且仅通过负载均衡器公开。下面是我的部署文件。 下面的集群截图 如您所见,有 3 个分配了外部 IP 的负载均衡器,而我希望它是一个具有外部 IP 的负载均衡器和 2 个 Kafka 代理。

  • 我正在使用一个安装了docker的docker映像,为了运行任务来清理我的kubernetes集群中每个节点上的docker映像数据。我尝试使用Daemonset,因为它将在除master之外的每个节点上运行,但是在docker容器中运行cron被证明是徒劳的。 因此,我尝试使用K8s Cronjob,它定期运行,具有以下属性: 和 我正在运行一个 shell 脚本,该脚本从上述 CronJob