私は kafka プロデューサーを作成しており、メッセージ タイプに従ってメッセージを送信する際に partitionId も指定したいと考えています。Mysql テーブルに type-partitonId マッピングがあります。新しいメッセージ タイプの場合、新しいパーティションを作成し、その ID を Mysql に保存して、次に同じタイプが来たときにその ID にメッセージを直接送信できるようにする必要があります。トピックの新しいパーティションを作成し、作成された partitionId を取得するにはどうすればよいですか? 最新のカフカ API .9 と Java 1.8 を使用しています。