Auf Anfrage Laufzeit kann ich programmatisch (mit Java) erstellen/löschen Partition von Kafka ThemaProgramatically (JAVA) erstellen/löschen Partition von Kafka Thema
ich Java Apache Kafka-Client bin mit (0.10) und Apache Kafka Installation (0.10)
Rufen Sie AdminUtils.createTopic und AdminUtils.deleteTopic auf, um Themen zu erstellen bzw. zu löschen.
EDIT:
Verwenden AdminUtils.addPartitions hinzuzufügen Partitionen für ein Thema. Kafka unterstützt derzeit nicht, die Partitionsnummer zu verringern.
Meine Abfrage ist über erstellen/löschen "PARTITIONS" eines Themas und nicht Thema. –
a) Was hast du ** bisher selbst versucht? b) Es würde dir nicht schaden, deine Fragen mit ein paar Fragezeichen zu schreiben, oder? –
Ich stimme zu. Würde es dem nächsten Mal definitiv folgen. –
Sie können Ihre Frage bearbeiten –