无法为bitnami/Kafka设置自定义参数(numPartitions,defaultReplicationFactor)

tcomlyy6  于 2023-10-15  发布在  Apache
关注(0)|答案(1)|浏览(124)

我创建了一个Azure K8s集群。然后使用helm安装bitnami/Kafka:

helm install kafka bitnami/kafka --set replicaCount=3,provisioning.enabled=true,provisioning.replicationFactor=3,provisioning.numPartitions=3,extraConfig="logRetentionHours=-1,logRetentionBytes=2199023985135,offsetsTopicReplicationFactor=3"

但是,如果部署Kafdrop ui并检查当我的nestjs项目向Kafka集群发送消息时自动创建的测试主题,它显示主题有一个Partition和一个Replication。
自定义参数无效。
我错过什么了吗?

kx5bkwkv

kx5bkwkv1#

您应该比较此文件中的参数。
https://github.com/bitnami/charts/blob/main/bitnami/kafka/values.yaml
replicaCount参数不存在。正确的参数是controller.replicaCountbroker.replicaCountzookeeper.replicaCount
extraConfig参数要求值之间用换行符分隔,如果在一行上,则必须使用;。正确的配置应该是

extraConfig="logRetentionHours=-1;logRetentionBytes=2199023985135;offsetsTopicReplicationFactor=3"

如果您想在多行配置extraConfig参数,可以参考here
此外,您可以使用以下内容来比较是否已应用值。

helm template kafka bitnami/kafka > output-default.yaml
helm template kafka bitnami/kafka --set replicaCount=3,provisioning.enabled=true,provisioning.replicationFactor=3,provisioning.numPartitions=3,extraConfig="logRetentionHours=-1,logRetentionBytes=2199023985135,offsetsTopicReplicationFactor=3" > output-custom.yaml

然后,比较两个文件output-default.yamloutput-custom.yaml以检查差异。

相关问题