Reactive Kafka：存在しないトピックのストリームを作成中にエラーはありません

Question

最近Reactive Kafkaに切り替えました。トピックのストリームを作成中にトピックが存在する場合、kafkaはエラーをスローしません。それはなぜそうですか？

私はトピックの存在がAdminUtils.topicExists(zkClient, topicName)で明示的に確認できることを知っています。ストリームを作成する前にトピックがそれ自身で存在するかどうかを確認するために、反応的なカフカに確認する方法はありますか？

Answer 1

これは、Kafka Brokerの設定で設定できます。関連する設定はauto.create.topics.enableで、デフォルトではtrueです。これをfalseに設定すると、新しいトピックを自動的に作成するのではなく、トピックが存在しない場合に、基礎となるApache Kafkaクライアントがエラーをスローするようになります。

詳細については、docsを参照してください。