DCOS/Mesos Kafka-Befehl zum Vergrößern der Partition

Question

Ich habe einen Kafka-Cluster, der auf Mesos läuft. Ich versuche, die Anzahl der Partitionen zu einem Thema zu erhöhen. Das funktioniert normalerweise mit bin/kafka-topics.sh - alter Befehl. Ist diese Option über dcos cli oder kafka-mesos rest API verfügbar? Von dem, was ich sehe, ist es nicht ausgesetzt.

Wenn nicht, was ist der beste Weg, um auf kafkas CLI innerhalb der mesos-Installation zuzugreifen? Im Moment benutze ich DCOs cli Broker IP und dann in einer Ad-hoc-Weise zu

/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 

Gibt es einen direkteren Weg zu bekommen?

Answer 1

Wir haben gerade eine neue Version des Kafka-Frameworks mit DC/OS 1.7 veröffentlicht. Die neue Version unterstützt die Änderung der Anzahl der Partitionen über dcos kafka [--name=frameworkname] topic partitions <topicname> <count>.

Siehe auch: Service documentation (Referenz "Alter Topic Partition Count")