我在一个项目中使用kafka,具体来说,我使用的是合流云的托管kafka。我需要更新我的代理配置(特别是字段offsets.retention.minutes),但我在的时候有点不知所措--应该怎么做。他们的在线控制台没有提供任何方法让我看到,我已经尝试使用他们专有的“confluent”CLI,声称能够完成我想要的事情(通过:https://docs.confluent.io/confluent-cli/current/command-reference/kafka/broker/confluent_kafka_broker_update.html#confluent-kafka-broker-update),但是我必须向该工具传递一个URL才能执行特定的命令(其他命令运行良好,但代理命令不起作用),当我传递汇流云UI中提供的默认REST URL时,该工具失败了。
但是,为了完整起见,我尝试运行的命令有以下形式:
confluent kafka broker update --all --url https://<CLUSTER_ID>.us-west1.gcp.confluent.cloud:443 --config offsets.retention.minutes=262800其结果是:“错误:无法建立卡夫卡REST连接: https://.us-west1.gcp.confluent.cloud:44/v3:拨号tcp 35.247.31.53:44: i/o超时”(它似乎在做一些非常奇怪的事情,因为它降低了端口号.
confluent kafka broker update --all --url https://<CLUSTER_ID>.us-west1.gcp.confluent.cloud --config offsets.retention.minutes=262800产生:“错误: REST请求失败:未找到(0)”
confluent kafka broker update --all --url https://<CLUSTER_ID>.us-west1.gcp.confluent.cloud:443/kafka --config offsets.retention.minutes=262800结果是:"Error: REST请求失败:HTTP404Notfind ( 404 )“(至少这是一个更正常的错误)。
我在网上看到了有关登录到代理和手动更改server.properties文件以包括我的配置和手动重新启动服务器的引用,我对此非常满意,但我看不到任何能够登录的具体机器来完成这一任务。
那么,如何在Cloud的managed产品中设置代理配置值呢?我是一个付费客户,如果这是重要的原因。
发布于 2022-12-01 18:30:44
显然,我的问题的答案是,我不能在合流云上改变这个设置。如果为专用群集付费,可以更改群集设置,但如果这样做,则只能更改代理配置字段的一小部分,而“offsets.retention.minutes”不是其中之一。
来自:https://docs.confluent.io/platform/current/installation/configuration/topic-configs.html#compaction
您不能在基本群集或标准群集上的合流云上编辑群集设置,但可以在创建主题之后编辑某些主题配置。有关可编辑主题设置的列表,请参阅所有群集类型的自定义主题设置。您可以使用Kafka或REST在专用集群上更改一些配置设置。请参阅更改专用群集的群集设置。
对一位非常有帮助的汇合支持代表表示赞许,他用一些有用的链接回答了一段文档反馈,这些链接使我找到了这些信息。
https://stackoverflow.com/questions/74635167
复制相似问题