我有一个Kafka集群运行在mesos上。我试图增加一个主题的分区数。这通常适用于bin/kafka-topics.sh--alter命令。此选项是否通过dcos cli或kafka mesos rest api公开?从我看来,它没有暴露。
如果没有,那么在mesos安装中访问kafka的cli的最佳方法是什么?现在,我使用dcos cli获取代理ip,然后以一种特殊的方式获取代理ip
/var/lib/mesos/slave/slaves/11aaafce-f12f-4aa8-9e5c-200b2a657225-S3/frameworks/11aaafce-f12f-4aa8-9e5c-200b2a657225-0001/executors/broker-1-7cf26bed-aa40-464b-b146-49b45b7800c7/runs/849ba6fb-b99e-4194-b90b-8c9b2bfabd7c/kafka_2.10-0.9.0.0/bin/kafka-console-consumer.sh
有更直接的方法吗?
1条答案
按热度按时间7tofc5zh1#
我们刚刚发布了带有dc/os1.7的kafka框架的新版本。新版本支持通过
dcos kafka [--name=frameworkname] topic partitions <topicname> <count>
.另请参阅:服务文档(“alter topic partition count”参考)