Reaktives Kafka: Kein Fehler beim Erstellen eines Streams für ein nicht vorhandenes Thema

Question

Wir haben kürzlich zu Reactive Kafka gewechselt. Es scheint, dass kafka keinen Fehler auslöst, wenn das Thema beim Erstellen des Streams für das Thema existiert. Wieso ist es so?

Ich weiß, dass die Existenz eines Themas explizit mit AdminUtils.topicExists(zkClient, topicName) überprüft werden kann. Gibt es eine Möglichkeit, reaktives Kafka dazu zu zwingen, vor dem Erstellen von Streams zu prüfen, ob das Thema selbst existiert?

Answer 1

Dies kann in den Einstellungen des Kafka Brokers konfiguriert werden. Die zugehörige Konfiguration lautet auto.create.topics.enable und ist standardmäßig richtig. Wenn Sie den Wert auf "false" setzen, sollte der zugrunde liegende Apache Kafka-Client einen Fehler auslösen, wenn kein Thema vorhanden ist, anstatt automatisch ein neues Thema zu erstellen.

Weitere Informationen finden Sie unter docs.