2016-12-19 8 views
0

からパーティションを作成/削除(0.10)プログラムによる(JAVA)私はプログラム的に(使用してJava)の作成/ Iは、Java Apacheのカフカクライアント(0.10)とApacheカフカのインストールを使用していますカフカトピックから</p> <p>をパーティションを削除することができ、カフカトピック需要ランタイムで

+0

a)あなたは**あなた自身で**これまでに試したことがありますか? b)疑問符をつけて質問を書くことに傷つけることはないでしょうか? –

+0

私は同意します。間違いなく次回からそれに続くだろう。 –

+0

あなたの質問を編集することができます –

答えて

1

AdminUtils.createTopicとAdminUtils.deleteTopicを呼び出してトピックをそれぞれ作成および削除します。

EDIT:

使用AdminUtils.addPartitionsトピックのためのパーティションを追加します。 Kafkaは現在、パーティション番号を減らすことをサポートしていません。

+0

私の質問は、トピックではなくトピックの「PARTITIONS」の作成/削除についてです。 –

関連する問題